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

Packages that use AecRecord

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

Uses of AecRecord in org.apache.flink.table.runtime.operators

Methods in org.apache.flink.table.runtime.operators with parameters of type AecRecord

Modifier and Type	Method	Description
KEY	TableKeyedAsyncWaitOperator.getKey(AecRecord<IN,OUT> aecRecord)
void	TableKeyedAsyncWaitOperator.invoke(AecRecord<IN,OUT> element)

Uses of AecRecord in org.apache.flink.table.runtime.operators.join.deltajoin

Methods in org.apache.flink.table.runtime.operators.join.deltajoin with parameters of type AecRecord

Modifier and Type	Method	Description
void	StreamingDeltaJoinOperator.invoke(AecRecord<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData> element)

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

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

Modifier and Type	Method	Description
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)
AecRecord<IN,OUT>	AecRecord.setRecord(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN> record)

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

Modifier and Type	Method	Description
org.apache.flink.util.function.ThrowingConsumer<AecRecord<IN,OUT>,Exception>	TableAsyncExecutionController.getAsyncInvoke()
RecordsBuffer<AecRecord<IN,OUT>,KEY>	TableAsyncExecutionController.getRecordsBuffer()
Map<KEY,Deque<AecRecord<IN,OUT>>>	TableAsyncExecutionController.pendingElements()

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

Modifier and Type	Method	Description
void	TableAsyncExecutionController.completeRecord(org.apache.flink.streaming.api.operators.async.queue.StreamElementQueueEntry<OUT> resultFuture, AecRecord<IN,OUT> aecRecord)	Used for an element to be completed.

Constructor parameters in org.apache.flink.table.runtime.operators.join.lookup.keyordered with type arguments of type AecRecord

Constructor

Description

TableAsyncExecutionController(org.apache.flink.util.function.ThrowingConsumer<AecRecord<IN,OUT>,Exception> asyncInvoke, org.apache.flink.util.function.ThrowingConsumer<org.apache.flink.streaming.api.watermark.Watermark,Exception> emitWatermark, Consumer<org.apache.flink.streaming.api.operators.async.queue.StreamElementQueueEntry<OUT>> emitResult, Function<org.apache.flink.streaming.api.operators.async.queue.StreamElementQueueEntry<OUT>,Integer> inferDrivenInputIndex, org.apache.flink.util.function.BiFunctionWithException<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN>,Integer,KEY,Exception> inferBlockingKey)