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)
Modifier and Type | Field and Description |
---|---|
static AsyncDataStream$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
AsyncDataStream$() |
Modifier and Type | Method and Description |
---|---|
<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.
|
<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.
|
<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.
|
<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.
|
<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.
|
<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.
|
<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.
|
<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 final AsyncDataStream$ MODULE$
public <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
operationsevidence$1
- (undocumented)public <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 timeoutevidence$2
- (undocumented)public <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 useevidence$3
- (undocumented)public <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 useevidence$4
- (undocumented)public <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
operationsevidence$5
- (undocumented)public <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 timeoutevidence$6
- (undocumented)public <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 useevidence$7
- (undocumented)public <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 useevidence$8
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.