Modifier and Type | Method and Description |
---|---|
void |
AsyncFunction.asyncInvoke(IN input,
ResultFuture<OUT> resultFuture)
Trigger async operation for each stream input.
|
abstract void |
RichAsyncFunction.asyncInvoke(IN input,
ResultFuture<OUT> resultFuture) |
default void |
AsyncFunction.timeout(IN input,
ResultFuture<OUT> resultFuture)
|
Modifier and Type | Class and Description |
---|---|
class |
StreamRecordQueueEntry<OUT>
StreamElementQueueEntry implementation for StreamRecord . |
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(BaseRow input,
ResultFuture<BaseRow> resultFuture) |
Constructor and Description |
---|
DelegatingResultFuture(ResultFuture<OUT> delegatedResultFuture) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.