Uses of Class
org.apache.paimon.CoreOptions

Packages that use CoreOptions

Package	Description
org.apache.paimon
org.apache.paimon.fileindex
org.apache.paimon.flink.compact
org.apache.paimon.flink.compact.changelog
org.apache.paimon.flink.lookup
org.apache.paimon.flink.sink.partition
org.apache.paimon.format
org.apache.paimon.io
org.apache.paimon.lookup
org.apache.paimon.mergetree
org.apache.paimon.mergetree.compact
org.apache.paimon.mergetree.compact.aggregate
org.apache.paimon.mergetree.compact.aggregate.factory
org.apache.paimon.operation
org.apache.paimon.partition
org.apache.paimon.partition.actions
org.apache.paimon.postpone
org.apache.paimon.privilege
org.apache.paimon.table
org.apache.paimon.table.sink
org.apache.paimon.table.source
org.apache.paimon.table.source.snapshot
org.apache.paimon.table.system
org.apache.paimon.tag
org.apache.paimon.utils

Uses of CoreOptions in org.apache.paimon

Methods in org.apache.paimon that return CoreOptions

Modifier and Type	Method and Description
static CoreOptions	CoreOptions.fromMap(Map<String,String> options)
CoreOptions	FileStore.options()

Constructors in org.apache.paimon with parameters of type CoreOptions

Constructor and Description
AppendOnlyFileStore(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, CoreOptions options, RowType partitionType, RowType bucketKeyType, RowType rowType, String tableName, CatalogEnvironment catalogEnvironment)
KeyValueFileStore(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, boolean crossPartitionUpdate, CoreOptions options, RowType partitionType, RowType bucketKeyType, RowType keyType, RowType valueType, KeyValueFieldsExtractor keyValueFieldsExtractor, MergeFunctionFactory<KeyValue> mfFactory, String tableName, CatalogEnvironment catalogEnvironment)

Uses of CoreOptions in org.apache.paimon.fileindex

Constructors in org.apache.paimon.fileindex with parameters of type CoreOptions

Constructor and Description
FileIndexOptions(CoreOptions coreOptions)

Uses of CoreOptions in org.apache.paimon.flink.compact

Constructors in org.apache.paimon.flink.compact with parameters of type CoreOptions

Constructor and Description
UnawareBucketNewFilesCompactionCoordinatorOperator(CoreOptions options)

Uses of CoreOptions in org.apache.paimon.flink.compact.changelog

Constructors in org.apache.paimon.flink.compact.changelog with parameters of type CoreOptions

Constructor and Description
ChangelogCompactCoordinateOperator(CoreOptions options)

Uses of CoreOptions in org.apache.paimon.flink.lookup

Constructors in org.apache.paimon.flink.lookup with parameters of type CoreOptions

Constructor and Description
LookupDataTableScan(CoreOptions options, SnapshotReader snapshotReader, SnapshotManager snapshotManager, ChangelogManager changelogManager, boolean supportStreamingReadOverwrite, DefaultValueAssigner defaultValueAssigner, LookupFileStoreTable.LookupStreamScanMode lookupScanMode)

Uses of CoreOptions in org.apache.paimon.flink.sink.partition

Methods in org.apache.paimon.flink.sink.partition with parameters of type CoreOptions

Modifier and Type	Method and Description
static PartitionMarkDoneTrigger	PartitionMarkDoneTrigger.create(CoreOptions coreOptions, boolean isRestored, org.apache.flink.api.common.state.OperatorStateStore stateStore)

Uses of CoreOptions in org.apache.paimon.format

Methods in org.apache.paimon.format with parameters of type CoreOptions

Modifier and Type	Method and Description
static FileFormatDiscover	FileFormatDiscover.of(CoreOptions options)

Uses of CoreOptions in org.apache.paimon.io

Methods in org.apache.paimon.io with parameters of type CoreOptions

Modifier and Type	Method and Description
KeyValueFileWriterFactory	KeyValueFileWriterFactory.Builder.build(BinaryRow partition, int bucket, CoreOptions options)
static KeyValueFileReaderFactory.Builder	KeyValueFileReaderFactory.builder(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, RowType keyType, RowType valueType, FileFormatDiscover formatDiscover, FileStorePathFactory pathFactory, KeyValueFieldsExtractor extractor, CoreOptions options)
static RecordLevelExpire	RecordLevelExpire.create(CoreOptions options, TableSchema schema, SchemaManager schemaManager)

