public abstract class TableFunctionResultFuture<T> extends AbstractRichFunction implements ResultFuture<T>
ResultFuture
in table joining.Constructor and Description |
---|
TableFunctionResultFuture() |
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.
|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
complete
public void setInput(Object input)
public Object getInput()
public void setResultFuture(ResultFuture<?> resultFuture)
public ResultFuture<?> getResultFuture()
public void completeExceptionally(Throwable error)
ResultFuture
completeExceptionally
in interface ResultFuture<T>
error
- A Throwable object.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.