public class AppendOnlyFileStore extends AbstractFileStore<org.apache.flink.table.data.RowData>
FileStore
for reading and writing RowData
.options, partitionType, schemaId, schemaManager
Constructor and Description |
---|
AppendOnlyFileStore(SchemaManager schemaManager,
long schemaId,
CoreOptions options,
org.apache.flink.table.types.logical.RowType partitionType,
org.apache.flink.table.types.logical.RowType bucketKeyType,
org.apache.flink.table.types.logical.RowType rowType) |
Modifier and Type | Method and Description |
---|---|
Comparator<org.apache.flink.table.data.RowData> |
newKeyComparator() |
AppendOnlyFileStoreRead |
newRead() |
AppendOnlyFileStoreScan |
newScan() |
AppendOnlyFileStoreWrite |
newWrite(String commitUser) |
manifestFileFactory, manifestListFactory, newCommit, newExpire, newPartitionExpire, options, partitionType, pathFactory, snapshotManager
public AppendOnlyFileStore(SchemaManager schemaManager, long schemaId, CoreOptions options, org.apache.flink.table.types.logical.RowType partitionType, org.apache.flink.table.types.logical.RowType bucketKeyType, org.apache.flink.table.types.logical.RowType rowType)
public AppendOnlyFileStoreScan newScan()
public AppendOnlyFileStoreRead newRead()
public AppendOnlyFileStoreWrite newWrite(String commitUser)
public Comparator<org.apache.flink.table.data.RowData> newKeyComparator()
newKeyComparator
in class AbstractFileStore<org.apache.flink.table.data.RowData>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.