Constructors in org.apache.paimon.io with parameters of type CoreOptions

Constructor and Description
KeyValueDataFileWriter(FileIO fileIO, FormatWriterFactory factory, Path path, java.util.function.Function<KeyValue,InternalRow> converter, RowType keyType, RowType valueType, RowType writeRowType, SimpleStatsProducer statsProducer, long schemaId, int level, String compression, CoreOptions options, FileSource fileSource, FileIndexOptions fileIndexOptions, boolean isExternalPath)
KeyValueDataFileWriterImpl(FileIO fileIO, FormatWriterFactory factory, Path path, java.util.function.Function<KeyValue,InternalRow> converter, RowType keyType, RowType valueType, SimpleStatsProducer statsProducer, long schemaId, int level, String compression, CoreOptions options, FileSource fileSource, FileIndexOptions fileIndexOptions, boolean isExternalPath)
KeyValueThinDataFileWriterImpl(FileIO fileIO, FormatWriterFactory factory, Path path, java.util.function.Function<KeyValue,InternalRow> converter, RowType keyType, RowType valueType, SimpleStatsProducer statsProducer, long schemaId, int level, String compression, CoreOptions options, FileSource fileSource, FileIndexOptions fileIndexOptions, boolean isExternalPath)

Uses of CoreOptions in org.apache.paimon.lookup

Methods in org.apache.paimon.lookup with parameters of type CoreOptions

Modifier and Type	Method and Description
static LookupStoreFactory	LookupStoreFactory.create(CoreOptions options, CacheManager cacheManager, Comparator<MemorySlice> keyComparator)
static BinaryExternalSortBuffer	RocksDBState.createBulkLoadSorter(IOManager ioManager, CoreOptions options)

Uses of CoreOptions in org.apache.paimon.mergetree

Constructors in org.apache.paimon.mergetree with parameters of type CoreOptions

Constructor and Description
MergeSorter(CoreOptions options, RowType keyType, RowType valueType, IOManager ioManager)

Uses of CoreOptions in org.apache.paimon.mergetree.compact

Constructors in org.apache.paimon.mergetree.compact with parameters of type CoreOptions

Constructor and Description

LookupMergeTreeCompactRewriter(int maxLevel, CoreOptions.MergeEngine mergeEngine, LookupLevels<T> lookupLevels, FileReaderFactory<KeyValue> readerFactory, KeyValueFileWriterFactory writerFactory, Comparator<InternalRow> keyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionFactory<KeyValue> mfFactory, MergeSorter mergeSorter, LookupMergeTreeCompactRewriter.MergeFunctionWrapperFactory<T> wrapperFactory, boolean produceChangelog, DeletionVectorsMaintainer dvMaintainer, CoreOptions options)

Uses of CoreOptions in org.apache.paimon.mergetree.compact.aggregate

Constructors in org.apache.paimon.mergetree.compact.aggregate with parameters of type CoreOptions

Constructor and Description
FieldListaggAgg(String name, VarCharType dataType, CoreOptions options, String field)

Uses of CoreOptions in org.apache.paimon.mergetree.compact.aggregate.factory

Methods in org.apache.paimon.mergetree.compact.aggregate.factory with parameters of type CoreOptions

Modifier and Type	Method and Description
FieldAggregator	FieldFirstNonNullValueAggLegacyFactory.create(DataType fieldType, CoreOptions options, String field)
FieldHllSketchAgg	FieldHllSketchAggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldAggregator	FieldAggregatorFactory.create(DataType fieldType, CoreOptions options, String field)
FieldCollectAgg	FieldCollectAggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldFirstNonNullValueAgg	FieldFirstNonNullValueAggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldSumAgg	FieldSumAggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldBoolOrAgg	FieldBoolOrAggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldProductAgg	FieldProductAggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldMergeMapAgg	FieldMergeMapAggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldListaggAgg	FieldListaggAggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldThetaSketchAgg	FieldThetaSketchAggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldLastValueAgg	FieldLastValueAggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldAggregator	FieldPrimaryKeyAggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldBoolAndAgg	FieldBoolAndAggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldFirstValueAgg	FieldFirstValueAggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldMaxAgg	FieldMaxAggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldLastNonNullValueAgg	FieldLastNonNullValueAggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldRoaringBitmap64Agg	FieldRoaringBitmap64AggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldRoaringBitmap32Agg	FieldRoaringBitmap32AggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldAggregator	FieldNestedUpdateAggFactory.create(DataType fieldType, CoreOptions options, String field)
FieldMinAgg	FieldMinAggFactory.create(DataType fieldType, CoreOptions options, String field)
static FieldAggregator	FieldAggregatorFactory.create(DataType fieldType, String fieldName, String aggFuncName, CoreOptions options)

