Modifier and Type | Method and Description |
---|---|
void |
SpoutWrapper.run(SourceFunction.SourceContext<OUT> ctx) |
Modifier and Type | Method and Description |
---|---|
void |
StatefulSequenceSource.run(SourceFunction.SourceContext<Long> ctx) |
void |
FileSourceFunction.run(SourceFunction.SourceContext<OUT> ctx) |
void |
SocketTextStreamFunction.run(SourceFunction.SourceContext<String> ctx) |
void |
SourceFunction.run(SourceFunction.SourceContext<T> ctx)
Starts the source.
|
void |
FromSplittableIteratorFunction.run(SourceFunction.SourceContext<T> ctx) |
void |
FromIteratorFunction.run(SourceFunction.SourceContext<T> ctx) |
void |
FromElementsFunction.run(SourceFunction.SourceContext<T> ctx) |
void |
FileMonitoringFunction.run(SourceFunction.SourceContext<Tuple3<String,Long,Long>> ctx) |
Modifier and Type | Class and Description |
---|---|
static class |
StreamSource.AutomaticWatermarkContext<T>
SourceFunction.SourceContext to be used for sources with automatic timestamps
and watermark emission. |
static class |
StreamSource.ManualWatermarkContext<T>
A SourceContext for event time.
|
static class |
StreamSource.NonTimestampContext<T>
A source context that attached
-1 as a timestamp to all records, and that
does not forward watermarks. |
Modifier and Type | Method and Description |
---|---|
<T> DataStream<T> |
StreamExecutionEnvironment.addSource(scala.Function1<SourceFunction.SourceContext<T>,scala.runtime.BoxedUnit> function,
TypeInformation<T> evidence$8)
Create a DataStream using a user defined source function for arbitrary
source functionality.
|
Modifier and Type | Method and Description |
---|---|
void |
FlinkKafkaConsumer09.run(SourceFunction.SourceContext<T> sourceContext) |
void |
FlinkKafkaConsumer08.run(SourceFunction.SourceContext<T> sourceContext) |
Modifier and Type | Method and Description |
---|---|
<T> void |
LegacyFetcher.run(SourceFunction.SourceContext<T> sourceContext,
KeyedDeserializationSchema<T> deserializer,
HashMap<KafkaTopicPartition,Long> lastOffsets) |
<T> void |
Fetcher.run(SourceFunction.SourceContext<T> sourceContext,
KeyedDeserializationSchema<T> valueDeserializer,
HashMap<KafkaTopicPartition,Long> lastOffsets)
Starts fetch data from Kafka and emitting it into the stream.
|
Modifier and Type | Method and Description |
---|---|
void |
NiFiSource.run(SourceFunction.SourceContext<NiFiDataPacket> ctx) |
Modifier and Type | Method and Description |
---|---|
void |
RMQSource.run(SourceFunction.SourceContext<OUT> ctx) |
Modifier and Type | Method and Description |
---|---|
void |
TwitterSource.run(SourceFunction.SourceContext<String> ctx) |
Modifier and Type | Method and Description |
---|---|
void |
WikipediaEditsSource.run(SourceFunction.SourceContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
WindowJoin.GradeSource.run(SourceFunction.SourceContext<Tuple3<Long,String,Integer>> ctx) |
void |
WindowJoin.SalarySource.run(SourceFunction.SourceContext<Tuple3<Long,String,Integer>> ctx) |
Modifier and Type | Method and Description |
---|---|
void |
IncrementalLearningSkeleton.FiniteNewDataSource.run(SourceFunction.SourceContext<Integer> ctx) |
void |
IncrementalLearningSkeleton.FiniteTrainingDataSource.run(SourceFunction.SourceContext<Integer> collector) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.