Abstract class StreamElement
Class StreamExecutionEnvironment
List<Transformation<?>> transformations = new ArrayList<>();StreamGraphGenerator getStreamGraphGenerator()StreamGraph getStreamGraph(): StreamGraphGenerator.generate addOperator(Transformation<?> transformation) : this.transformations.add(transformation);JobExecutionResult execute(StreamGraph streamGraph)
Interface OneInputStreamOperator
对应Transformation，还有其他TwoInputStreamOperator等等，很多OperatorprocessElement(StreamRecord<IN> var1)processWatermark(Watermark mark)processLatencyMarker(LatencyMarker latencyMarker)
Class StreamRecord
abstract class AbstractStreamOperator
Output<StreamRecord<OUT>> output
classStreamingJobGraphGenerator
将StreamGraph转化成JobGraph
class SinkTransformation<T>
classRemoteStreamEnvironment
class UnionTransformation
Class DataStream
StreamExecutionEnvironment environment;Transformation<T> transformation;
每一个操作environment都会添加operator
Class StreamGraphGenerator
StreamGraph generate(): 具体的生成StreamGraph的过程
Interface StreamOperator
+ operation1(params):returnType- operation2(params)- operation3()
Class DataStreamSource
两个包：org.apache.flink.api.java org.apache.flink.stream.api.java
interface Function
class MultipleInputTransformation<OUT>
List<Transformation<?>> inputs
Class KeyedStream
O map(T var1)
Class SplitStream(弃用)
Abstract class Transformation
代表一个产生DataStream的operation
Class SingleOutputStreamOperator
abstract class PhysicalTransformation
abstract class AbstractUdfStreamOperator
Function userFunctionopen()close()
class SourceTransformation<T>
class LocalStreamEnvironment
