Uses of Class
org.apache.paimon.table.BucketMode

Packages that use BucketMode

Package	Description
org.apache.paimon
org.apache.paimon.flink.source
org.apache.paimon.flink.source.align
org.apache.paimon.flink.source.operator
org.apache.paimon.manifest
org.apache.paimon.operation
org.apache.paimon.privilege
org.apache.paimon.table
org.apache.paimon.table.sink
org.apache.paimon.table.source

Uses of BucketMode in org.apache.paimon

Methods in org.apache.paimon that return BucketMode

Modifier and Type	Method and Description
BucketMode	FileStore.bucketMode()
BucketMode	KeyValueFileStore.bucketMode()
BucketMode	AppendOnlyFileStore.bucketMode()

Uses of BucketMode in org.apache.paimon.flink.source

Fields in org.apache.paimon.flink.source declared as BucketMode

Modifier and Type	Field and Description
protected BucketMode	ContinuousFileStoreSource.bucketMode

Methods in org.apache.paimon.flink.source with parameters of type BucketMode

Modifier and Type	Method and Description
protected SplitAssigner	ContinuousFileSplitEnumerator.createSplitAssigner(BucketMode bucketMode)

Constructors in org.apache.paimon.flink.source with parameters of type BucketMode

Constructor and Description
ContinuousFileSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> remainSplits, Long nextSnapshotId, long discoveryInterval, StreamTableScan scan, BucketMode bucketMode, int splitMaxPerTask, boolean shuffleBucketWithPartition)
ContinuousFileStoreSource(ReadBuilder readBuilder, Map<String,String> options, Long limit, BucketMode bucketMode)

Uses of BucketMode in org.apache.paimon.flink.source.align

Methods in org.apache.paimon.flink.source.align with parameters of type BucketMode

Modifier and Type	Method and Description
protected SplitAssigner	AlignedContinuousFileSplitEnumerator.createSplitAssigner(BucketMode bucketMode)

Constructors in org.apache.paimon.flink.source.align with parameters of type BucketMode

Constructor and Description
AlignedContinuousFileSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> remainSplits, Long nextSnapshotId, long discoveryInterval, StreamTableScan scan, BucketMode bucketMode, long alignTimeout, int splitPerTaskMax, boolean shuffleBucketWithPartition)
AlignedContinuousFileStoreSource(ReadBuilder readBuilder, Map<String,String> options, Long limit, BucketMode bucketMode)

Uses of BucketMode in org.apache.paimon.flink.source.operator

Methods in org.apache.paimon.flink.source.operator with parameters of type BucketMode

Modifier and Type	Method and Description
static org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData>	MonitorFunction.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String name, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> typeInfo, ReadBuilder readBuilder, long monitorInterval, boolean emitSnapshotWatermark, boolean shuffleBucketWithPartition, BucketMode bucketMode)

Uses of BucketMode in org.apache.paimon.manifest

Methods in org.apache.paimon.manifest with parameters of type BucketMode

Modifier and Type	Method and Description
String	IndexManifestFile.writeIndexFiles(String previousIndexManifest, List<IndexManifestEntry> newIndexFiles, BucketMode bucketMode) Write new index files to index manifest.

Uses of BucketMode in org.apache.paimon.operation

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

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)
FileStoreCommitImpl(FileIO fileIO, SchemaManager schemaManager, String commitUser, RowType partitionType, 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)

Uses of BucketMode in org.apache.paimon.privilege

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

Modifier and Type	Method and Description
BucketMode	PrivilegedFileStore.bucketMode()

Uses of BucketMode in org.apache.paimon.table

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

Modifier and Type	Method and Description
default BucketMode	FileStoreTable.bucketMode()
BucketMode	BucketSpec.getBucketMode()
static BucketMode	BucketMode.valueOf(String name) Returns the enum constant of this type with the specified name.
static BucketMode[]	BucketMode.values() Returns an array containing the constants of this enum type, in the order they are declared.

Constructors in org.apache.paimon.table with parameters of type BucketMode

Constructor and Description
BucketSpec(BucketMode bucketMode, List<String> bucketKeys, int numBuckets)

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

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

Modifier and Type	Method and Description
TableWriteImpl<T>	TableWriteImpl.withBucketMode(BucketMode bucketMode)

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

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

Constructor and Description
AppendOnlySplitGenerator(long targetSplitSize, long openFileCost, BucketMode bucketMode)