Uses of Interface
org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator
Packages that use 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
Subinterfaces of SchemaNegotiator in org.apache.drill.exec.physical.impl.scan.columnsModifier and TypeInterfaceDescriptioninterfaceSchema negotiator that supports the file scan options plus access to the specific selected columns indexes.Classes in org.apache.drill.exec.physical.impl.scan.columns that implement SchemaNegotiatorModifier and TypeClassDescriptionstatic classImplementation of the columns array schema negotiator. -
Uses of SchemaNegotiator in org.apache.drill.exec.physical.impl.scan.file
Subinterfaces of SchemaNegotiator in org.apache.drill.exec.physical.impl.scan.fileModifier and TypeInterfaceDescriptionstatic interfaceThe file schema negotiator adds no behavior at present, but is created as a placeholder anticipating the need for file-specific behavior later.Classes in org.apache.drill.exec.physical.impl.scan.file that implement SchemaNegotiatorModifier and TypeClassDescriptionstatic classImplementation of the file-level schema negotiator.Methods in org.apache.drill.exec.physical.impl.scan.file that return types with arguments of type SchemaNegotiatorModifier and TypeMethodDescriptionManagedReader<? extends SchemaNegotiator> FileScanFramework.FileReaderFactory.next() -
Uses of SchemaNegotiator in org.apache.drill.exec.physical.impl.scan.framework
Classes in org.apache.drill.exec.physical.impl.scan.framework with type parameters of type SchemaNegotiatorModifier and TypeInterfaceDescriptioninterfaceManagedReader<T extends SchemaNegotiator>Extended version of a record reader which uses a size-aware batch mutator.Classes in org.apache.drill.exec.physical.impl.scan.framework that implement SchemaNegotiatorModifier and TypeClassDescriptionclassImplementation of the schema negotiation between scan operator and batch reader.Fields in org.apache.drill.exec.physical.impl.scan.framework with type parameters of type SchemaNegotiatorModifier and TypeFieldDescriptionprotected final ManagedReader<? extends SchemaNegotiator> ShimBatchReader.readerMethods in org.apache.drill.exec.physical.impl.scan.framework that return types with arguments of type SchemaNegotiatorModifier and TypeMethodDescriptionManagedReader<? extends SchemaNegotiator> BasicScanFactory.next()ManagedReader<? extends SchemaNegotiator> ManagedScanFramework.ReaderFactory.next()ManagedReader<? extends SchemaNegotiator> ShimBatchReader.reader()Constructor parameters in org.apache.drill.exec.physical.impl.scan.framework with type arguments of type SchemaNegotiatorModifierConstructorDescriptionBasicScanFactory(Iterator<ManagedReader<SchemaNegotiator>> iterator) ShimBatchReader(ManagedScanFramework manager, ManagedReader<? extends SchemaNegotiator> reader) -
Uses of SchemaNegotiator in org.apache.drill.exec.store.easy.json
Methods in org.apache.drill.exec.store.easy.json with parameters of type SchemaNegotiatorModifier and TypeMethodDescriptionbooleanJsonStreamBatchReader.open(SchemaNegotiator negotiator) -
Uses of SchemaNegotiator in org.apache.drill.exec.store.enumerable
Methods in org.apache.drill.exec.store.enumerable with parameters of type SchemaNegotiatorModifier and TypeMethodDescriptionbooleanEnumerableRecordReader.open(SchemaNegotiator negotiator) -
Uses of SchemaNegotiator in org.apache.drill.exec.store.googlesheets
Methods in org.apache.drill.exec.store.googlesheets with parameters of type SchemaNegotiatorModifier and TypeMethodDescriptionbooleanGoogleSheetsBatchReader.open(SchemaNegotiator negotiator) -
Uses of SchemaNegotiator in org.apache.drill.exec.store.http
Methods in org.apache.drill.exec.store.http with parameters of type SchemaNegotiatorModifier and TypeMethodDescriptionbooleanHttpBatchReader.open(SchemaNegotiator negotiator) booleanHttpCSVBatchReader.open(SchemaNegotiator negotiator) booleanHttpXMLBatchReader.open(SchemaNegotiator negotiator) -
Uses of SchemaNegotiator in org.apache.drill.exec.store.iceberg.read
Methods in org.apache.drill.exec.store.iceberg.read with parameters of type SchemaNegotiator -
Uses of SchemaNegotiator in org.apache.drill.exec.store.jdbc
Methods in org.apache.drill.exec.store.jdbc with parameters of type SchemaNegotiator -
Uses of SchemaNegotiator in org.apache.drill.exec.store.kafka
Methods in org.apache.drill.exec.store.kafka with parameters of type SchemaNegotiator -
Uses of SchemaNegotiator in org.apache.drill.exec.store.kafka.decoders
Methods in org.apache.drill.exec.store.kafka.decoders with parameters of type SchemaNegotiatorModifier and TypeMethodDescriptionvoidAvroMessageReader.init(SchemaNegotiator negotiator, ReadOptions readOptions, KafkaStoragePlugin plugin) voidJsonMessageReader.init(SchemaNegotiator negotiator, ReadOptions readOptions, KafkaStoragePlugin plugin) voidMessageReader.init(SchemaNegotiator negotiator, ReadOptions readOptions, KafkaStoragePlugin plugin) -
Uses of SchemaNegotiator in org.apache.drill.exec.store.mock
Methods in org.apache.drill.exec.store.mock with parameters of type SchemaNegotiatorModifier and TypeMethodDescriptionbooleanExtendedMockBatchReader.open(SchemaNegotiator schemaNegotiator) -
Uses of SchemaNegotiator in org.apache.drill.exec.store.phoenix
Methods in org.apache.drill.exec.store.phoenix with parameters of type SchemaNegotiator -
Uses of SchemaNegotiator in org.apache.drill.exec.store.splunk
Methods in org.apache.drill.exec.store.splunk with parameters of type SchemaNegotiator