Flink类图

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