Class | Description |
---|---|
IngestFromKafkaDriver |
This class executes the ingestion of intermediate data from a Kafka topic into GeoWave.
|
KafkaCommandLineArgument | |
KafkaCommandLineOptions | |
KafkaConsumerCommandLineOptions | |
KafkaIngestRunData |
A class to hold intermediate run data that must be used throughout the life of an ingest process.
|
KafkaProducerCommandLineOptions | |
StageKafkaData<T extends org.apache.avro.specific.SpecificRecordBase> |
A class to hold intermediate stage data that must be used throughout the life of the Kafka stage
process.
|
StageToKafkaDriver<T extends org.apache.avro.specific.SpecificRecordBase> |
This class actually executes the staging of data to a Kafka topic based on the available type
plugin providers that are discovered through SPI.
|
Annotation Type | Description |
---|---|
PropertyReference |
This is just a hack to get access to the property name that we need to overwrite in the kafka
config property file.
|
Copyright © 2013–2022. All rights reserved.