@Internal public abstract class StreamElement extends Object
Constructor and Description |
---|
StreamElement() |
Modifier and Type | Method and Description |
---|---|
LatencyMarker |
asLatencyMarker()
Casts this element into a LatencyMarker.
|
<E> StreamRecord<E> |
asRecord()
Casts this element into a StreamRecord.
|
RecordAttributes |
asRecordAttributes()
Casts this element into a RecordAttributes.
|
Watermark |
asWatermark()
Casts this element into a Watermark.
|
WatermarkStatus |
asWatermarkStatus()
Casts this element into a WatermarkStatus.
|
boolean |
isLatencyMarker()
Checks whether this element is a latency marker.
|
boolean |
isRecord()
Checks whether this element is a record.
|
boolean |
isRecordAttributes()
Check whether this element is record attributes.
|
boolean |
isWatermark()
Checks whether this element is a watermark.
|
boolean |
isWatermarkStatus()
Checks whether this element is a watermark status.
|
public final boolean isWatermark()
public final boolean isWatermarkStatus()
public final boolean isRecord()
public final boolean isLatencyMarker()
public final boolean isRecordAttributes()
public final <E> StreamRecord<E> asRecord()
ClassCastException
- Thrown, if this element is actually not a stream record.public final Watermark asWatermark()
ClassCastException
- Thrown, if this element is actually not a Watermark.public final WatermarkStatus asWatermarkStatus()
ClassCastException
- Thrown, if this element is actually not a Watermark
Status.public final LatencyMarker asLatencyMarker()
ClassCastException
- Thrown, if this element is actually not a LatencyMarker.public final RecordAttributes asRecordAttributes()
ClassCastException
- Thrown, if this element is actually not a
RecordAttributes.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.