Package io.deephaven.enterprise.kafkawriter

package io.deephaven.enterprise.kafkawriter

Classes

Class	Description
KafkaTableWriter	The KafkaTableWriter creates a Deephaven Core KafkaIngester that persists the data to disk and serves it to other queries using an in-worker instance of the DataImportServer.
KafkaTableWriter.Options	A builder class containing the options for Kafka ingestion.
TimePartitionRotation	Create functions for generating column partitions from an epoch timestamp.