TableFunctionCollector (Flink : Table : Runtime 1.19.2-cp2 API)

java.lang.Object
- org.apache.flink.api.common.functions.AbstractRichFunction
- - org.apache.flink.table.runtime.collector.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

Constructor Summary

Constructors
Constructor Description

TableFunctionCollector()

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 class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.util.Collector
collect

Methods inherited from interface org.apache.flink.api.common.functions.RichFunction
open

- 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