Package | Description |
---|---|
org.apache.flink.table.store.file | |
org.apache.flink.table.store.file.operation | |
org.apache.flink.table.store.table.source |
Modifier and Type | Method and Description |
---|---|
FileStoreScan |
FileStore.newScan() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractFileStoreScan
Default implementation of
FileStoreScan . |
class |
AppendOnlyFileStoreScan
|
class |
KeyValueFileStoreScan
|
Modifier and Type | Method and Description |
---|---|
FileStoreScan |
FileStoreScan.withBucket(int bucket) |
FileStoreScan |
AbstractFileStoreScan.withBucket(int bucket) |
protected FileStoreScan |
AbstractFileStoreScan.withBucketKeyFilter(Predicate predicate) |
FileStoreScan |
FileStoreScan.withKind(ScanKind scanKind) |
FileStoreScan |
AbstractFileStoreScan.withKind(ScanKind scanKind) |
FileStoreScan |
FileStoreScan.withLevel(int level) |
FileStoreScan |
AbstractFileStoreScan.withLevel(int level) |
FileStoreScan |
FileStoreScan.withManifestList(List<ManifestFileMeta> manifests) |
FileStoreScan |
AbstractFileStoreScan.withManifestList(List<ManifestFileMeta> manifests) |
FileStoreScan |
FileStoreScan.withPartitionFilter(List<org.apache.flink.table.data.binary.BinaryRowData> partitions) |
FileStoreScan |
AbstractFileStoreScan.withPartitionFilter(List<org.apache.flink.table.data.binary.BinaryRowData> partitions) |
FileStoreScan |
FileStoreScan.withPartitionFilter(Predicate predicate) |
FileStoreScan |
AbstractFileStoreScan.withPartitionFilter(Predicate predicate) |
FileStoreScan |
FileStoreScan.withSnapshot(long snapshotId) |
FileStoreScan |
AbstractFileStoreScan.withSnapshot(long snapshotId) |
Constructor and Description |
---|
AbstractFileStoreWrite(String commitUser,
SnapshotManager snapshotManager,
FileStoreScan scan) |
AppendOnlyFileStoreWrite(AppendOnlyFileStoreRead read,
long schemaId,
String commitUser,
org.apache.flink.table.types.logical.RowType rowType,
FileStorePathFactory pathFactory,
SnapshotManager snapshotManager,
FileStoreScan scan,
CoreOptions options) |
FileStoreCommitImpl(long schemaId,
String commitUser,
org.apache.flink.table.types.logical.RowType partitionType,
FileStorePathFactory pathFactory,
SnapshotManager snapshotManager,
ManifestFile.Factory manifestFileFactory,
ManifestList.Factory manifestListFactory,
FileStoreScan scan,
int numBucket,
org.apache.flink.configuration.MemorySize manifestTargetSize,
int manifestMergeMinCount,
Comparator<org.apache.flink.table.data.RowData> keyComparator) |
KeyValueFileStoreWrite(SchemaManager schemaManager,
long schemaId,
String commitUser,
org.apache.flink.table.types.logical.RowType keyType,
org.apache.flink.table.types.logical.RowType valueType,
java.util.function.Supplier<Comparator<org.apache.flink.table.data.RowData>> keyComparatorSupplier,
MergeFunctionFactory<KeyValue> mfFactory,
FileStorePathFactory pathFactory,
SnapshotManager snapshotManager,
FileStoreScan scan,
CoreOptions options,
KeyValueFieldsExtractor extractor) |
MemoryFileStoreWrite(String commitUser,
SnapshotManager snapshotManager,
FileStoreScan scan,
CoreOptions options) |
PartitionExpire(org.apache.flink.table.types.logical.RowType partitionType,
java.time.Duration expirationTime,
java.time.Duration checkInterval,
String timePattern,
String timeFormatter,
FileStoreScan scan,
FileStoreCommit commit) |
Constructor and Description |
---|
AbstractDataTableScan(FileStoreScan scan,
TableSchema tableSchema,
FileStorePathFactory pathFactory,
CoreOptions options) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.