SerializationSchema
.@PublicEvolving @Deprecated public final class CsvRowSerializationSchema extends Object implements SerializationSchema<Row>
Serializes the input row into a ObjectNode
and converts it into byte[]
.
Result byte[]
messages can be deserialized using CsvRowDeserializationSchema
.
Modifier and Type | Class and Description |
---|---|
static class |
CsvRowSerializationSchema.Builder
Deprecated.
A builder for creating a
CsvRowSerializationSchema . |
SerializationSchema.InitializationContext
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o)
Deprecated.
|
int |
hashCode()
Deprecated.
|
byte[] |
serialize(Row row)
Deprecated.
Serializes the incoming element to a specified type.
|
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
open
public byte[] serialize(Row row)
SerializationSchema
serialize
in interface SerializationSchema<Row>
row
- The incoming element to be serializedCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.