Uses of Interface
org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator

Packages that use SchemaNegotiator

Package	Description
org.apache.drill.exec.physical.impl.scan	Defines the scan operation implementation.
org.apache.drill.exec.physical.impl.scan.columns	Handles the special "columns" column used by the text reader, and available to similar readers.
org.apache.drill.exec.physical.impl.scan.file	Handles optional file metadata columns: implicit columns and partition columns.
org.apache.drill.exec.physical.impl.scan.framework	Defines the projection, vector continuity and other operations for a set of one or more readers.
org.apache.drill.exec.store.enumerable
org.apache.drill.exec.store.http
org.apache.drill.exec.store.kafka	Kafka storage plugin.
org.apache.drill.exec.store.kafka.decoders
org.apache.drill.exec.store.mock	Defines a mock data source which generates dummy test data for use in testing.
org.apache.drill.exec.store.splunk

Uses of SchemaNegotiator in org.apache.drill.exec.physical.impl.scan

Fields in org.apache.drill.exec.physical.impl.scan with type parameters of type SchemaNegotiator

Modifier and Type	Field and Description
List<ManagedReader<SchemaNegotiator>>	BaseScanOperatorExecTest.BaseScanFixtureBuilder.readers

Methods in org.apache.drill.exec.physical.impl.scan with parameters of type SchemaNegotiator

Modifier and Type	Method and Description
boolean	BaseScanOperatorExecTest.MockEarlySchemaReader.open(SchemaNegotiator schemaNegotiator)

Method parameters in org.apache.drill.exec.physical.impl.scan with type arguments of type SchemaNegotiator

Modifier and Type	Method and Description
void	BaseScanOperatorExecTest.BaseScanFixtureBuilder.addReader(ManagedReader<SchemaNegotiator> reader)
void	BaseScanOperatorExecTest.BaseScanFixtureBuilder.addReaders(List<ManagedReader<SchemaNegotiator>> readers)

Uses of SchemaNegotiator in org.apache.drill.exec.physical.impl.scan.columns

Subinterfaces of SchemaNegotiator in org.apache.drill.exec.physical.impl.scan.columns

Modifier and Type	Interface and Description
interface	ColumnsSchemaNegotiator Schema 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 SchemaNegotiator

Modifier and Type	Class and Description
static class	ColumnsScanFramework.ColumnsSchemaNegotiatorImpl Implementation 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.file

Modifier and Type	Interface and Description
static interface	FileScanFramework.FileSchemaNegotiator The 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 SchemaNegotiator

Modifier and Type	Class and Description
static class	FileScanFramework.FileSchemaNegotiatorImpl Implementation of the file-level schema negotiator.

Methods in org.apache.drill.exec.physical.impl.scan.file that return types with arguments of type SchemaNegotiator

Modifier and Type	Method and Description
ManagedReader<? 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 SchemaNegotiator

Modifier and Type	Interface and Description
interface	ManagedReader<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 SchemaNegotiator

Modifier and Type	Class and Description
class	SchemaNegotiatorImpl Implementation 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 SchemaNegotiator

Modifier and Type	Field and Description
protected ManagedReader<? extends SchemaNegotiator>	ShimBatchReader.reader

Methods in org.apache.drill.exec.physical.impl.scan.framework that return types with arguments of type SchemaNegotiator

Modifier and Type	Method and Description
ManagedReader<? 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 SchemaNegotiator

Constructor and Description
BasicScanFactory(Iterator<ManagedReader<SchemaNegotiator>> iterator)
ShimBatchReader(ManagedScanFramework manager, ManagedReader<? extends SchemaNegotiator> reader)

Uses of SchemaNegotiator in org.apache.drill.exec.store.enumerable

Methods in org.apache.drill.exec.store.enumerable with parameters of type SchemaNegotiator

Modifier and Type	Method and Description
boolean	EnumerableRecordReader.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 SchemaNegotiator

Modifier and Type	Method and Description
boolean	HttpBatchReader.open(SchemaNegotiator negotiator)
boolean	HttpXMLBatchReader.open(SchemaNegotiator negotiator)
boolean	HttpCSVBatchReader.open(SchemaNegotiator negotiator)

Uses of SchemaNegotiator in org.apache.drill.exec.store.kafka

Methods in org.apache.drill.exec.store.kafka with parameters of type SchemaNegotiator

Modifier and Type	Method and Description
boolean	KafkaRecordReader.open(SchemaNegotiator negotiator)

Uses of SchemaNegotiator in org.apache.drill.exec.store.kafka.decoders

Methods in org.apache.drill.exec.store.kafka.decoders with parameters of type SchemaNegotiator

Modifier and Type	Method and Description
void	AvroMessageReader.init(SchemaNegotiator negotiator, ReadOptions readOptions, KafkaStoragePlugin plugin)
void	MessageReader.init(SchemaNegotiator negotiator, ReadOptions readOptions, KafkaStoragePlugin plugin)
void	JsonMessageReader.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 SchemaNegotiator

Modifier and Type	Method and Description
boolean	ExtendedMockBatchReader.open(SchemaNegotiator schemaNegotiator)

Uses of SchemaNegotiator in org.apache.drill.exec.store.splunk

Methods in org.apache.drill.exec.store.splunk with parameters of type SchemaNegotiator

Modifier and Type	Method and Description
boolean	SplunkBatchReader.open(SchemaNegotiator negotiator)