public class MultiUnawareTablesReadOperator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<MultiTableUnawareAppendCompactionTask> implements org.apache.flink.streaming.api.operators.OneInputStreamOperator<MultiTableUnawareAppendCompactionTask,MultiTableUnawareAppendCompactionTask>
MultiTableUnawareAppendCompactionTask
received from the preceding CombinedUnawareBatchSourceFunction
and filter partitions which is not historical.Constructor and Description |
---|
MultiUnawareTablesReadOperator(Catalog.Loader catalogLoader,
java.time.Duration partitionIdleTime) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
open() |
void |
processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<MultiTableUnawareAppendCompactionTask> 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 MultiUnawareTablesReadOperator(Catalog.Loader catalogLoader, java.time.Duration partitionIdleTime)
public void open() throws Exception
open
in interface org.apache.flink.streaming.api.operators.StreamOperator<MultiTableUnawareAppendCompactionTask>
open
in class org.apache.flink.streaming.api.operators.AbstractStreamOperator<MultiTableUnawareAppendCompactionTask>
Exception
public void processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<MultiTableUnawareAppendCompactionTask> record)
processElement
in interface org.apache.flink.streaming.api.operators.Input<MultiTableUnawareAppendCompactionTask>
public void close() throws Exception
close
in interface org.apache.flink.streaming.api.operators.StreamOperator<MultiTableUnawareAppendCompactionTask>
close
in class org.apache.flink.streaming.api.operators.AbstractStreamOperator<MultiTableUnawareAppendCompactionTask>
Exception
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.