Modifier and Type | Method and Description |
---|---|
StreamElement |
StreamElementQueueEntry.getStreamElement() |
Constructor and Description |
---|
StreamElementQueueEntry(StreamElement streamElement) |
Modifier and Type | Class and Description |
---|---|
class |
Watermark
A Watermark tells operators that receive it that no elements with a timestamp older or equal
to the watermark timestamp should arrive at the operator.
|
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.
|
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) |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<StreamElement> |
StreamElementSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
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) |
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.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.