Uses of Interface
org.apache.flink.table.runtime.generated.FilterCondition
-
Packages that use FilterCondition Package Description org.apache.flink.table.runtime.operators.deduplicate.utils org.apache.flink.table.runtime.operators.join.lookup -
-
Uses of FilterCondition in org.apache.flink.table.runtime.operators.deduplicate.utils
Methods in org.apache.flink.table.runtime.operators.deduplicate.utils with parameters of type FilterCondition Modifier and Type Method Description static voidDeduplicateFunctionHelper. processLastRowOnChangelogWithFilter(FilterCondition.Context context, org.apache.flink.table.data.RowData currentRow, boolean generateUpdateBefore, org.apache.flink.api.common.state.ValueState<org.apache.flink.table.data.RowData> state, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out, boolean isStateTtlEnabled, RecordEqualiser equaliser, FilterCondition filterCondition) -
Uses of FilterCondition in org.apache.flink.table.runtime.operators.join.lookup
Fields in org.apache.flink.table.runtime.operators.join.lookup declared as FilterCondition Modifier and Type Field Description protected FilterConditionAsyncLookupJoinRunner. preFilterConditionprotected FilterConditionLookupJoinRunner. preFilterCondition
-