public abstract class TableFunctionCollector<T> extends AbstractRichFunction implements Collector<T>
TableFunction
.Constructor and Description |
---|
TableFunctionCollector() |
Modifier and Type | Method and Description |
---|---|
void |
close()
Tear-down method for the user code.
|
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(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.
|
getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public void setInput(Object input)
public Object getInput()
public void setCollector(Collector<?> collector)
public void reset()
public void outputResult(Object result)
public boolean isCollected()
Collector.collect(Object)
has been called.Collector.collect(Object)
has been called.public void close()
RichFunction
This method can be used for clean up work.
close
in interface RichFunction
close
in interface Collector<T>
close
in class AbstractRichFunction
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.