Package | Description |
---|---|
org.apache.flink.streaming.api.watermark | |
org.apache.flink.streaming.runtime.streamrecord |
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 |
StreamRecord<T>
One value in a data stream.
|
Modifier and Type | Method and Description |
---|---|
StreamElement |
MultiplexingStreamRecordSerializer.copy(StreamElement from) |
StreamElement |
MultiplexingStreamRecordSerializer.copy(StreamElement from,
StreamElement reuse) |
StreamElement |
MultiplexingStreamRecordSerializer.deserialize(DataInputView source) |
StreamElement |
MultiplexingStreamRecordSerializer.deserialize(StreamElement reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
StreamElement |
MultiplexingStreamRecordSerializer.copy(StreamElement from) |
StreamElement |
MultiplexingStreamRecordSerializer.copy(StreamElement from,
StreamElement reuse) |
StreamElement |
MultiplexingStreamRecordSerializer.deserialize(StreamElement reuse,
DataInputView source) |
void |
MultiplexingStreamRecordSerializer.serialize(StreamElement value,
DataOutputView target) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.