public class AsyncDataStream extends Object
AsyncFunction
to a data stream.
Example:
val input: DataStream[String] = ...
val asyncFunction: (String, AsyncCollector[String]) => Unit = ...
AsyncDataStream.orderedWait(input, asyncFunction, timeout, TimeUnit.MILLISECONDS, 100)
Constructor and Description |
---|
AsyncDataStream() |
Modifier and Type | Method and Description |
---|---|
static <IN,OUT> DataStream<OUT> |
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> |
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> |
orderedWait(DataStream<IN> input,
long timeout,
TimeUnit timeUnit,
scala.Function2<IN,AsyncCollector<OUT>,scala.runtime.BoxedUnit> asyncFunction,
TypeInformation<OUT> evidence$8)
Apply an asynchronous function on the input data stream.
|
static <IN,OUT> DataStream<OUT> |
orderedWait(DataStream<IN> input,
long timeout,
TimeUnit timeUnit,
int capacity,
scala.Function2<IN,AsyncCollector<OUT>,scala.runtime.BoxedUnit> asyncFunction,
TypeInformation<OUT> evidence$7)
Apply an asynchronous function on the input data stream.
|
static <IN,OUT> DataStream<OUT> |
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> |
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> |
unorderedWait(DataStream<IN> input,
long timeout,
TimeUnit timeUnit,
scala.Function2<IN,AsyncCollector<OUT>,scala.runtime.BoxedUnit> asyncFunction,
TypeInformation<OUT> evidence$4)
Apply an asynchronous function on the input data stream.
|
static <IN,OUT> DataStream<OUT> |
unorderedWait(DataStream<IN> input,
long timeout,
TimeUnit timeUnit,
int capacity,
scala.Function2<IN,AsyncCollector<OUT>,scala.runtime.BoxedUnit> asyncFunction,
TypeInformation<OUT> evidence$3)
Apply an asynchronous function on the input data stream.
|
public static <IN,OUT> DataStream<OUT> unorderedWait(DataStream<IN> input, AsyncFunction<IN,OUT> asyncFunction, long timeout, TimeUnit timeUnit, int capacity, TypeInformation<OUT> evidence$1)
input
- to apply the async function onasyncFunction
- to usetimeout
- for the asynchronous operation to completetimeUnit
- of the timeoutcapacity
- of the operator which is equivalent to the number of concurrent asynchronous
operationspublic static <IN,OUT> DataStream<OUT> unorderedWait(DataStream<IN> input, AsyncFunction<IN,OUT> asyncFunction, long timeout, TimeUnit timeUnit, TypeInformation<OUT> evidence$2)
input
- to apply the async function onasyncFunction
- to usetimeout
- for the asynchronous operation to completetimeUnit
- of the timeoutpublic static <IN,OUT> DataStream<OUT> unorderedWait(DataStream<IN> input, long timeout, TimeUnit timeUnit, int capacity, scala.Function2<IN,AsyncCollector<OUT>,scala.runtime.BoxedUnit> asyncFunction, TypeInformation<OUT> evidence$3)
input
- to apply the async function ontimeout
- for the asynchronous operation to completetimeUnit
- of the timeoutcapacity
- of the operator which is equivalent to the number of concurrent asynchronous
operationsasyncFunction
- to usepublic static <IN,OUT> DataStream<OUT> unorderedWait(DataStream<IN> input, long timeout, TimeUnit timeUnit, scala.Function2<IN,AsyncCollector<OUT>,scala.runtime.BoxedUnit> asyncFunction, TypeInformation<OUT> evidence$4)
input
- to apply the async function ontimeout
- for the asynchronous operation to completetimeUnit
- of the timeoutasyncFunction
- to usepublic static <IN,OUT> DataStream<OUT> orderedWait(DataStream<IN> input, AsyncFunction<IN,OUT> asyncFunction, long timeout, TimeUnit timeUnit, int capacity, TypeInformation<OUT> evidence$5)
input
- to apply the async function onasyncFunction
- to usetimeout
- for the asynchronous operation to completetimeUnit
- of the timeoutcapacity
- of the operator which is equivalent to the number of concurrent asynchronous
operationspublic static <IN,OUT> DataStream<OUT> orderedWait(DataStream<IN> input, AsyncFunction<IN,OUT> asyncFunction, long timeout, TimeUnit timeUnit, TypeInformation<OUT> evidence$6)
input
- to apply the async function onasyncFunction
- to usetimeout
- for the asynchronous operation to completetimeUnit
- of the timeoutpublic static <IN,OUT> DataStream<OUT> orderedWait(DataStream<IN> input, long timeout, TimeUnit timeUnit, int capacity, scala.Function2<IN,AsyncCollector<OUT>,scala.runtime.BoxedUnit> asyncFunction, TypeInformation<OUT> evidence$7)
input
- to apply the async function ontimeout
- for the asynchronous operation to completetimeUnit
- of the timeoutcapacity
- of the operator which is equivalent to the number of concurrent asynchronous
operationsasyncFunction
- to usepublic static <IN,OUT> DataStream<OUT> orderedWait(DataStream<IN> input, long timeout, TimeUnit timeUnit, scala.Function2<IN,AsyncCollector<OUT>,scala.runtime.BoxedUnit> asyncFunction, TypeInformation<OUT> evidence$8)
input
- to apply the async function ontimeout
- for the asynchronous operation to completetimeUnit
- of the timeoutasyncFunction
- to useCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.