Uses of Class
org.apache.flink.table.runtime.collector.ListenableCollector

Packages that use ListenableCollector

Package	Description
org.apache.flink.table.runtime.operators.join.lookup
org.apache.flink.table.runtime.operators.ml
org.apache.flink.table.runtime.operators.search

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

Fields in org.apache.flink.table.runtime.operators.join.lookup declared as ListenableCollector

Modifier and Type	Field	Description
protected ListenableCollector<org.apache.flink.table.data.RowData>	LookupJoinRunner.collector

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

Constructor	Description
LookupJoinRunner(GeneratedFunction<org.apache.flink.api.common.functions.FlatMapFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>> generatedFetcher, GeneratedCollector<ListenableCollector<org.apache.flink.table.data.RowData>> generatedCollector, GeneratedFunction<FilterCondition> generatedPreFilterCondition, boolean isLeftOuterJoin, int tableFieldsCount)
LookupJoinWithCalcRunner(GeneratedFunction<org.apache.flink.api.common.functions.FlatMapFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>> generatedFetcher, GeneratedFunction<org.apache.flink.api.common.functions.FlatMapFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>> generatedCalc, GeneratedCollector<ListenableCollector<org.apache.flink.table.data.RowData>> generatedCollector, GeneratedFunction<FilterCondition> generatedFilterCondition, boolean isLeftOuterJoin, int tableFieldsCount)

Uses of ListenableCollector in org.apache.flink.table.runtime.operators.ml

Fields in org.apache.flink.table.runtime.operators.ml declared as ListenableCollector

Modifier and Type	Field	Description
protected ListenableCollector<org.apache.flink.table.data.RowData>	MLPredictRunner.collector

Constructor parameters in org.apache.flink.table.runtime.operators.ml with type arguments of type ListenableCollector

Constructor	Description
MLPredictRunner(GeneratedFunction<org.apache.flink.api.common.functions.FlatMapFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>> generatedFetcher, GeneratedCollector<ListenableCollector<org.apache.flink.table.data.RowData>> generatedCollector)

Uses of ListenableCollector in org.apache.flink.table.runtime.operators.search

Constructor parameters in org.apache.flink.table.runtime.operators.search with type arguments of type ListenableCollector

Constructor	Description
VectorSearchRunner(GeneratedFunction<org.apache.flink.api.common.functions.FlatMapFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>> generatedFetcher, GeneratedCollector<ListenableCollector<org.apache.flink.table.data.RowData>> generatedCollector, boolean isLeftOuterJoin, int searchTableFieldCount)