Package org.apache.flink.table.runtime.operators.join.window.utils

Class WindowJoinHelper

java.lang.Object

org.apache.flink.table.runtime.operators.join.window.utils.WindowJoinHelper

public abstract class WindowJoinHelper
extends Object

A helper to do the window join operations for WindowJoinOperator and AsyncStateWindowJoinOperator.

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.flink.streaming.api.operators.TimestampedCollector<org.apache.flink.table.data.RowData>	collector	This is used for emitting elements with a given timestamp.
protected JoinConditionWithNullFilters	joinCondition
protected RowDataSerializer	leftSerializer
protected RowDataSerializer	rightSerializer

Constructor Summary

Constructors

Constructor	Description
WindowJoinHelper(RowDataSerializer leftSerializer, RowDataSerializer rightSerializer, ZoneId shiftTimeZone, WindowTimerService<Long> windowTimerService, JoinConditionWithNullFilters joinCondition, org.apache.flink.streaming.api.operators.TimestampedCollector<org.apache.flink.table.data.RowData> collector, FlinkJoinType joinType)

Method Summary

Modifier and Type	Method	Description
abstract void	clearState(long windowEnd, boolean isLeft)
org.apache.flink.metrics.Meter	getLeftLateRecordsDroppedRate()
org.apache.flink.metrics.Meter	getRightLateRecordsDroppedRate()
void	joinAndClear(long windowEnd, Iterable<org.apache.flink.table.data.RowData> leftRecords, Iterable<org.apache.flink.table.data.RowData> rightRecords)
void	processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.table.data.RowData> element, int windowEndIndex, org.apache.flink.metrics.Meter lateRecordsDroppedRate, org.apache.flink.util.function.BiConsumerWithException<Long,org.apache.flink.table.data.RowData,Exception> accStateConsumer)
void	registerMetric(org.apache.flink.metrics.groups.OperatorMetricGroup metrics)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

leftSerializer

protected final RowDataSerializer leftSerializer

rightSerializer

protected final RowDataSerializer rightSerializer

joinCondition

protected final JoinConditionWithNullFilters joinCondition

collector

protected final org.apache.flink.streaming.api.operators.TimestampedCollector<org.apache.flink.table.data.RowData> collector

This is used for emitting elements with a given timestamp.

Constructor Detail

WindowJoinHelper

public WindowJoinHelper(RowDataSerializer leftSerializer,
                        RowDataSerializer rightSerializer,
                        ZoneId shiftTimeZone,
                        WindowTimerService<Long> windowTimerService,
                        JoinConditionWithNullFilters joinCondition,
                        org.apache.flink.streaming.api.operators.TimestampedCollector<org.apache.flink.table.data.RowData> collector,
                        FlinkJoinType joinType)

Method Detail

registerMetric

public void registerMetric(org.apache.flink.metrics.groups.OperatorMetricGroup metrics)

processElement

public void processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.table.data.RowData> element,
                           int windowEndIndex,
                           org.apache.flink.metrics.Meter lateRecordsDroppedRate,
                           org.apache.flink.util.function.BiConsumerWithException<Long,org.apache.flink.table.data.RowData,Exception> accStateConsumer)
                    throws Exception

Throws:

Exception

joinAndClear

public void joinAndClear(long windowEnd,
                         @Nullable
                         Iterable<org.apache.flink.table.data.RowData> leftRecords,
                         @Nullable
                         Iterable<org.apache.flink.table.data.RowData> rightRecords)
                  throws Exception

Throws:

Exception

getLeftLateRecordsDroppedRate

public org.apache.flink.metrics.Meter getLeftLateRecordsDroppedRate()

getRightLateRecordsDroppedRate

public org.apache.flink.metrics.Meter getRightLateRecordsDroppedRate()

clearState

public abstract void clearState(long windowEnd,
                                boolean isLeft)
                         throws Exception

Throws:

Exception