public class RawFileSplitRead extends Object implements SplitRead<InternalRow>
Constructor and Description |
---|
RawFileSplitRead(FileIO fileIO,
SchemaManager schemaManager,
TableSchema schema,
RowType rowType,
FileFormatDiscover formatDiscover,
FileStorePathFactory pathFactory,
boolean fileIndexReadEnabled) |
Modifier and Type | Method and Description |
---|---|
RecordReader<InternalRow> |
createReader(BinaryRow partition,
int bucket,
List<DataFileMeta> files,
List<IOExceptionSupplier<DeletionVector>> dvFactories) |
RecordReader<InternalRow> |
createReader(DataSplit split)
Create a
RecordReader from split. |
SplitRead<InternalRow> |
forceKeepDelete() |
RawFileSplitRead |
withFilter(Predicate predicate) |
SplitRead<InternalRow> |
withIOManager(IOManager ioManager) |
SplitRead<InternalRow> |
withReadType(RowType readRowType) |
public RawFileSplitRead(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, RowType rowType, FileFormatDiscover formatDiscover, FileStorePathFactory pathFactory, boolean fileIndexReadEnabled)
public SplitRead<InternalRow> forceKeepDelete()
forceKeepDelete
in interface SplitRead<InternalRow>
public SplitRead<InternalRow> withIOManager(@Nullable IOManager ioManager)
withIOManager
in interface SplitRead<InternalRow>
public SplitRead<InternalRow> withReadType(RowType readRowType)
withReadType
in interface SplitRead<InternalRow>
public RawFileSplitRead withFilter(Predicate predicate)
withFilter
in interface SplitRead<InternalRow>
public RecordReader<InternalRow> createReader(DataSplit split) throws IOException
SplitRead
RecordReader
from split.createReader
in interface SplitRead<InternalRow>
IOException
public RecordReader<InternalRow> createReader(BinaryRow partition, int bucket, List<DataFileMeta> files, @Nullable List<IOExceptionSupplier<DeletionVector>> dvFactories) throws IOException
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.