Package | Description |
---|---|
org.apache.flink.streaming.api.scala | |
org.apache.flink.streaming.api.scala.async |
Modifier and Type | Method and Description |
---|---|
<IN,OUT> DataStream<OUT> |
AsyncDataStream$.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> |
AsyncDataStream.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> |
AsyncDataStream$.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> |
AsyncDataStream.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> |
AsyncDataStream$.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> |
AsyncDataStream.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> |
AsyncDataStream$.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.
|
static <IN,OUT> DataStream<OUT> |
AsyncDataStream.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.
|
Modifier and Type | Class and Description |
---|---|
class |
JavaAsyncCollectorWrapper<OUT>
Internal wrapper class to map a Flink's Java API
JavaAsyncCollector to a Scala
AsyncCollector . |
Modifier and Type | Method and Description |
---|---|
void |
AsyncFunction.asyncInvoke(IN input,
AsyncCollector<OUT> collector)
Trigger the async operation for each stream input
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.