Uses of Class
org.apache.drill.exec.store.kafka.ReadOptions
-
Uses of ReadOptions in org.apache.drill.exec.store.kafka.decoders
Modifier and TypeMethodDescriptionvoid
AvroMessageReader.init
(SchemaNegotiator negotiator, ReadOptions readOptions, KafkaStoragePlugin plugin) void
JsonMessageReader.init
(SchemaNegotiator negotiator, ReadOptions readOptions, KafkaStoragePlugin plugin) void
MessageReader.init
(SchemaNegotiator negotiator, ReadOptions readOptions, KafkaStoragePlugin plugin)