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.
|
void |
open(SerializationSchema.InitializationContext context)
Deprecated.
Initialization method for the schema.
|
byte[] |
serialize(Row row)
Deprecated.
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<Row>
context
- Contextual information that can be used during initialization.Exception
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–2024 The Apache Software Foundation. All rights reserved.