Package io.deephaven.kafka.ingest

Interface Summary

Interface	Description
ConsumerRecordToTableWriterAdapter	Converter from a stream of Kafka records to a table writer.
JsonRecordSetter	An interface for RowSetters that obtain their values from JSON objects.

Class Summary

Class	Description
AvroDiscovery	A builder for generating a Deephaven schema from an Avro schema.
GenericRecordConsumerRecordToTableWriterAdapter	Convert an Avro GenericRecord to Deephaven rows.
GenericRecordConsumerRecordToTableWriterAdapter.Builder	A builder to map key and value fields to table columns.
JsonConsumerRecordToTableWriterAdapter	Converts a consumer record containing JSON serialized objects to a Deephaven row.
JsonConsumerRecordToTableWriterAdapter.Builder	A builder to map key and value fields to table columns.
JsonRecord	Provides convenience methods to facilitate parsing of a JSON String and extraction of typed values.
JsonRecordUtil	Provides methods and classes for retrieving typed values from a JsonRecord.
JsonRecordUtil.JsonBigDecimalSetter	Provides a BigDecimal-typed set method to call a RowSetter set method and populate it with a value from a JsonRecord.
JsonRecordUtil.JsonBigIntegerSetter	Provides a BigInteger-typed set method to call a RowSetter set method and populate it with a value from a JsonRecord.
JsonRecordUtil.JsonBooleanSetter	Provides a Boolean-typed set method to call a RowSetter set method and populate it with a value from a JsonRecord.
JsonRecordUtil.JsonDateTimeSetter	Provides a Deephaven DBDateTime-typed set method to call a RowSetter set method and populate it with a value from a JsonRecord.
JsonRecordUtil.JsonDoubleSetter	Provides a Deephaven double-typed set method to call a RowSetter set method and populate it with a value from a JsonRecord.
JsonRecordUtil.JsonFloatSetter	Provides a Deephaven float-typed set method to call a RowSetter set method and populate it with a value from a JsonRecord.
JsonRecordUtil.JsonIntSetter	Provides a Deephaven int-typed set method to call a RowSetter set method and populate it with a value from a JsonRecord.
JsonRecordUtil.JsonLongSetter	Provides a Deephaven long-typed set method to call a RowSetter set method and populate it with a value from a JsonRecord.
JsonRecordUtil.JsonSetter	Provides a generic Object set method to call a RowSetter set method and populate it with a value from a JsonRecord.
JsonRecordUtil.JsonShortSetter	Provides a Deephaven short-typed set method to call a RowSetter set method and populate it with a value from a JsonRecord.
JsonRecordUtil.JsonStringSetter	Provides a String-typed set method to call a RowSetter set method and populate it with a value from a JsonRecord.
KafkaIngester	An intraday ingester that replicates a Apache Kafka topic to a Deephaven Data Import Server.
KafkaIngester.PartitionRange	A predicate for handling a range of partitions.
KafkaIngester.PartitionRoundRobin	A predicate for evenly distributing partitions among a set of ingesters.
KafkaIngester.SinglePartition	A predicate for handling a single partition.
PojoConsumerRecordToTableWriterAdapter<K,V>	Converts a consumer record containing Java objects to a Deephaven row.
PojoConsumerRecordToTableWriterAdapter.Builder	A builder for the PojoConsumerRecordToTableWriterAdapter.
ProtobufConsumerRecordToTableWriterAdapter	Converts a consumer record containing ProtoBuf serialized objects to a Deephaven row.
ProtobufConsumerRecordToTableWriterAdapter.Builder	A builder to map key and value fields to table columns.
ProtobufDiscovery
ResumeImportFrom	Utility to copy source file records from one checkpoint to another, with zero size so that a Kafka import resumes from where it left off.
SchemaDiscovery
SimpleConsumerRecordToTableWriterAdapter	An adapter that maps keys and values to single Deephaven columns.

Enum Summary

Enum	Description
ResumeImportFrom.Behavior	What behavior should we provide when an existing partition is encountered?

Exception Summary

Exception	Description
KafkaIngesterException	This exception is thrown when there is a failure to consume a Kafka record during Kafka to Deephaven ingestion.
ResumeImportFrom.NoPriorPartitionsFoundException