Uses of Class
org.apache.flink.streaming.runtime.streamrecord.StreamElement

Packages that use StreamElement

Package	Description
org.apache.flink.streaming.api.operators.async.queue
org.apache.flink.streaming.api.watermark
org.apache.flink.streaming.runtime.streamrecord
org.apache.flink.streaming.runtime.streamstatus

Uses of StreamElement in org.apache.flink.streaming.api.operators.async.queue

Methods in org.apache.flink.streaming.api.operators.async.queue that return StreamElement

Modifier and Type	Method and Description
StreamElement	StreamElementQueueEntry.getStreamElement()

Constructors in org.apache.flink.streaming.api.operators.async.queue with parameters of type StreamElement

Constructor and Description
StreamElementQueueEntry(StreamElement streamElement)

Uses of StreamElement in org.apache.flink.streaming.api.watermark

Subclasses of StreamElement in org.apache.flink.streaming.api.watermark

Modifier and Type	Class and Description
class	Watermark A Watermark tells operators that no elements with a timestamp older or equal to the watermark timestamp should arrive at the operator.

Uses of StreamElement in org.apache.flink.streaming.runtime.streamrecord

Subclasses of StreamElement in org.apache.flink.streaming.runtime.streamrecord

Modifier and Type	Class and Description
class	LatencyMarker Special record type carrying a timestamp of its creation time at a source operator and the vertexId and subtask index of the operator.
class	StreamRecord<T> One value in a data stream.

Methods in org.apache.flink.streaming.runtime.streamrecord that return StreamElement

Modifier and Type	Method and Description
StreamElement	StreamElementSerializer.copy(StreamElement from)
StreamElement	StreamElementSerializer.copy(StreamElement from, StreamElement reuse)
StreamElement	StreamElementSerializer.deserialize(org.apache.flink.core.memory.DataInputView source)
StreamElement	StreamElementSerializer.deserialize(StreamElement reuse, org.apache.flink.core.memory.DataInputView source)

Methods in org.apache.flink.streaming.runtime.streamrecord that return types with arguments of type StreamElement

Modifier and Type	Method and Description
org.apache.flink.api.common.typeutils.CompatibilityResult<StreamElement>	StreamElementSerializer.ensureCompatibility(org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot<?> configSnapshot)

Methods in org.apache.flink.streaming.runtime.streamrecord with parameters of type StreamElement

Modifier and Type	Method and Description
StreamElement	StreamElementSerializer.copy(StreamElement from)
StreamElement	StreamElementSerializer.copy(StreamElement from, StreamElement reuse)
StreamElement	StreamElementSerializer.deserialize(StreamElement reuse, org.apache.flink.core.memory.DataInputView source)
void	StreamElementSerializer.serialize(StreamElement value, org.apache.flink.core.memory.DataOutputView target)

Uses of StreamElement in org.apache.flink.streaming.runtime.streamstatus

Subclasses of StreamElement in org.apache.flink.streaming.runtime.streamstatus

Modifier and Type	Class and Description
class	StreamStatus A Stream Status element informs stream tasks whether or not they should continue to expect records and watermarks from the input stream that sent them.