| Modifier and Type | Class and Description |
|---|---|
protected static class |
BaseScanOperatorExecTest.BaseMockBatchReader
Base class for the "mock" readers used in this test.
|
protected static class |
BaseScanOperatorExecTest.MockEarlySchemaReader
Mock reader that pretends to have a schema at open time
like an HBase or JDBC reader.
|
static class |
TestColumnsArrayFramework.DummyColumnsReader |
| Modifier and Type | Field and Description |
|---|---|
List<ManagedReader<SchemaNegotiator>> |
BaseScanOperatorExecTest.BaseScanFixtureBuilder.readers |
| Modifier and Type | Method and Description |
|---|---|
ManagedReader<? extends FileScanFramework.FileSchemaNegotiator> |
TestFileScanFramework.MockFileReaderFactory.newReader() |
ManagedReader<? extends FileScanFramework.FileSchemaNegotiator> |
TestColumnsArrayFramework.MockFileReaderFactory.newReader() |
| Modifier and Type | Method and Description |
|---|---|
void |
BaseScanOperatorExecTest.BaseScanFixtureBuilder.addReader(ManagedReader<SchemaNegotiator> reader) |
void |
BaseScanOperatorExecTest.BaseScanFixtureBuilder.addReaders(ManagedReader<SchemaNegotiator>... readers) |
static BaseScanOperatorExecTest.BaseScanFixtureBuilder |
BaseScanOperatorExecTest.simpleBuilder(ManagedReader<SchemaNegotiator>... readers) |
static ScanTestUtils.ScanFixture |
BaseScanOperatorExecTest.simpleFixture(ManagedReader<SchemaNegotiator>... readers) |
| Modifier and Type | Method and Description |
|---|---|
void |
BaseScanOperatorExecTest.BaseScanFixtureBuilder.addReaders(List<ManagedReader<SchemaNegotiator>> readers) |
| Modifier and Type | Method and Description |
|---|---|
abstract ManagedReader<? extends FileScanFramework.FileSchemaNegotiator> |
FileScanFramework.FileReaderFactory.newReader() |
ManagedReader<? extends SchemaNegotiator> |
FileScanFramework.FileReaderFactory.next() |
| Modifier and Type | Field and Description |
|---|---|
protected ManagedReader<? extends SchemaNegotiator> |
ShimBatchReader.reader |
| Modifier and Type | Method and Description |
|---|---|
ManagedReader<? extends SchemaNegotiator> |
BasicScanFactory.next() |
ManagedReader<? extends SchemaNegotiator> |
ManagedScanFramework.ReaderFactory.next() |
ManagedReader<? extends SchemaNegotiator> |
ShimBatchReader.reader() |
| Constructor and Description |
|---|
ShimBatchReader(ManagedScanFramework manager,
ManagedReader<? extends SchemaNegotiator> reader) |
| Constructor and Description |
|---|
BasicScanFactory(Iterator<ManagedReader<SchemaNegotiator>> iterator) |
| Modifier and Type | Class and Description |
|---|---|
class |
AvroBatchReader |
| Modifier and Type | Method and Description |
|---|---|
ManagedReader<? extends FileScanFramework.FileSchemaNegotiator> |
EasyFormatPlugin.newBatchReader(EasySubScan scan,
OptionManager options) |
| Modifier and Type | Class and Description |
|---|---|
class |
SequenceFileBatchReader |
| Modifier and Type | Method and Description |
|---|---|
ManagedReader<? extends FileScanFramework.FileSchemaNegotiator> |
SequenceFileFormatPlugin.newBatchReader(EasySubScan scan,
OptionManager options) |
| Modifier and Type | Class and Description |
|---|---|
class |
CompliantTextBatchReader
Text reader, Complies with the RFC 4180 standard for text/csv files.
|
| Modifier and Type | Class and Description |
|---|---|
class |
EnumerableRecordReader
ManagedReader implementation that compiles and executes specified code,
calls the method on it for obtaining the values, and reads the results using column converters. |
| Modifier and Type | Class and Description |
|---|---|
class |
ShpBatchReader |
| Modifier and Type | Method and Description |
|---|---|
ManagedReader<? extends FileScanFramework.FileSchemaNegotiator> |
ShpFormatPlugin.newBatchReader(EasySubScan scan,
OptionManager options) |
ManagedReader<? extends FileScanFramework.FileSchemaNegotiator> |
ShpFormatPlugin.ShpReaderFactory.newReader() |
| Modifier and Type | Class and Description |
|---|---|
class |
ExcelBatchReader |
| Modifier and Type | Method and Description |
|---|---|
ManagedReader<? extends FileScanFramework.FileSchemaNegotiator> |
ExcelFormatPlugin.newBatchReader(EasySubScan scan,
OptionManager options) |
| Modifier and Type | Class and Description |
|---|---|
class |
HDF5BatchReader |
| Modifier and Type | Method and Description |
|---|---|
ManagedReader<? extends FileScanFramework.FileSchemaNegotiator> |
HDF5FormatPlugin.HDF5ReaderFactory.newReader() |
| Modifier and Type | Class and Description |
|---|---|
class |
HttpBatchReader |
class |
HttpCSVBatchReader |
class |
HttpXMLBatchReader |
| Modifier and Type | Class and Description |
|---|---|
class |
HttpdLogBatchReader |
| Modifier and Type | Method and Description |
|---|---|
ManagedReader<? extends FileScanFramework.FileSchemaNegotiator> |
HttpdLogFormatPlugin.newBatchReader(EasySubScan scan,
OptionManager options) |
| Modifier and Type | Class and Description |
|---|---|
class |
ImageBatchReader |
| Modifier and Type | Method and Description |
|---|---|
ManagedReader<? extends FileScanFramework.FileSchemaNegotiator> |
ImageFormatPlugin.newBatchReader(EasySubScan scan,
OptionManager options) |
| Modifier and Type | Class and Description |
|---|---|
class |
KafkaRecordReader |
| Modifier and Type | Class and Description |
|---|---|
class |
LogBatchReader |
| Modifier and Type | Class and Description |
|---|---|
class |
ExtendedMockBatchReader
Extended form of the mock record reader that uses generator class
instances to create the mock values.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PcapBatchReader |
| Modifier and Type | Method and Description |
|---|---|
ManagedReader<? extends FileScanFramework.FileSchemaNegotiator> |
BasePcapFormatPlugin.newBatchReader(EasySubScan scan,
OptionManager options) |
| Modifier and Type | Class and Description |
|---|---|
class |
PcapngBatchReader |
| Modifier and Type | Class and Description |
|---|---|
class |
SplunkBatchReader |
| Modifier and Type | Class and Description |
|---|---|
class |
SpssBatchReader |
| Modifier and Type | Method and Description |
|---|---|
ManagedReader<? extends FileScanFramework.FileSchemaNegotiator> |
SpssFormatPlugin.newBatchReader(EasySubScan scan,
OptionManager options) |
| Modifier and Type | Class and Description |
|---|---|
class |
SyslogBatchReader |
| Modifier and Type | Method and Description |
|---|---|
ManagedReader<? extends FileScanFramework.FileSchemaNegotiator> |
SyslogFormatPlugin.newBatchReader(EasySubScan scan,
OptionManager options) |
| Modifier and Type | Class and Description |
|---|---|
class |
XMLBatchReader |
| Modifier and Type | Method and Description |
|---|---|
ManagedReader<? extends FileScanFramework.FileSchemaNegotiator> |
XMLFormatPlugin.newBatchReader(EasySubScan scan,
OptionManager options) |
ManagedReader<? extends FileScanFramework.FileSchemaNegotiator> |
XMLFormatPlugin.XMLReaderFactory.newReader() |
Copyright © 2021 The Apache Software Foundation. All rights reserved.