RuntimeChangelogMode (Flink : Table : Runtime 2.1.2-cp1 API)

java.lang.Object
- org.apache.flink.table.runtime.operators.process.RuntimeChangelogMode

All Implemented Interfaces:

Serializable
```
@Internal
public class RuntimeChangelogMode
extends Object
implements Serializable
```
Serializable version of ChangelogMode.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

RuntimeChangelogMode(byte[] changes, boolean keyOnlyDeletes)

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`org.apache.flink.table.connector.ChangelogMode`	`deserialize()`
`static RuntimeChangelogMode`	`serialize(org.apache.flink.table.connector.ChangelogMode mode)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RuntimeChangelogMode

public RuntimeChangelogMode(byte[] changes,
                            boolean keyOnlyDeletes)

Method Detail

serialize

public static RuntimeChangelogMode serialize(org.apache.flink.table.connector.ChangelogMode mode)

deserialize

public org.apache.flink.table.connector.ChangelogMode deserialize()