@PublicEvolving public final class CsvRowDataSerializationSchema extends Object implements SerializationSchema<RowData>
Serializes the input row into a JsonNode
and converts it into byte[]
.
Result byte[]
messages can be deserialized using CsvRowDataDeserializationSchema
.
Modifier and Type | Class and Description |
---|---|
static class |
CsvRowDataSerializationSchema.Builder
A builder for creating a
CsvRowDataSerializationSchema . |
SerializationSchema.InitializationContext
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
hashCode() |
void |
open(SerializationSchema.InitializationContext context)
Initialization method for the schema.
|
byte[] |
serialize(RowData row)
Serializes the incoming element to a specified type.
|
public void open(SerializationSchema.InitializationContext context) throws Exception
SerializationSchema
SerializationSchema.serialize(Object)
and thus suitable for one time setup work.
The provided SerializationSchema.InitializationContext
can be used to access additional features such
as e.g. registering user metrics.
open
in interface SerializationSchema<RowData>
context
- Contextual information that can be used during initialization.Exception
public byte[] serialize(RowData row)
SerializationSchema
serialize
in interface SerializationSchema<RowData>
row
- The incoming element to be serializedCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.