public class BucketStreamPartitioner
extends org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<org.apache.flink.table.data.RowData>
StreamPartitioner
to partition records by bucket.Constructor and Description |
---|
BucketStreamPartitioner(TableSchema schema) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<org.apache.flink.table.data.RowData> |
copy() |
org.apache.flink.runtime.io.network.api.writer.SubtaskStateMapper |
getDownstreamSubtaskStateMapper() |
boolean |
isPointwise() |
int |
selectChannel(org.apache.flink.runtime.plugable.SerializationDelegate<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.table.data.RowData>> record) |
void |
setup(int numberOfChannels) |
String |
toString() |
public BucketStreamPartitioner(TableSchema schema)
public void setup(int numberOfChannels)
setup
in interface org.apache.flink.runtime.io.network.api.writer.ChannelSelector<org.apache.flink.runtime.plugable.SerializationDelegate<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.table.data.RowData>>>
setup
in class org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<org.apache.flink.table.data.RowData>
public int selectChannel(org.apache.flink.runtime.plugable.SerializationDelegate<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.table.data.RowData>> record)
public org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<org.apache.flink.table.data.RowData> copy()
copy
in class org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<org.apache.flink.table.data.RowData>
public org.apache.flink.runtime.io.network.api.writer.SubtaskStateMapper getDownstreamSubtaskStateMapper()
getDownstreamSubtaskStateMapper
in class org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<org.apache.flink.table.data.RowData>
public boolean isPointwise()
isPointwise
in class org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<org.apache.flink.table.data.RowData>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.