org.apache.flink.streaming.runtime.streamrecord

Class StreamElement

java.lang.Object

org.apache.flink.streaming.runtime.streamrecord.StreamElement

Direct Known Subclasses:

LatencyMarker, StreamRecord, StreamStatus, Watermark

@Internal
public abstract class StreamElement
extends Object

An element in a data stream. Can be a record or a Watermark.

Constructor Summary

Constructors

Constructor and Description
StreamElement()

Method Summary

Modifier and Type	Method and Description
LatencyMarker	asLatencyMarker() Casts this element into a LatencyMarker.
<E> StreamRecord<E>	asRecord() Casts this element into a StreamRecord.
StreamStatus	asStreamStatus() Casts this element into a StreamStatus.
Watermark	asWatermark() Casts this element into a Watermark.
boolean	isLatencyMarker() Checks whether this element is a record.
boolean	isRecord() Checks whether this element is a record.
boolean	isStreamStatus() Checks whether this element is a stream status.
boolean	isWatermark() Checks whether this element is a watermark.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamElement

public StreamElement()

Method Detail

isWatermark

public final boolean isWatermark()

Checks whether this element is a watermark.

Returns:

True, if this element is a watermark, false otherwise.

isStreamStatus

public final boolean isStreamStatus()

Checks whether this element is a stream status.

Returns:

True, if this element is a stream status, false otherwise.

isRecord

public final boolean isRecord()

Checks whether this element is a record.

Returns:

True, if this element is a record, false otherwise.

isLatencyMarker

public final boolean isLatencyMarker()

Checks whether this element is a record.

Returns:

True, if this element is a record, false otherwise.

asRecord

public final <E> StreamRecord<E> asRecord()

Casts this element into a StreamRecord.

Returns:

This element as a stream record.

Throws:

ClassCastException - Thrown, if this element is actually not a stream record.

asWatermark

public final Watermark asWatermark()

Casts this element into a Watermark.

Returns:

This element as a Watermark.

Throws:

ClassCastException - Thrown, if this element is actually not a Watermark.

asStreamStatus

public final StreamStatus asStreamStatus()

Casts this element into a StreamStatus.

Returns:

This element as a StreamStatus.

Throws:

ClassCastException - Thrown, if this element is actually not a Stream Status.

asLatencyMarker

public final LatencyMarker asLatencyMarker()

Casts this element into a LatencyMarker.

Returns:

This element as a LatencyMarker.

Throws:

ClassCastException - Thrown, if this element is actually not a LatencyMarker.