@PublicEvolving 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
A builder for creating a
CsvRowSerializationSchema . |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
hashCode() |
byte[] |
serialize(Row row)
Serializes the incoming element to a specified type.
|
public byte[] serialize(Row row)
SerializationSchema
serialize
in interface SerializationSchema<Row>
row
- The incoming element to be serializedCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.