Uses of Package
org.apache.flink.streaming.api.operators.collect
-
Classes in org.apache.flink.streaming.api.operators.collect used by org.apache.flink.streaming.api.datastream Class Description ClientAndIterator A pair of anIteratorto receive results from a streaming application and aJobClientto interact with the program. -
Classes in org.apache.flink.streaming.api.operators.collect used by org.apache.flink.streaming.api.environment Class Description CollectResultIterator An iterator which iterates through the results of a query job. -
Classes in org.apache.flink.streaming.api.operators.collect used by org.apache.flink.streaming.api.operators.collect Class Description AbstractCollectResultBuffer A buffer which encapsulates the logic of dealing with the response from theCollectSinkFunction.CollectCoordinationResponse ACoordinationResponsefrom the coordinator containing the required batch or new results and other necessary information in serialized form.CollectResultIterator An iterator which iterates through the results of a query job.CollectSinkOperatorFactory The Factory class forCollectSinkOperator.