public class DataSplit extends Object implements Split
Modifier and Type | Class and Description |
---|---|
static class |
DataSplit.Builder
Builder for
DataSplit . |
Constructor and Description |
---|
DataSplit() |
Modifier and Type | Method and Description |
---|---|
Optional<List<DeletionFile>> |
beforeDeletionFiles() |
List<DataFileMeta> |
beforeFiles() |
int |
bucket() |
String |
bucketPath() |
static DataSplit.Builder |
builder() |
Optional<List<RawFile>> |
convertToRawFiles()
|
List<DataFileMeta> |
dataFiles() |
Optional<List<DeletionFile>> |
deletionFiles()
Return the deletion file of the data file, indicating which row in the data file was deleted.
|
static DataSplit |
deserialize(DataInputView in) |
OptionalLong |
earliestFileCreationEpochMillis() |
boolean |
equals(Object o) |
int |
hashCode() |
Optional<List<IndexFile>> |
indexFiles()
* Return the index file of the data file, for example, bloom-filter index.
|
boolean |
isStreaming() |
OptionalLong |
latestFileCreationEpochMillis() |
BinaryRow |
partition() |
boolean |
rawConvertible() |
long |
rowCount() |
void |
serialize(DataOutputView out) |
long |
snapshotId() |
public long snapshotId()
public BinaryRow partition()
public int bucket()
public String bucketPath()
public List<DataFileMeta> beforeFiles()
public Optional<List<DeletionFile>> beforeDeletionFiles()
public List<DataFileMeta> dataFiles()
public Optional<List<DeletionFile>> deletionFiles()
Split
If there is no corresponding deletion file, the element will be null.
deletionFiles
in interface Split
public boolean isStreaming()
public boolean rawConvertible()
public OptionalLong latestFileCreationEpochMillis()
public OptionalLong earliestFileCreationEpochMillis()
public Optional<List<RawFile>> convertToRawFiles()
Split
Optional
wrapping
a list of RawFile
s to be read without merging. Otherwise, returns Optional.empty()
.convertToRawFiles
in interface Split
@Nullable public Optional<List<IndexFile>> indexFiles()
Split
If there is no corresponding index file, the element will be null.
indexFiles
in interface Split
public void serialize(DataOutputView out) throws IOException
IOException
public static DataSplit deserialize(DataInputView in) throws IOException
IOException
public static DataSplit.Builder builder()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.