SerializationSchema
.@PublicEvolving @Deprecated public class JsonRowSerializationSchema extends Object implements SerializationSchema<Row>
Serializes the input Flink object into a JSON string and converts it into byte[]
.
Result byte[]
messages can be deserialized using JsonRowDeserializationSchema
.
Modifier and Type | Class and Description |
---|---|
static class |
JsonRowSerializationSchema.Builder
Deprecated.
Builder for
JsonRowSerializationSchema . |
SerializationSchema.InitializationContext
Modifier and Type | Method and Description |
---|---|
static JsonRowSerializationSchema.Builder |
builder()
Deprecated.
Creates a builder for
JsonRowSerializationSchema.Builder . |
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 static JsonRowSerializationSchema.Builder builder()
JsonRowSerializationSchema.Builder
.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.