public class AppendBypassCoordinateOperator<CommitT> extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<org.apache.flink.types.Either<CommitT,UnawareAppendCompactionTask>> implements org.apache.flink.streaming.api.operators.OneInputStreamOperator<CommitT,org.apache.flink.types.Either<CommitT,UnawareAppendCompactionTask>>, org.apache.flink.api.common.operators.ProcessingTimeService.ProcessingTimeCallback
OneInputStreamOperator
to accept commit messages and send append compact coordinate
compact task to downstream operators.Constructor and Description |
---|
AppendBypassCoordinateOperator(FileStoreTable table,
org.apache.flink.streaming.runtime.tasks.ProcessingTimeService processingTimeService) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
onProcessingTime(long time) |
void |
open() |
void |
processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<CommitT> record) |
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, initializeState, isUsingCustomRawKeyedState, notifyCheckpointAborted, notifyCheckpointComplete, prepareSnapshotPreBarrier, 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, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState
notifyCheckpointAborted, notifyCheckpointComplete
getCurrentKey, setCurrentKey
public AppendBypassCoordinateOperator(FileStoreTable table, org.apache.flink.streaming.runtime.tasks.ProcessingTimeService processingTimeService)
public void open() throws Exception
open
in interface org.apache.flink.streaming.api.operators.StreamOperator<org.apache.flink.types.Either<CommitT,UnawareAppendCompactionTask>>
open
in class org.apache.flink.streaming.api.operators.AbstractStreamOperator<org.apache.flink.types.Either<CommitT,UnawareAppendCompactionTask>>
Exception
public void onProcessingTime(long time)
onProcessingTime
in interface org.apache.flink.api.common.operators.ProcessingTimeService.ProcessingTimeCallback
public void processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<CommitT> record) throws Exception
public void close() throws Exception
close
in interface org.apache.flink.streaming.api.operators.StreamOperator<org.apache.flink.types.Either<CommitT,UnawareAppendCompactionTask>>
close
in class org.apache.flink.streaming.api.operators.AbstractStreamOperator<org.apache.flink.types.Either<CommitT,UnawareAppendCompactionTask>>
Exception
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.