Modifier and Type | Class and Description |
---|---|
static class |
FileRecordFormatAdapter.Reader<T>
Deprecated.
This interface is Deprecated, use
StreamFormatAdapter.Reader instead. |
static class |
StreamFormatAdapter.Reader<T>
The reader adapter, from
StreamFormat.Reader to BulkFormat.Reader . |
Modifier and Type | Method and Description |
---|---|
BulkFormat.Reader<T> |
FileRecordFormatAdapter.createReader(Configuration config,
FileSourceSplit split)
Deprecated.
|
BulkFormat.Reader<T> |
StreamFormatAdapter.createReader(Configuration config,
FileSourceSplit split) |
BulkFormat.Reader<T> |
FileRecordFormatAdapter.restoreReader(Configuration config,
FileSourceSplit split)
Deprecated.
|
BulkFormat.Reader<T> |
StreamFormatAdapter.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 <I,O> BulkFormat.Reader<O> |
RecordMapperWrapperRecordIterator.wrapReader(BulkFormat.Reader<I> wrappedReader,
RecordMapperWrapperRecordIterator.RecordMapper<I,O> recordMapper)
Wrap a
BulkFormat.Reader applying a RecordMapperWrapperRecordIterator.RecordMapper on the returned iterator. |
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. |
static <I,O> BulkFormat.Reader<O> |
RecordMapperWrapperRecordIterator.wrapReader(BulkFormat.Reader<I> wrappedReader,
RecordMapperWrapperRecordIterator.RecordMapper<I,O> recordMapper)
Wrap a
BulkFormat.Reader applying a RecordMapperWrapperRecordIterator.RecordMapper on the returned iterator. |
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) |
Modifier and Type | Method and Description |
---|---|
BulkFormat.Reader<RowData> |
HiveInputFormat.createReader(Configuration config,
HiveSourceSplit split) |
BulkFormat.Reader<RowData> |
HiveInputFormat.restoreReader(Configuration config,
HiveSourceSplit split) |
Modifier and Type | Class and Description |
---|---|
protected static class |
AbstractOrcFileInputFormat.OrcVectorizedReader<T,BatchT>
A vectorized ORC reader.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.