Uses of Interface
org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator
Package
Description
Handles the special "columns" column used by the text reader,
and available to similar readers.
Handles optional file metadata columns: implicit columns and
partition columns.
Defines the projection, vector continuity and other operations for
a set of one or more readers.
Kafka storage plugin.
Defines a mock data source which generates dummy test data for use
in testing.
-
Uses of SchemaNegotiator in org.apache.drill.exec.physical.impl.scan.columns
Modifier and TypeInterfaceDescriptioninterface
Schema negotiator that supports the file scan options plus access to the specific selected columns indexes.Modifier and TypeClassDescriptionstatic class
Implementation of the columns array schema negotiator. -
Uses of SchemaNegotiator in org.apache.drill.exec.physical.impl.scan.file
Modifier and TypeInterfaceDescriptionstatic interface
The file schema negotiator adds no behavior at present, but is created as a placeholder anticipating the need for file-specific behavior later.Modifier and TypeClassDescriptionstatic class
Implementation of the file-level schema negotiator.Modifier and TypeMethodDescriptionManagedReader<? extends SchemaNegotiator>
FileScanFramework.FileReaderFactory.next()
-
Uses of SchemaNegotiator in org.apache.drill.exec.physical.impl.scan.framework
Modifier and TypeInterfaceDescriptioninterface
ManagedReader<T extends SchemaNegotiator>
Extended version of a record reader which uses a size-aware batch mutator.Modifier and TypeClassDescriptionclass
Implementation of the schema negotiation between scan operator and batch reader.Modifier and TypeFieldDescriptionprotected final ManagedReader<? extends SchemaNegotiator>
ShimBatchReader.reader
Modifier and TypeMethodDescriptionManagedReader<? extends SchemaNegotiator>
BasicScanFactory.next()
ManagedReader<? extends SchemaNegotiator>
ManagedScanFramework.ReaderFactory.next()
ManagedReader<? extends SchemaNegotiator>
ShimBatchReader.reader()
ModifierConstructorDescriptionBasicScanFactory
(Iterator<ManagedReader<SchemaNegotiator>> iterator) ShimBatchReader
(ManagedScanFramework manager, ManagedReader<? extends SchemaNegotiator> reader) -
Uses of SchemaNegotiator in org.apache.drill.exec.store.easy.json
Modifier and TypeMethodDescriptionboolean
JsonStreamBatchReader.open
(SchemaNegotiator negotiator) -
Uses of SchemaNegotiator in org.apache.drill.exec.store.enumerable
Modifier and TypeMethodDescriptionboolean
EnumerableRecordReader.open
(SchemaNegotiator negotiator) -
Uses of SchemaNegotiator in org.apache.drill.exec.store.googlesheets
Modifier and TypeMethodDescriptionboolean
GoogleSheetsBatchReader.open
(SchemaNegotiator negotiator) -
Uses of SchemaNegotiator in org.apache.drill.exec.store.http
Modifier and TypeMethodDescriptionboolean
HttpBatchReader.open
(SchemaNegotiator negotiator) boolean
HttpCSVBatchReader.open
(SchemaNegotiator negotiator) boolean
HttpXMLBatchReader.open
(SchemaNegotiator negotiator) -
Uses of SchemaNegotiator in org.apache.drill.exec.store.iceberg.read
-
Uses of SchemaNegotiator in org.apache.drill.exec.store.jdbc
-
Uses of SchemaNegotiator in org.apache.drill.exec.store.kafka
-
Uses of SchemaNegotiator 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) -
Uses of SchemaNegotiator in org.apache.drill.exec.store.mock
Modifier and TypeMethodDescriptionboolean
ExtendedMockBatchReader.open
(SchemaNegotiator schemaNegotiator) -
Uses of SchemaNegotiator in org.apache.drill.exec.store.phoenix
-
Uses of SchemaNegotiator in org.apache.drill.exec.store.splunk