Uses of Class
org.apache.flink.table.runtime.operators.join.lookup.keyordered.Epoch

Packages that use Epoch

Package	Description
org.apache.flink.table.runtime.operators.join.lookup.keyordered

Uses of Epoch in org.apache.flink.table.runtime.operators.join.lookup.keyordered

Methods in org.apache.flink.table.runtime.operators.join.lookup.keyordered that return Epoch

Modifier and Type	Method	Description
Epoch<OUT>	EpochManager.getActiveEpoch()
Epoch<OUT>	TableAsyncExecutionController.getActiveEpoch()
Epoch<OUT>	AecRecord.getEpoch()
Epoch<OUT>	EpochManager.onRecord()	Add a record to the current epoch and return the current open epoch.

Methods in org.apache.flink.table.runtime.operators.join.lookup.keyordered that return types with arguments of type Epoch

Modifier and Type	Method	Description
LinkedList<Epoch<OUT>>	EpochManager.getOutputQueue()
Optional<Epoch<OUT>>	EpochManager.getProperEpoch(org.apache.flink.streaming.api.watermark.Watermark watermark)

Methods in org.apache.flink.table.runtime.operators.join.lookup.keyordered with parameters of type Epoch

Modifier and Type	Method	Description
void	EpochManager.completeOneRecord(Epoch<OUT> epoch)	Complete one record in the specific epoch.
void	TableAsyncExecutionController.outputRecord(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN> record, Epoch<OUT> epoch, int inputIndex)
AecRecord<IN,OUT>	AecRecord.reset(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN> record, Epoch<OUT> epoch, int inputIndex)
AecRecord<IN,OUT>	AecRecord.setEpoch(Epoch<OUT> epoch)
void	TableAsyncExecutionController.submitRecord(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN> record, Epoch<OUT> epoch, int inputIndex)

Constructors in org.apache.flink.table.runtime.operators.join.lookup.keyordered with parameters of type Epoch

Constructor	Description
AecRecord(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN> record, Epoch<OUT> epoch, int inputIndex)