Uses of CoreOptions in org.apache.paimon.operation

Fields in org.apache.paimon.operation declared as CoreOptions

Modifier and Type	Field and Description
protected CoreOptions	MemoryFileStoreWrite.options

Constructors in org.apache.paimon.operation with parameters of type CoreOptions

Constructor and Description
AbstractFileStoreWrite(SnapshotManager snapshotManager, FileStoreScan scan, IndexMaintainer.Factory<T> indexFactory, DeletionVectorsMaintainer.Factory dvMaintainerFactory, String tableName, CoreOptions options, RowType partitionType)
AppendOnlyFileStoreWrite(FileIO fileIO, RawFileSplitRead read, long schemaId, RowType rowType, RowType partitionType, FileStorePathFactory pathFactory, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, DeletionVectorsMaintainer.Factory dvMaintainerFactory, String tableName)
AppendOnlyFixedBucketFileStoreWrite(FileIO fileIO, RawFileSplitRead read, long schemaId, String commitUser, RowType rowType, RowType partitionType, FileStorePathFactory pathFactory, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, DeletionVectorsMaintainer.Factory dvMaintainerFactory, String tableName)
AppendOnlyUnawareBucketFileStoreWrite(FileIO fileIO, RawFileSplitRead read, long schemaId, RowType rowType, RowType partitionType, FileStorePathFactory pathFactory, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, DeletionVectorsMaintainer.Factory dvMaintainerFactory, String tableName)
FileStoreCommitImpl(SnapshotCommit snapshotCommit, FileIO fileIO, SchemaManager schemaManager, String tableName, String commitUser, RowType partitionType, CoreOptions options, String partitionDefaultName, FileStorePathFactory pathFactory, SnapshotManager snapshotManager, ManifestFile.Factory manifestFileFactory, ManifestList.Factory manifestListFactory, IndexManifestFile.Factory indexManifestFileFactory, FileStoreScan scan, int numBucket, MemorySize manifestTargetSize, MemorySize manifestFullCompactionSize, int manifestMergeMinCount, boolean dynamicPartitionOverwrite, Comparator<InternalRow> keyComparator, String branchName, StatsFileHandler statsFileHandler, BucketMode bucketMode, Integer manifestReadParallelism, List<CommitCallback> commitCallbacks, int commitMaxRetries, long commitTimeout)
KeyValueFileStoreWrite(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, String commitUser, RowType partitionType, RowType keyType, RowType valueType, java.util.function.Supplier<Comparator<InternalRow>> keyComparatorSupplier, java.util.function.Supplier<FieldsComparator> udsComparatorSupplier, java.util.function.Supplier<RecordEqualiser> logDedupEqualSupplier, MergeFunctionFactory<KeyValue> mfFactory, FileStorePathFactory pathFactory, java.util.function.BiFunction<CoreOptions,String,FileStorePathFactory> formatPathFactory, SnapshotManager snapshotManager, FileStoreScan scan, IndexMaintainer.Factory<KeyValue> indexFactory, DeletionVectorsMaintainer.Factory deletionVectorsMaintainerFactory, CoreOptions options, KeyValueFieldsExtractor extractor, String tableName)
MemoryFileStoreWrite(SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, RowType partitionType, IndexMaintainer.Factory<T> indexFactory, DeletionVectorsMaintainer.Factory dvMaintainerFactory, String tableName)
MergeFileSplitRead(CoreOptions options, TableSchema schema, RowType keyType, RowType valueType, Comparator<InternalRow> keyComparator, MergeFunctionFactory<KeyValue> mfFactory, KeyValueFileReaderFactory.Builder readerFactoryBuilder)

