org.apache.flink.streaming.api.datastream

Class DataStreamSource<T>

java.lang.Object

org.apache.flink.streaming.api.datastream.DataStream<T>

org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<T>

org.apache.flink.streaming.api.datastream.DataStreamSource<T>

Type Parameters:

T - Type of the elements in the DataStream created from the this source.

@Public
public class DataStreamSource<T>
extends SingleOutputStreamOperator<T>

The DataStreamSource represents the starting point of a DataStream.

Field Summary

Fields inherited from class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator

nonParallel

Fields inherited from class org.apache.flink.streaming.api.datastream.DataStream

environment, transformation

Constructor Summary

Constructors

Constructor and Description
DataStreamSource(SingleOutputStreamOperator<T> operator)
DataStreamSource(StreamExecutionEnvironment environment, TypeInformation<T> outTypeInfo, StreamSource<T,?> operator, boolean isParallel, String sourceName)

Method Summary

Modifier and Type	Method and Description
DataStreamSource<T>	setParallelism(int parallelism) Sets the parallelism for this operator.

Methods inherited from class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator

disableChaining, forceNonParallel, getName, getSideOutput, name, returns, returns, returns, returns, setBufferTimeout, setMaxParallelism, setUidHash, slotSharingGroup, split, startNewChain, uid

Methods inherited from class org.apache.flink.streaming.api.datastream.DataStream

addSink, assignTimestamps, assignTimestampsAndWatermarks, assignTimestampsAndWatermarks, broadcast, broadcast, clean, coGroup, connect, connect, countWindowAll, countWindowAll, filter, flatMap, forward, getExecutionConfig, getExecutionEnvironment, getId, getMinResources, getParallelism, getPreferredResources, getTransformation, getType, global, iterate, iterate, join, keyBy, keyBy, keyBy, map, partitionCustom, partitionCustom, partitionCustom, print, printToErr, process, process, project, rebalance, rescale, setConnectionType, shuffle, timeWindowAll, timeWindowAll, transform, union, windowAll, writeAsCsv, writeAsCsv, writeAsCsv, writeAsText, writeAsText, writeToSocket, writeUsingOutputFormat

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DataStreamSource

public DataStreamSource(StreamExecutionEnvironment environment,
                        TypeInformation<T> outTypeInfo,
                        StreamSource<T,?> operator,
                        boolean isParallel,
                        String sourceName)

DataStreamSource

public DataStreamSource(SingleOutputStreamOperator<T> operator)

Method Detail

setParallelism

public DataStreamSource<T> setParallelism(int parallelism)

Description copied from class: SingleOutputStreamOperator

Sets the parallelism for this operator.

Overrides:

setParallelism in class SingleOutputStreamOperator<T>

Parameters:

parallelism - The parallelism for this operator.

Returns:

The operator with set parallelism.