public class GlobalIndexAssignerOperator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>> implements org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,InternalRow>,org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>>, org.apache.flink.streaming.api.operators.BoundedOneInput
OneInputStreamOperator
for GlobalIndexAssigner
.Constructor and Description |
---|
GlobalIndexAssignerOperator(GlobalIndexAssigner assigner) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
endInput() |
static GlobalIndexAssignerOperator |
forRowData(Table table) |
void |
initializeState(org.apache.flink.runtime.state.StateInitializationContext context) |
void |
prepareSnapshotPreBarrier(long checkpointId) |
void |
processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,InternalRow>> streamRecord) |
finish, getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getStateKeySelector1, getStateKeySelector2, getTimeServiceManager, getUserCodeClassloader, hasKeyContext1, hasKeyContext2, initializeState, isUsingCustomRawKeyedState, notifyCheckpointAborted, notifyCheckpointComplete, open, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processRecordAttributes, processRecordAttributes1, processRecordAttributes2, processWatermark, processWatermark1, processWatermark2, processWatermarkStatus, processWatermarkStatus1, processWatermarkStatus2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, setMailboxExecutor, setProcessingTimeService, setup, snapshotState, snapshotState, useSplittableTimers
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setKeyContextElement
finish, getMetricGroup, getOperatorAttributes, getOperatorID, initializeState, open, setKeyContextElement1, setKeyContextElement2, snapshotState
notifyCheckpointAborted, notifyCheckpointComplete
getCurrentKey, setCurrentKey
public GlobalIndexAssignerOperator(GlobalIndexAssigner assigner)
public void initializeState(org.apache.flink.runtime.state.StateInitializationContext context) throws Exception
initializeState
in interface org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.CheckpointedStreamOperator
initializeState
in class org.apache.flink.streaming.api.operators.AbstractStreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>>
Exception
public void processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,InternalRow>> streamRecord) throws Exception
processElement
in interface org.apache.flink.streaming.api.operators.Input<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,InternalRow>>
Exception
public void prepareSnapshotPreBarrier(long checkpointId) throws Exception
prepareSnapshotPreBarrier
in interface org.apache.flink.streaming.api.operators.StreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>>
prepareSnapshotPreBarrier
in class org.apache.flink.streaming.api.operators.AbstractStreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>>
Exception
public void endInput() throws Exception
endInput
in interface org.apache.flink.streaming.api.operators.BoundedOneInput
Exception
public void close() throws Exception
close
in interface org.apache.flink.streaming.api.operators.StreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>>
close
in class org.apache.flink.streaming.api.operators.AbstractStreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>>
Exception
public static GlobalIndexAssignerOperator forRowData(Table table)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.