Package org.apache.flink.util

Interface Collector<T>

@Public public interface Collector<T>
Collects a record and forwards it. The collector is the "push" counterpart of the Iterator, which "pulls" data in.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
    Closes the collector.
    void
    collect(T record)
    Emits a record.

  • Method Details

    • collect

      void collect(T record)
      Emits a record.
      Parameters:
      record - The record to collect.

    • close

      void close()
      Closes the collector. If any data was buffered, that data will be flushed.