Package io.deephaven.kafka.ingest
package io.deephaven.kafka.ingest
-
ClassDescriptionA builder for generating a Deephaven schema from an Avro schema.Converter from a stream of Kafka records to a table writer.Convert an Avro
GenericRecordto Deephaven rows.A builder to map key and value fields to table columns.Converts a consumer record containing JSON serialized objects to a Deephaven row.A builder to map key and value fields to table columns.Provides convenience methods to facilitate parsing of a JSON String and extraction of typed values.An interface for retrieving type-aware values from JSON objects.Provides methods and classes for retrieving typed values from aJsonRecord.Provides a BigDecimal-typed set method to call aRowSetterset method and populate it with a value from aJsonRecord.Provides a BigInteger-typed set method to call aRowSetterset method and populate it with a value from aJsonRecord.Provides a Boolean-typed set method to call aRowSetterset method and populate it with a value from aJsonRecord.Provides a Byte-typed set method to call aRowSetterset method and populate it with a value from aJsonRecord.Provides a Char-typed set method to call aRowSetterset method and populate it with a value from aJsonRecord.Provides a DeephavenDBDateTime-typed set method to call aRowSetterset method and populate it with a value from aJsonRecord.Provides a Deephaven double-typed set method to call aRowSetterset method and populate it with a value from aJsonRecord.Provides a Deephaven float-typed set method to call aRowSetterset method and populate it with a value from aJsonRecord.Provides a generic Object set method to call aRowSetterset method and populate it with a value from aJsonRecord.Provides a Deephaven int-typed set method to call aRowSetterset method and populate it with a value from aJsonRecord.Provides a Deephaven long-typed set method to call aRowSetterset method and populate it with a value from aJsonRecord.Provides a Deephaven short-typed set method to call aRowSetterset method and populate it with a value from aJsonRecord.Provides a String-typed set method to call aRowSetterset method and populate it with a value from aJsonRecord.An intraday ingester that replicates a Apache Kafka topic to a Deephaven Data Import Server.A predicate for handling a range of partitions.A predicate for evenly distributing partitions among a set of ingesters.A predicate for handling a single partition.This exception is thrown when there is a failure to consume a Kafka record during Kafka to Deephaven ingestion.A utility intended to assist in parallel-parsing inbound messages from a Kafka broker while ensuring that row(s) are written to disk in the order corresponding to the order in which they were sent to the utility.Converts a consumer record containing Java objects to a Deephaven row.A builder for the PojoConsumerRecordToTableWriterAdapter.Converts a consumer record containing ProtoBuf serialized objects to a Deephaven row.A builder to map key and value fields to table columns.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.What behavior should we provide when an existing partition is encountered?An adapter that maps keys and values to single Deephaven columns.