FlussEventSerializer (flink-cdc-parent 3.8-SNAPSHOT API)

Type Parameters:

InputT - The type of the input record which comes from the upstream and will be transformed into a FlussEvent here.

All Superinterfaces:

Serializable

All Known Implementing Classes:

FlussEventSerializationSchema
```
public interface FlussEventSerializer<InputT>
extends Serializable
```
Serializer to serialize the input record to a FlussEvent for FlussSinkWriter.

- Method Summary
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method Description
  
  void open(org.apache.fluss.client.Connection connection)
  
  FlussEvent serialize(InputT in)

Method Detail

open

void open(org.apache.fluss.client.Connection connection)
   throws IOException

Throws:: IOException

serialize

FlussEvent serialize(InputT in)
              throws IOException

Throws:: IOException