Constructor parameters in org.apache.paimon.operation with type arguments of type CoreOptions

Constructor and Description

KeyValueFileStoreWrite(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, String commitUser, RowType partitionType, RowType keyType, RowType valueType, java.util.function.Supplier<Comparator<InternalRow>> keyComparatorSupplier, java.util.function.Supplier<FieldsComparator> udsComparatorSupplier, java.util.function.Supplier<RecordEqualiser> logDedupEqualSupplier, MergeFunctionFactory<KeyValue> mfFactory, FileStorePathFactory pathFactory, java.util.function.BiFunction<CoreOptions,String,FileStorePathFactory> formatPathFactory, SnapshotManager snapshotManager, FileStoreScan scan, IndexMaintainer.Factory<KeyValue> indexFactory, DeletionVectorsMaintainer.Factory deletionVectorsMaintainerFactory, CoreOptions options, KeyValueFieldsExtractor extractor, String tableName)

Uses of CoreOptions in org.apache.paimon.partition

Methods in org.apache.paimon.partition with parameters of type CoreOptions

Modifier and Type	Method and Description
static PartitionExpireStrategy	PartitionExpireStrategy.createPartitionExpireStrategy(CoreOptions options, RowType partitionType)

Constructors in org.apache.paimon.partition with parameters of type CoreOptions

Constructor and Description
PartitionValuesTimeExpireStrategy(CoreOptions options, RowType partitionType)

Uses of CoreOptions in org.apache.paimon.partition.actions

Methods in org.apache.paimon.partition.actions with parameters of type CoreOptions

Modifier and Type	Method and Description
static List<PartitionMarkDoneAction>	PartitionMarkDoneAction.createActions(ClassLoader cl, FileStoreTable fileStoreTable, CoreOptions options)
static PartitionHandler	PartitionMarkDoneAction.createPartitionHandler(FileStoreTable table, CoreOptions options)
static PartitionMarkDoneAction	PartitionMarkDoneAction.generateCustomMarkDoneAction(ClassLoader cl, CoreOptions options)
default void	PartitionMarkDoneAction.open(FileStoreTable fileStoreTable, CoreOptions options)
void	HttpReportMarkDoneAction.open(FileStoreTable fileStoreTable, CoreOptions options)

Uses of CoreOptions in org.apache.paimon.postpone

Constructors in org.apache.paimon.postpone with parameters of type CoreOptions

Constructor and Description
PostponeBucketFileStoreWrite(FileIO fileIO, TableSchema schema, String commitUser, RowType partitionType, RowType keyType, RowType valueType, java.util.function.BiFunction<CoreOptions,String,FileStorePathFactory> formatPathFactory, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, String tableName)

Constructor parameters in org.apache.paimon.postpone with type arguments of type CoreOptions

Constructor and Description
PostponeBucketFileStoreWrite(FileIO fileIO, TableSchema schema, String commitUser, RowType partitionType, RowType keyType, RowType valueType, java.util.function.BiFunction<CoreOptions,String,FileStorePathFactory> formatPathFactory, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, String tableName)

Uses of CoreOptions in org.apache.paimon.privilege

Methods in org.apache.paimon.privilege that return CoreOptions

Modifier and Type	Method and Description
CoreOptions	PrivilegedFileStore.options()

Uses of CoreOptions in org.apache.paimon.table

Methods in org.apache.paimon.table that return CoreOptions

Modifier and Type	Method and Description
CoreOptions	DelegatedFileStoreTable.coreOptions()
CoreOptions	DataTable.coreOptions()

Uses of CoreOptions in org.apache.paimon.table.sink

Methods in org.apache.paimon.table.sink with parameters of type CoreOptions

Modifier and Type	Method and Description
static RowKindGenerator	RowKindGenerator.create(TableSchema schema, CoreOptions options)
static List<CommitCallback>	CallbackUtils.loadCommitCallbacks(CoreOptions coreOptions)
static List<TagCallback>	CallbackUtils.loadTagCallbacks(CoreOptions coreOptions)

Uses of CoreOptions in org.apache.paimon.table.source

Constructors in org.apache.paimon.table.source with parameters of type CoreOptions

