Uses of Class
org.apache.paimon.CoreOptions

Packages that use CoreOptions

Package	Description
org.apache.paimon
org.apache.paimon.fileindex
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.operation
org.apache.paimon.partition
org.apache.paimon.partition.actions
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.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, RowType rowType)

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, SimpleStatsExtractor simpleStatsExtractor, long schemaId, int level, String compression, CoreOptions options, FileSource fileSource)

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

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

Modifier and Type	Method and Description
static FieldAggregator	FieldAggregator.createFieldAggregator(DataType fieldType, String strAgg, boolean ignoreRetract, boolean isPrimaryKey, CoreOptions options, String field)

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

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

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
AppendOnlyFileStoreWrite(FileIO fileIO, RawFileSplitRead read, long schemaId, String commitUser, RowType rowType, FileStorePathFactory pathFactory, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, BucketMode bucketMode, DeletionVectorsMaintainer.Factory dvMaintainerFactory, String tableName)
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, Map<String,FileStorePathFactory> format2PathFactory, SnapshotManager snapshotManager, FileStoreScan scan, IndexMaintainer.Factory<KeyValue> indexFactory, DeletionVectorsMaintainer.Factory deletionVectorsMaintainerFactory, CoreOptions options, KeyValueFieldsExtractor extractor, String tableName)
MemoryFileStoreWrite(String commitUser, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, 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)

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(FileStoreTable fileStoreTable, CoreOptions options)
static MetastoreClient	PartitionMarkDoneAction.createMetastoreClient(FileStoreTable table, CoreOptions options)

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	DataTable.coreOptions()
CoreOptions	DelegatedFileStoreTable.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

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

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

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

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

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

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, 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	CompactBucketsTable.coreOptions()
CoreOptions	AuditLogTable.coreOptions()
CoreOptions	ReadOptimizedTable.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 TagPreview	TagPreview.create(CoreOptions options)
static TagPeriodHandler	TagPeriodHandler.create(CoreOptions options)
static TagAutoManager	TagAutoManager.create(CoreOptions options, SnapshotManager snapshotManager, TagManager tagManager, TagDeletion tagDeletion, List<TagCallback> callbacks)
static TagAutoCreation	TagAutoCreation.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 SimpleColStatsCollector.Factory[]	StatsCollectorFactories.createStatsFactories(CoreOptions options, List<String> fields)