Uses of Interface
org.apache.paimon.utils.SerializableSupplier

Packages that use SerializableSupplier

Package	Description
org.apache.paimon.flink.shuffle
org.apache.paimon.flink.sink
org.apache.paimon.flink.sorter
org.apache.paimon.utils

Uses of SerializableSupplier in org.apache.paimon.flink.shuffle

Methods in org.apache.paimon.flink.shuffle with parameters of type SerializableSupplier

Modifier and Type

Method and Description

static <T> org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.api.java.tuple.Tuple2<T,org.apache.flink.table.data.RowData>>

RangeShuffle.rangeShuffleByKey(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.api.java.tuple.Tuple2<T,org.apache.flink.table.data.RowData>> inputDataStream, SerializableSupplier<Comparator<T>> keyComparator, org.apache.flink.api.common.typeinfo.TypeInformation<T> keyTypeInformation, int localSampleSize, int globalSampleSize, int rangeNum, int outParallelism, RowType valueRowType, boolean isSortBySize) The RelNode with range-partition distribution will create the following transformations.

Uses of SerializableSupplier in org.apache.paimon.flink.sink

Constructors in org.apache.paimon.flink.sink with parameters of type SerializableSupplier

Constructor and Description
AutoTagForSavepointCommitterOperator(CommitterOperator<CommitT,GlobalCommitT> commitOperator, SerializableSupplier<SnapshotManager> snapshotManagerFactory, SerializableSupplier<TagManager> tagManagerFactory, SerializableSupplier<TagDeletion> tagDeletionFactory, SerializableSupplier<List<TagCallback>> callbacksSupplier, java.time.Duration tagTimeRetained)
AutoTagForSavepointCommitterOperator(CommitterOperator<CommitT,GlobalCommitT> commitOperator, SerializableSupplier<SnapshotManager> snapshotManagerFactory, SerializableSupplier<TagManager> tagManagerFactory, SerializableSupplier<TagDeletion> tagDeletionFactory, SerializableSupplier<List<TagCallback>> callbacksSupplier, java.time.Duration tagTimeRetained)
AutoTagForSavepointCommitterOperator(CommitterOperator<CommitT,GlobalCommitT> commitOperator, SerializableSupplier<SnapshotManager> snapshotManagerFactory, SerializableSupplier<TagManager> tagManagerFactory, SerializableSupplier<TagDeletion> tagDeletionFactory, SerializableSupplier<List<TagCallback>> callbacksSupplier, java.time.Duration tagTimeRetained)
AutoTagForSavepointCommitterOperator(CommitterOperator<CommitT,GlobalCommitT> commitOperator, SerializableSupplier<SnapshotManager> snapshotManagerFactory, SerializableSupplier<TagManager> tagManagerFactory, SerializableSupplier<TagDeletion> tagDeletionFactory, SerializableSupplier<List<TagCallback>> callbacksSupplier, java.time.Duration tagTimeRetained)
RestoreAndFailCommittableStateManager(SerializableSupplier<VersionedSerializer<GlobalCommitT>> committableSerializer)

Uses of SerializableSupplier in org.apache.paimon.flink.sorter

Methods in org.apache.paimon.flink.sorter with parameters of type SerializableSupplier

Modifier and Type

Method and Description

static <KEY> org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData>

SortUtils.sortStreamByKey(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> inputStream, FileStoreTable table, RowType sortKeyType, org.apache.flink.api.common.typeinfo.TypeInformation<KEY> keyTypeInformation, SerializableSupplier<Comparator<KEY>> shuffleKeyComparator, org.apache.paimon.flink.sorter.SortUtils.KeyAbstract<KEY> shuffleKeyAbstract, org.apache.paimon.flink.sorter.SortUtils.ShuffleKeyConvertor<KEY> convertor, TableSortInfo tableSortInfo) Sort the input stream by the key specified.

Uses of SerializableSupplier in org.apache.paimon.utils

Classes in org.apache.paimon.utils that implement SerializableSupplier

Modifier and Type	Class and Description
class	KeyComparatorSupplier A Supplier that returns the comparator for the file store key.
class	ValueEqualiserSupplier A Supplier that returns the equaliser for the file store value.