org.apache.flink.table.runtime.collector

Class TableFunctionResultFuture<T>

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.table.runtime.collector.TableFunctionResultFuture<T>

All Implemented Interfaces:

Serializable, Function, RichFunction, ResultFuture<T>

public abstract class TableFunctionResultFuture<T>
extends AbstractRichFunction
implements ResultFuture<T>

The basic implementation of collector for ResultFuture in table joining.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TableFunctionResultFuture()

Method Summary

Modifier and Type	Method and Description
void	completeExceptionally(Throwable error) Completes the result future exceptionally with an exception.
Object	getInput() Gets the input value from left table, which will be used to cross join with the result of right table.
ResultFuture<?>	getResultFuture() Gets the internal 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 right table.
void	setResultFuture(ResultFuture<?> resultFuture) Sets the current collector, which used to emit the final row.

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, 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.streaming.api.functions.async.ResultFuture

complete

Constructor Detail

TableFunctionResultFuture

public TableFunctionResultFuture()

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 right table.

getInput

public Object getInput()

Gets the input value from left table, which will be used to cross join with the result of right table.

setResultFuture

public void setResultFuture(ResultFuture<?> resultFuture)

Sets the current collector, which used to emit the final row.

getResultFuture

public ResultFuture<?> getResultFuture()

Gets the internal collector which used to emit the final row.

completeExceptionally

public void completeExceptionally(Throwable error)

Description copied from interface: ResultFuture

Completes the result future exceptionally with an exception.

Specified by:

completeExceptionally in interface ResultFuture<T>

Parameters:

error - A Throwable object.