Package org.apache.flink.formats.json
Class JsonRowSerializationSchema
- java.lang.Object
-
- org.apache.flink.formats.json.JsonRowSerializationSchema
-
- All Implemented Interfaces:
Serializable,org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.Row>
@PublicEvolving @Deprecated public class JsonRowSerializationSchema extends Object implements org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.Row>
Deprecated.The format was developed for the Table API users and will not be maintained for DataStream API users anymore. Either use Table API or switch to Data Stream, defining your ownSerializationSchema.Serialization schema that serializes an object of Flink types into a JSON bytes.Serializes the input Flink object into a JSON string and converts it into
byte[].Result
byte[]messages can be deserialized usingJsonRowDeserializationSchema.- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classJsonRowSerializationSchema.BuilderDeprecated.Builder forJsonRowSerializationSchema.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static JsonRowSerializationSchema.Builderbuilder()Deprecated.Creates a builder forJsonRowSerializationSchema.Builder.booleanequals(Object o)Deprecated.inthashCode()Deprecated.voidopen(org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext context)Deprecated.byte[]serialize(org.apache.flink.types.Row row)Deprecated.
-
-
-
Method Detail
-
open
public void open(org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext context) throws ExceptionDeprecated.- Specified by:
openin interfaceorg.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.Row>- Throws:
Exception
-
builder
public static JsonRowSerializationSchema.Builder builder()
Deprecated.Creates a builder forJsonRowSerializationSchema.Builder.
-
serialize
public byte[] serialize(org.apache.flink.types.Row row)
Deprecated.- Specified by:
serializein interfaceorg.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.Row>
-
-