Package org.apache.flink.streaming.runtime.streamrecord

Class Summary

Class	Description
LatencyMarker	Special record type carrying a timestamp of its creation time at a source operator and the vertexId and subtask index of the operator.
StreamElement	An element in a data stream.
StreamElementSerializer<T>	Serializer for StreamRecord, Watermark, LatencyMarker, and WatermarkStatus.
StreamElementSerializer.StreamElementSerializerSnapshot<T>	Configuration snapshot specific to the StreamElementSerializer.
StreamRecord<T>	One value in a data stream.