Uses of Class
org.apache.flink.streaming.api.datastream.DataStreamSource

Packages that use DataStreamSource

Package	Description
org.apache.flink.state.api.input
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.environment

Uses of DataStreamSource in org.apache.flink.state.api.input

Methods in org.apache.flink.state.api.input that return DataStreamSource

Modifier and Type	Method	Description
static <OUT> DataStreamSource<OUT>	SourceBuilder.fromFormat(StreamExecutionEnvironment env, InputFormat<OUT,?> inputFormat, TypeInformation<OUT> typeInfo)	Creates a new source that is bounded.

Uses of DataStreamSource in org.apache.flink.streaming.api.datastream

Methods in org.apache.flink.streaming.api.datastream that return DataStreamSource

Modifier and Type	Method	Description
DataStreamSource<T>	DataStreamSource.setParallelism(int parallelism)

Uses of DataStreamSource in org.apache.flink.streaming.api.environment

Methods in org.apache.flink.streaming.api.environment that return DataStreamSource

Modifier and Type	Method	Description
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.addSource(SourceFunction<OUT> function)	Deprecated. This method relies on the SourceFunction API, which is due to be removed.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.addSource(SourceFunction<OUT> function, String sourceName)	Deprecated. This method relies on the SourceFunction API, which is due to be removed.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.addSource(SourceFunction<OUT> function, String sourceName, TypeInformation<OUT> typeInfo)	Deprecated. This method relies on the SourceFunction API, which is due to be removed.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.addSource(SourceFunction<OUT> function, TypeInformation<OUT> typeInfo)	Deprecated. This method relies on the SourceFunction API, which is due to be removed.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.createInput(InputFormat<OUT,?> inputFormat)	Generic method to create an input data stream with InputFormat.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.createInput(InputFormat<OUT,?> inputFormat, TypeInformation<OUT> typeInfo)	Generic method to create an input data stream with InputFormat.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.fromCollection(Collection<OUT> data)	Deprecated. This method will be removed a future release, possibly as early as version 2.0.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.fromCollection(Collection<OUT> data, TypeInformation<OUT> typeInfo)	Deprecated. This method will be removed a future release, possibly as early as version 2.0.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.fromCollection(Iterator<OUT> data, Class<OUT> type)	Deprecated. This method will be removed a future release, possibly as early as version 2.0.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.fromCollection(Iterator<OUT> data, TypeInformation<OUT> typeInfo)	Deprecated. This method will be removed a future release, possibly as early as version 2.0.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.fromData(Class<OUT> type, OUT... data)	Creates a new data stream that contains the given elements.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.fromData(Collection<OUT> data)	Creates a new data stream that contains the given elements.The type of the data stream is that of the elements in the collection.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.fromData(Collection<OUT> data, TypeInformation<OUT> typeInfo)	Creates a new data stream that contains the given elements.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.fromData(TypeInformation<OUT> typeInfo, OUT... data)	Creates a new data stream that contains the given elements.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.fromData(OUT... data)	Creates a new data stream that contains the given elements.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.fromElements(Class<OUT> type, OUT... data)	Deprecated. This method will be removed a future release, possibly as early as version 2.0.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.fromElements(OUT... data)	Deprecated. This method will be removed a future release, possibly as early as version 2.0.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.fromParallelCollection(SplittableIterator<OUT> iterator, Class<OUT> type)	Creates a new data stream that contains elements in the iterator.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.fromParallelCollection(SplittableIterator<OUT> iterator, TypeInformation<OUT> typeInfo)	Creates a new data stream that contains elements in the iterator.
DataStreamSource<Long>	StreamExecutionEnvironment.fromSequence(long from, long to)	Creates a new data stream that contains a sequence of numbers (longs) and is useful for testing and for cases that just need a stream of N events of any kind.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.fromSource(Source<OUT,?,?> source, WatermarkStrategy<OUT> timestampsAndWatermarks, String sourceName)	Adds a data Source to the environment to get a DataStream.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.fromSource(Source<OUT,?,?> source, WatermarkStrategy<OUT> timestampsAndWatermarks, String sourceName, TypeInformation<OUT> typeInfo)	Adds a data Source to the environment to get a DataStream.
DataStreamSource<Long>	StreamExecutionEnvironment.generateSequence(long from, long to)	Deprecated. Use StreamExecutionEnvironment.fromSequence(long, long) instead to create a new data stream that contains NumberSequenceSource.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.readFile(FileInputFormat<OUT> inputFormat, String filePath)	Deprecated. Use FileSource#forRecordStreamFormat()/forBulkFileFormat()/forRecordFileFormat() instead.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.readFile(FileInputFormat<OUT> inputFormat, String filePath, FileProcessingMode watchType, long interval)	Deprecated. Use FileSource#forRecordStreamFormat()/forBulkFileFormat()/forRecordFileFormat() instead.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.readFile(FileInputFormat<OUT> inputFormat, String filePath, FileProcessingMode watchType, long interval, FilePathFilter filter)	Deprecated. Use FileInputFormat.setFilesFilter(FilePathFilter) to set a filter and StreamExecutionEnvironment.readFile(FileInputFormat, String, FileProcessingMode, long)
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.readFile(FileInputFormat<OUT> inputFormat, String filePath, FileProcessingMode watchType, long interval, TypeInformation<OUT> typeInformation)	Deprecated. Use FileSource#forRecordStreamFormat()/forBulkFileFormat()/forRecordFileFormat() instead.
DataStreamSource<String>	StreamExecutionEnvironment.socketTextStream(String hostname, int port)	Creates a new data stream that contains the strings received infinitely from a socket.
DataStreamSource<String>	StreamExecutionEnvironment.socketTextStream(String hostname, int port, char delimiter)	Deprecated. Use StreamExecutionEnvironment.socketTextStream(String, int, String) instead.
DataStreamSource<String>	StreamExecutionEnvironment.socketTextStream(String hostname, int port, char delimiter, long maxRetry)	Deprecated. Use StreamExecutionEnvironment.socketTextStream(String, int, String, long) instead.
DataStreamSource<String>	StreamExecutionEnvironment.socketTextStream(String hostname, int port, String delimiter)	Creates a new data stream that contains the strings received infinitely from a socket.
DataStreamSource<String>	StreamExecutionEnvironment.socketTextStream(String hostname, int port, String delimiter, long maxRetry)	Creates a new data stream that contains the strings received infinitely from a socket.