Modifier and Type | Field and Description |
---|---|
protected CoreOptions |
MergeTreeBenchmark.options |
Modifier and Type | Field and Description |
---|---|
protected CoreOptions |
AbstractFileStore.options |
Modifier and Type | Method and Description |
---|---|
CoreOptions |
AbstractFileStore.options() |
CoreOptions |
FileStore.options() |
Constructor and Description |
---|
AbstractFileStore(SchemaManager schemaManager,
long schemaId,
CoreOptions options,
org.apache.flink.table.types.logical.RowType partitionType) |
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) |
KeyValueFileStore(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 keyType,
org.apache.flink.table.types.logical.RowType valueType,
KeyValueFieldsExtractor keyValueFieldsExtractor,
MergeFunctionFactory<KeyValue> mfFactory) |
Constructor and Description |
---|
AppendOnlyFileStoreWrite(AppendOnlyFileStoreRead read,
long schemaId,
String commitUser,
org.apache.flink.table.types.logical.RowType rowType,
FileStorePathFactory pathFactory,
SnapshotManager snapshotManager,
FileStoreScan scan,
CoreOptions options) |
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) |
Modifier and Type | Method and Description |
---|---|
CoreOptions |
AbstractFileStoreTable.options() |
CoreOptions |
DataTable.options() |
Modifier and Type | Method and Description |
---|---|
CoreOptions |
AbstractDataTableScan.options() |
Constructor and Description |
---|
AbstractDataTableScan(FileStoreScan scan,
TableSchema tableSchema,
FileStorePathFactory pathFactory,
CoreOptions options) |
Modifier and Type | Method and Description |
---|---|
CoreOptions |
BucketsTable.options() |
CoreOptions |
AuditLogTable.options() |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.