Uses of Package
org.apache.flink.table.runtime.collector
-
Classes in org.apache.flink.table.runtime.collector used by org.apache.flink.table.runtime.collector Class Description ListenableCollector.CollectListener An interface can listen on collecting original record.TableFunctionCollector The basic implementation of collector forTableFunction. -
Classes in org.apache.flink.table.runtime.collector used by org.apache.flink.table.runtime.operators.join.deltajoin Class Description TableFunctionResultFuture The basic implementation of collector forResultFuturein table joining. -
Classes in org.apache.flink.table.runtime.collector used by org.apache.flink.table.runtime.operators.join.lookup Class Description ListenableCollector A listenable collector for lookup join that can be called when an original record was collected.TableFunctionResultFuture The basic implementation of collector forResultFuturein table joining.