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.io
org.apache.flink.streaming.runtime.streamrecord
org.apache.flink.streaming.runtime.watermarkstatus

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

Methods in org.apache.flink.streaming.api.operators.async.queue that return types with arguments of type StreamElement

Modifier and Type	Method and Description
List<StreamElement>	UnorderedStreamElementQueue.values()
List<StreamElement>	OrderedStreamElementQueue.values()
List<StreamElement>	StreamElementQueue.values() Returns the collection of StreamElement currently contained in this queue for checkpointing.

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

Modifier and Type	Method and Description
Optional<ResultFuture<OUT>>	UnorderedStreamElementQueue.tryPut(StreamElement streamElement)
Optional<ResultFuture<OUT>>	OrderedStreamElementQueue.tryPut(StreamElement streamElement)
Optional<ResultFuture<OUT>>	StreamElementQueue.tryPut(StreamElement streamElement) Tries to put the given element in the queue.

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	InternalWatermark The Watermark that contains extra information to be used internally.
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.io

Classes in org.apache.flink.streaming.runtime.io with type parameters of type StreamElement

Modifier and Type	Class and Description
class	AbstractStreamTaskNetworkInput<T,R extends RecordDeserializer<DeserializationDelegate<StreamElement>>> Base class for network-based StreamTaskInput where each channel has a designated RecordDeserializer for spanning records.

Fields in org.apache.flink.streaming.runtime.io with type parameters of type StreamElement

Modifier and Type	Field and Description
protected DeserializationDelegate<StreamElement>	AbstractStreamTaskNetworkInput.deserializationDelegate

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	RecordAttributes A RecordAttributes describes the attributes of records from the current RecordAttributes until the next one is received.
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(DataInputView source)
StreamElement	StreamElementSerializer.deserialize(StreamElement reuse, DataInputView source)

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, DataInputView source)
void	StreamElementSerializer.serialize(StreamElement value, DataOutputView target)

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

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

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