Modifier and Type | Method and Description |
---|---|
abstract void |
RichAsyncFunction.asyncInvoke(IN input,
ResultFuture<OUT> resultFuture) |
void |
AsyncFunction.asyncInvoke(IN input,
ResultFuture<OUT> resultFuture)
Trigger async operation for each stream input.
|
default void |
AsyncFunction.timeout(IN input,
ResultFuture<OUT> resultFuture)
|
Modifier and Type | Method and Description |
---|---|
Optional<ResultFuture<OUT>> |
OrderedStreamElementQueue.tryPut(StreamElement streamElement) |
Optional<ResultFuture<OUT>> |
StreamElementQueue.tryPut(StreamElement streamElement)
Tries to put the given element in the queue.
|
Optional<ResultFuture<OUT>> |
UnorderedStreamElementQueue.tryPut(StreamElement streamElement) |
Modifier and Type | Class and Description |
---|---|
class |
TableFunctionResultFuture<T>
The basic implementation of collector for
ResultFuture in table joining. |
Modifier and Type | Method and Description |
---|---|
ResultFuture<?> |
TableFunctionResultFuture.getResultFuture()
Gets the internal collector which used to emit the final row.
|
Modifier and Type | Method and Description |
---|---|
void |
TableFunctionResultFuture.setResultFuture(ResultFuture<?> resultFuture)
Sets the current collector, which used to emit the final row.
|
Modifier and Type | Class and Description |
---|---|
class |
GeneratedResultFuture<T extends ResultFuture<?>>
Describes a generated
ResultFuture . |
Modifier and Type | Method and Description |
---|---|
void |
AsyncLookupJoinRunner.asyncInvoke(RowData input,
ResultFuture<RowData> resultFuture) |
Constructor and Description |
---|
DelegatingResultFuture(ResultFuture<OUT> delegatedResultFuture) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.