Package | Description |
---|---|
org.apache.flink.streaming.api.operators.async.queue | |
org.apache.flink.streaming.api.watermark | |
org.apache.flink.streaming.runtime.streamrecord |
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 |
---|---|
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) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.