Package | Description |
---|---|
org.apache.flink.streaming.api.scala |
Modifier and Type | Method and Description |
---|---|
<IN,OUT> DataStream<OUT> |
AsyncDataStream$.orderedWait(DataStream<IN> input,
AsyncFunction<IN,OUT> asyncFunction,
long timeout,
TimeUnit timeUnit,
int capacity,
TypeInformation<OUT> evidence$5)
Apply an asynchronous function on the input data stream.
|
static <IN,OUT> DataStream<OUT> |
AsyncDataStream.orderedWait(DataStream<IN> input,
AsyncFunction<IN,OUT> asyncFunction,
long timeout,
TimeUnit timeUnit,
int capacity,
TypeInformation<OUT> evidence$5)
Apply an asynchronous function on the input data stream.
|
<IN,OUT> DataStream<OUT> |
AsyncDataStream$.orderedWait(DataStream<IN> input,
AsyncFunction<IN,OUT> asyncFunction,
long timeout,
TimeUnit timeUnit,
TypeInformation<OUT> evidence$6)
Apply an asynchronous function on the input data stream.
|
static <IN,OUT> DataStream<OUT> |
AsyncDataStream.orderedWait(DataStream<IN> input,
AsyncFunction<IN,OUT> asyncFunction,
long timeout,
TimeUnit timeUnit,
TypeInformation<OUT> evidence$6)
Apply an asynchronous function on the input data stream.
|
<IN,OUT> DataStream<OUT> |
AsyncDataStream$.unorderedWait(DataStream<IN> input,
AsyncFunction<IN,OUT> asyncFunction,
long timeout,
TimeUnit timeUnit,
int capacity,
TypeInformation<OUT> evidence$1)
Apply an asynchronous function on the input data stream.
|
static <IN,OUT> DataStream<OUT> |
AsyncDataStream.unorderedWait(DataStream<IN> input,
AsyncFunction<IN,OUT> asyncFunction,
long timeout,
TimeUnit timeUnit,
int capacity,
TypeInformation<OUT> evidence$1)
Apply an asynchronous function on the input data stream.
|
<IN,OUT> DataStream<OUT> |
AsyncDataStream$.unorderedWait(DataStream<IN> input,
AsyncFunction<IN,OUT> asyncFunction,
long timeout,
TimeUnit timeUnit,
TypeInformation<OUT> evidence$2)
Apply an asynchronous function on the input data stream.
|
static <IN,OUT> DataStream<OUT> |
AsyncDataStream.unorderedWait(DataStream<IN> input,
AsyncFunction<IN,OUT> asyncFunction,
long timeout,
TimeUnit timeUnit,
TypeInformation<OUT> evidence$2)
Apply an asynchronous function on the input data stream.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.