public class OffsetRowDataHashStreamPartitioner
extends org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<org.apache.flink.table.data.RowData>
Constructor and Description |
---|
OffsetRowDataHashStreamPartitioner(org.apache.flink.table.types.logical.RowType offsetRowType,
int offset) |
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 OffsetRowDataHashStreamPartitioner(org.apache.flink.table.types.logical.RowType offsetRowType, int offset)
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.