Class TableFunctionCollector<T>

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction, org.apache.flink.util.Collector<T>
    Direct Known Subclasses:
    ListenableCollector

    public abstract class TableFunctionCollector<T>
    extends org.apache.flink.api.common.functions.AbstractRichFunction
    implements org.apache.flink.util.Collector<T>
    The basic implementation of collector for TableFunction.
    See Also:
    Serialized Form
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void close()  
      Object getInput()
      Gets the input value from left table, which will be used to cross join with the result of table function.
      boolean isCollected()
      Whether Collector.collect(Object) has been called.
      void outputResult​(Object result)
      Output final result of this UDTF to downstreams.
      void reset()
      Resets the flag to indicate whether [[collect(T)]] has been called.
      void setCollector​(org.apache.flink.util.Collector<?> collector)
      Sets the current collector, which used to emit the final row.
      void setInput​(Object input)
      Sets the input row from left table, which will be used to cross join with the result of table function.
      • Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

        getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
      • Methods inherited from interface org.apache.flink.util.Collector

        collect
    • Constructor Detail

      • TableFunctionCollector

        public TableFunctionCollector()
    • Method Detail

      • setInput

        public void setInput​(Object input)
        Sets the input row from left table, which will be used to cross join with the result of table function.
      • getInput

        public Object getInput()
        Gets the input value from left table, which will be used to cross join with the result of table function.
      • setCollector

        public void setCollector​(org.apache.flink.util.Collector<?> collector)
        Sets the current collector, which used to emit the final row.
      • reset

        public void reset()
        Resets the flag to indicate whether [[collect(T)]] has been called.
      • outputResult

        public void outputResult​(Object result)
        Output final result of this UDTF to downstreams.
      • isCollected

        public boolean isCollected()
        Whether Collector.collect(Object) has been called.
        Returns:
        True if Collector.collect(Object) has been called.
      • close

        public void close()
        Specified by:
        close in interface org.apache.flink.util.Collector<T>
        Specified by:
        close in interface org.apache.flink.api.common.functions.RichFunction
        Overrides:
        close in class org.apache.flink.api.common.functions.AbstractRichFunction