SchemaManager.Serializer (flink-cdc-parent 3.8-SNAPSHOT API)

java.lang.Object
- org.apache.flink.cdc.runtime.operators.schema.common.SchemaManager.Serializer

All Implemented Interfaces:

org.apache.flink.core.io.SimpleVersionedSerializer<SchemaManager>, org.apache.flink.core.io.Versioned

Enclosing class:

SchemaManager
```
public static class SchemaManager.Serializer
extends Object
implements org.apache.flink.core.io.SimpleVersionedSerializer<SchemaManager>
```
Serializer for SchemaManager.

Field Summary

Fields
Modifier and Type Field Description

static int CURRENT_VERSION
Update history: from Version 3.0.0, set to 0, from version 3.1.1, updated to 1, from version 3.2.0, updated to 2.

Constructor Summary

Constructors
Constructor Description

Serializer()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`SchemaManager`	`deserialize(int version, byte[] serialized)`
`int`	`getVersion()`
`byte[]`	`serialize(SchemaManager schemaManager)`

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

- Field Detail
  - CURRENT_VERSION
```
public static final int CURRENT_VERSION
```
    Update history: from Version 3.0.0, set to 0, from version 3.1.1, updated to 1, from version 3.2.0, updated to 2.
    
    See Also:
    
    Constant Field Values
- Constructor Detail
  - Serializer
```
public Serializer()
```
- Method Detail
  - getVersion
```
public int getVersion()
```
    Specified by:
    
    getVersion in interface org.apache.flink.core.io.SimpleVersionedSerializer<SchemaManager>
    
    Specified by:
    
    getVersion in interface org.apache.flink.core.io.Versioned
  - serialize
```
public byte[] serialize(SchemaManager schemaManager)
                 throws IOException
```
    Specified by:
    
    serialize in interface org.apache.flink.core.io.SimpleVersionedSerializer<SchemaManager>
    
    Throws:
    
    IOException
  - deserialize
```
public SchemaManager deserialize(int version,
                                 byte[] serialized)
                          throws IOException
```
    Specified by:
    
    deserialize in interface org.apache.flink.core.io.SimpleVersionedSerializer<SchemaManager>
    
    Throws:
    
    IOException