public abstract class TableFunctionCollector<T> extends Object implements Collector<T>
TableFunction
.Constructor and Description |
---|
TableFunctionCollector() |
Modifier and Type | Method and Description |
---|---|
void |
collect(T record)
Emits a record.
|
Collector<?> |
getCollector()
Gets the internal collector which used to emit the final row.
|
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
collect(T) has been called. |
void |
reset()
Resets the flag to indicate whether
collect(T) has been called. |
void |
setCollector(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.
|
public void setInput(Object input)
input
- (undocumented)public Object getInput()
public void setCollector(Collector<?> collector)
collector
- (undocumented)public Collector<?> getCollector()
public void reset()
collect(T)
has been called.public boolean isCollected()
collect(T)
has been called.
collect(T)
has been called.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.