Class MultiTableCommittableChannelComputer

  • All Implemented Interfaces:
    Serializable, org.apache.paimon.table.sink.ChannelComputer<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<org.apache.paimon.flink.sink.MultiTableCommittable>>

    public class MultiTableCommittableChannelComputer
    extends Object
    implements org.apache.paimon.table.sink.ChannelComputer<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<org.apache.paimon.flink.sink.MultiTableCommittable>>
    ChannelComputer for MultiTableCommittable. Shuffle by database and table, make sure that MultiTableCommittable from the same table will be sent to the same channel.
    See Also:
    Serialized Form
    • Constructor Detail

      • MultiTableCommittableChannelComputer

        public MultiTableCommittableChannelComputer()
    • Method Detail

      • setup

        public void setup​(int numChannels)
        Specified by:
        setup in interface org.apache.paimon.table.sink.ChannelComputer<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<org.apache.paimon.flink.sink.MultiTableCommittable>>
      • channel

        public int channel​(org.apache.flink.streaming.api.connector.sink2.CommittableMessage<org.apache.paimon.flink.sink.MultiTableCommittable> committableMessage)
        Specified by:
        channel in interface org.apache.paimon.table.sink.ChannelComputer<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<org.apache.paimon.flink.sink.MultiTableCommittable>>