AbstractFileStoreScan(org.apache.flink.table.types.logical.RowType partitionType,
org.apache.flink.table.types.logical.RowType bucketKeyType,
SnapshotManager snapshotManager,
SchemaManager schemaManager,
long schemaId,
ManifestFile.Factory manifestFileFactory,
ManifestList.Factory manifestListFactory,
int numOfBuckets,
boolean checkNumOfBuckets) |
AppendOnlyFileStoreScan(org.apache.flink.table.types.logical.RowType partitionType,
org.apache.flink.table.types.logical.RowType bucketKeyType,
org.apache.flink.table.types.logical.RowType rowType,
SnapshotManager snapshotManager,
SchemaManager schemaManager,
long schemaId,
ManifestFile.Factory manifestFileFactory,
ManifestList.Factory manifestListFactory,
int numOfBuckets,
boolean checkNumOfBuckets) |
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) |
FileStoreExpireImpl(int numRetainedMin,
int numRetainedMax,
long millisRetained,
FileStorePathFactory pathFactory,
SnapshotManager snapshotManager,
ManifestFile.Factory manifestFileFactory,
ManifestList.Factory manifestListFactory) |
KeyValueFileStoreScan(org.apache.flink.table.types.logical.RowType partitionType,
org.apache.flink.table.types.logical.RowType bucketKeyType,
org.apache.flink.table.types.logical.RowType keyType,
SnapshotManager snapshotManager,
SchemaManager schemaManager,
long schemaId,
KeyValueFieldsExtractor keyValueFieldsExtractor,
ManifestFile.Factory manifestFileFactory,
ManifestList.Factory manifestListFactory,
int numOfBuckets,
boolean checkNumOfBuckets) |