Modifier and Type | Class and Description |
---|---|
static class |
FileRecordFormatAdapter.Reader<T>
The reader adapter, from
FileRecordFormat.Reader to BulkFormat.Reader . |
static class |
StreamFormatAdapter.Reader<T>
The reader adapter, from
StreamFormat.Reader to BulkFormat.Reader . |
Modifier and Type | Method and Description |
---|---|
BulkFormat.Reader<T> |
StreamFormatAdapter.createReader(Configuration config,
FileSourceSplit split) |
BulkFormat.Reader<T> |
FileRecordFormatAdapter.createReader(Configuration config,
FileSourceSplit split) |
BulkFormat.Reader<T> |
StreamFormatAdapter.restoreReader(Configuration config,
FileSourceSplit split) |
BulkFormat.Reader<T> |
FileRecordFormatAdapter.restoreReader(Configuration config,
FileSourceSplit split) |
Modifier and Type | Method and Description |
---|---|
BulkFormat.Reader<T> |
BulkFormat.createReader(Configuration config,
SplitT split)
Creates a new reader that reads from the
split's path starting
at the FileSourceSplit.offset() split's offset} and reads length bytes after the offset. |
BulkFormat.Reader<T> |
BulkFormat.restoreReader(Configuration config,
SplitT split)
Creates a new reader that reads from
split.path() starting at offset and
reads until length bytes after the offset. |
Modifier and Type | Method and Description |
---|---|
static <T> void |
Utils.forEachRemaining(BulkFormat.Reader<T> reader,
java.util.function.Consumer<? super T> action)
Performs the given action for each remaining element in
BulkFormat.Reader until all
elements have been processed or the action throws an exception. |
Modifier and Type | Method and Description |
---|---|
BulkFormat.Reader<RowData> |
HiveBulkFormatAdapter.createReader(Configuration config,
HiveSourceSplit split) |
BulkFormat.Reader<RowData> |
HiveBulkFormatAdapter.restoreReader(Configuration config,
HiveSourceSplit split) |
Modifier and Type | Class and Description |
---|---|
protected static class |
AbstractOrcFileInputFormat.OrcVectorizedReader<T,BatchT>
A vectorized ORC reader.
|
Modifier and Type | Method and Description |
---|---|
BulkFormat.Reader<T> |
LimitableBulkFormat.createReader(Configuration config,
SplitT split) |
BulkFormat.Reader<T> |
LimitableBulkFormat.restoreReader(Configuration config,
SplitT split) |
Constructor and Description |
---|
CompactBulkReader(BulkFormat.Reader<T> reader) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.