org.apache.flink.streaming.api.datastream

接口

• PartitionWindowedStream

类

• AllWindowedStream
• AsyncDataStream
• BroadcastConnectedStream
• BroadcastStream
• CachedDataStream
• CoGroupedStreams
• CoGroupedStreams.TaggedUnion
• CoGroupedStreams.UnionSerializer
• CoGroupedStreams.UnionSerializerSnapshot
• CoGroupedStreams.WithWindow
• ConnectedStreams
• CustomSinkOperatorUidHashes
• CustomSinkOperatorUidHashes.SinkOperatorUidHashesBuilder
• DataStream
• DataStream.Collector
• DataStreamSink
• DataStreamSource
• DataStreamUtils
• IterativeStream
• IterativeStream.ConnectedIterativeStreams
• JoinedStreams
• JoinedStreams.WithWindow
• KeyedPartitionWindowedStream
• KeyedStream
• KeyedStream.IntervalJoin
• KeyedStream.IntervalJoined
• MultipleConnectedStreams
• NonKeyedPartitionWindowedStream
• QueryableStateStream
• SideOutputDataStream
• SingleOutputStreamOperator
• StreamProjection
• WindowedStream

枚举

• AsyncDataStream.OutputMode

异常错误

• UnsupportedTimeCharacteristicException