Modifier and Type | Method and Description |
---|---|
FileStorePathFactory |
AbstractFileStore.pathFactory() |
Modifier and Type | Method and Description |
---|---|
static KeyValueFileWriterFactory.Builder |
KeyValueFileWriterFactory.builder(long schemaId,
org.apache.flink.table.types.logical.RowType keyType,
org.apache.flink.table.types.logical.RowType valueType,
FileFormat fileFormat,
FileStorePathFactory pathFactory,
long suggestedFileSize) |
static KeyValueFileReaderFactory.Builder |
KeyValueFileReaderFactory.builder(SchemaManager schemaManager,
long schemaId,
org.apache.flink.table.types.logical.RowType keyType,
org.apache.flink.table.types.logical.RowType valueType,
FileFormat fileFormat,
FileStorePathFactory pathFactory,
KeyValueFieldsExtractor extractor) |
Modifier and Type | Method and Description |
---|---|
String |
ManifestEntry.Identifier.toString(FileStorePathFactory pathFactory) |
Constructor and Description |
---|
Factory(org.apache.flink.table.types.logical.RowType partitionType,
FileFormat fileFormat,
FileStorePathFactory pathFactory) |
Factory(SchemaManager schemaManager,
long schemaId,
org.apache.flink.table.types.logical.RowType partitionType,
FileFormat fileFormat,
FileStorePathFactory pathFactory,
long suggestedFileSize) |
Constructor and Description |
---|
AppendOnlyFileStoreRead(SchemaManager schemaManager,
long schemaId,
org.apache.flink.table.types.logical.RowType rowType,
FileFormat fileFormat,
FileStorePathFactory pathFactory) |
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) |
FileStoreExpireImpl(int numRetainedMin,
int numRetainedMax,
long millisRetained,
FileStorePathFactory pathFactory,
SnapshotManager snapshotManager,
ManifestFile.Factory manifestFileFactory,
ManifestList.Factory manifestListFactory) |
KeyValueFileStoreRead(SchemaManager schemaManager,
long schemaId,
org.apache.flink.table.types.logical.RowType keyType,
org.apache.flink.table.types.logical.RowType valueType,
Comparator<org.apache.flink.table.data.RowData> keyComparator,
MergeFunctionFactory<KeyValue> mfFactory,
FileFormat fileFormat,
FileStorePathFactory pathFactory,
KeyValueFieldsExtractor extractor) |
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) |
Modifier and Type | Method and Description |
---|---|
protected abstract SplitGenerator |
AbstractDataTableScan.splitGenerator(FileStorePathFactory pathFactory) |
Constructor and Description |
---|
AbstractDataTableScan(FileStoreScan scan,
TableSchema tableSchema,
FileStorePathFactory pathFactory,
CoreOptions options) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.