Constructor and Description
DataTableBatchScan(boolean pkTable, CoreOptions options, SnapshotReader snapshotReader, DefaultValueAssigner defaultValueAssigner)
DataTableStreamScan(CoreOptions options, SnapshotReader snapshotReader, SnapshotManager snapshotManager, ChangelogManager changelogManager, boolean supportStreamingReadOverwrite, DefaultValueAssigner defaultValueAssigner)

Uses of CoreOptions in org.apache.paimon.table.source.snapshot

Methods in org.apache.paimon.table.source.snapshot with parameters of type CoreOptions

Modifier and Type	Method and Description
static Snapshot	TimeTravelUtil.resolveSnapshotFromOptions(CoreOptions options, SnapshotManager snapshotManager)
static AbstractStartingScanner	IncrementalDiffStartingScanner.toEndAutoTag(SnapshotManager snapshotManager, String endTagName, CoreOptions options)

Constructors in org.apache.paimon.table.source.snapshot with parameters of type CoreOptions

Constructor and Description
SnapshotReaderImpl(FileStoreScan scan, TableSchema tableSchema, CoreOptions options, SnapshotManager snapshotManager, ChangelogManager changelogManager, SplitGenerator splitGenerator, java.util.function.BiConsumer<FileStoreScan,Predicate> nonPartitionFilterConsumer, DefaultValueAssigner defaultValueAssigner, FileStorePathFactory pathFactory, String tableName, IndexFileHandler indexFileHandler)

Uses of CoreOptions in org.apache.paimon.table.system

Methods in org.apache.paimon.table.system that return CoreOptions

Modifier and Type	Method and Description
CoreOptions	FileMonitorTable.coreOptions()
CoreOptions	AuditLogTable.coreOptions()
CoreOptions	ReadOptimizedTable.coreOptions()
CoreOptions	CompactBucketsTable.coreOptions()

Uses of CoreOptions in org.apache.paimon.tag

Methods in org.apache.paimon.tag with parameters of type CoreOptions

Modifier and Type	Method and Description
static TagTimeExtractor	TagTimeExtractor.create(CoreOptions.TagCreationMode mode, CoreOptions options)
static TagPeriodHandler	TagPeriodHandler.create(CoreOptions options)
static TagPreview	TagPreview.create(CoreOptions options)
static TagAutoCreation	TagAutoCreation.create(CoreOptions options, SnapshotManager snapshotManager, TagManager tagManager, TagDeletion tagDeletion, List<TagCallback> callbacks)
static TagAutoManager	TagAutoManager.create(CoreOptions options, SnapshotManager snapshotManager, TagManager tagManager, TagDeletion tagDeletion, List<TagCallback> callbacks)
static TagTimeExtractor	TagTimeExtractor.createForAutoTag(CoreOptions options)
static TagTimeExtractor	TagTimeExtractor.createForTagPreview(CoreOptions options)

Uses of CoreOptions in org.apache.paimon.utils

Methods in org.apache.paimon.utils with parameters of type CoreOptions

Modifier and Type	Method and Description
static UserDefinedSeqComparator	UserDefinedSeqComparator.create(RowType rowType, CoreOptions options)
static Map<String,FileStorePathFactory>	FileStorePathFactory.createFormatPathFactories(CoreOptions options, java.util.function.BiFunction<CoreOptions,String,FileStorePathFactory> formatPathFactory)
static SimpleColStatsCollector.Factory[]	StatsCollectorFactories.createStatsFactories(String statsMode, CoreOptions options, List<String> fields)
static SimpleColStatsCollector.Factory[]	StatsCollectorFactories.createStatsFactories(String statsMode, CoreOptions coreOptions, List<String> fields, List<String> keyNames)
static SimpleColStatsCollector.Factory[]	StatsCollectorFactories.createStatsFactoriesForAvro(String statsMode, CoreOptions coreOptions, List<String> fields) If all are None, return all None to Avro Writer, which can greatly accelerate the writing speed.
static ExpireConfig.Builder	ProcedureUtils.fillInSnapshotOptions(CoreOptions tableOptions, Integer retainMax, Integer retainMin, String olderThanStr, Integer maxDeletes)

Method parameters in org.apache.paimon.utils with type arguments of type CoreOptions

Modifier and Type	Method and Description
static Map<String,FileStorePathFactory>	FileStorePathFactory.createFormatPathFactories(CoreOptions options, java.util.function.BiFunction<CoreOptions,String,FileStorePathFactory> formatPathFactory)