Modifier and Type | Method and Description |
---|---|
static <IN,OUT> SingleOutputStreamOperator<OUT> |
AsyncDataStream.orderedWait(DataStream<IN> in,
AsyncFunction<IN,OUT> func,
long timeout,
TimeUnit timeUnit)
Add an AsyncWaitOperator.
|
static <IN,OUT> SingleOutputStreamOperator<OUT> |
AsyncDataStream.orderedWait(DataStream<IN> in,
AsyncFunction<IN,OUT> func,
long timeout,
TimeUnit timeUnit,
int capacity)
Add an AsyncWaitOperator.
|
static <IN,OUT> SingleOutputStreamOperator<OUT> |
AsyncDataStream.unorderedWait(DataStream<IN> in,
AsyncFunction<IN,OUT> func,
long timeout,
TimeUnit timeUnit)
Add an AsyncWaitOperator.
|
static <IN,OUT> SingleOutputStreamOperator<OUT> |
AsyncDataStream.unorderedWait(DataStream<IN> in,
AsyncFunction<IN,OUT> func,
long timeout,
TimeUnit timeUnit,
int capacity)
Add an AsyncWaitOperator.
|
Modifier and Type | Class and Description |
---|---|
class |
RichAsyncFunction<IN,OUT>
Rich variant of the
AsyncFunction . |
Constructor and Description |
---|
AsyncWaitOperator(AsyncFunction<IN,OUT> asyncFunction,
long timeout,
int capacity,
AsyncDataStream.OutputMode outputMode,
ProcessingTimeService processingTimeService,
MailboxExecutor mailboxExecutor) |
AsyncWaitOperatorFactory(AsyncFunction<IN,OUT> asyncFunction,
long timeout,
int capacity,
AsyncDataStream.OutputMode outputMode) |
Modifier and Type | Class and Description |
---|---|
class |
AsyncLookupJoinRunner
The async join runner to lookup the dimension table.
|
class |
AsyncLookupJoinWithCalcRunner
The async join runner with an additional calculate function on the dimension table.
|
Constructor and Description |
---|
AsyncLookupJoinRunner(GeneratedFunction<AsyncFunction<RowData,Object>> generatedFetcher,
DataStructureConverter<RowData,Object> fetcherConverter,
GeneratedResultFuture<TableFunctionResultFuture<RowData>> generatedResultFuture,
RowDataSerializer rightRowSerializer,
boolean isLeftOuterJoin,
int asyncBufferCapacity) |
AsyncLookupJoinWithCalcRunner(GeneratedFunction<AsyncFunction<RowData,Object>> generatedFetcher,
DataStructureConverter<RowData,Object> fetcherConverter,
GeneratedFunction<FlatMapFunction<RowData,RowData>> generatedCalc,
GeneratedResultFuture<TableFunctionResultFuture<RowData>> generatedResultFuture,
RowDataSerializer rightRowSerializer,
boolean isLeftOuterJoin,
int asyncBufferCapacity) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.