public class MaxwellJsonSerializationSchema extends Object implements SerializationSchema<RowData>
RowData
to
maxwell-Json.SerializationSchema.InitializationContext
Constructor and Description |
---|
MaxwellJsonSerializationSchema(RowType rowType,
TimestampFormat timestampFormat,
JsonOptions.MapNullKeyMode mapNullKeyMode,
String mapNullKeyLiteral,
boolean encodeDecimalAsPlainNumber) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
hashCode() |
void |
open(SerializationSchema.InitializationContext context)
Initialization method for the schema.
|
byte[] |
serialize(RowData element)
Serializes the incoming element to a specified type.
|
public MaxwellJsonSerializationSchema(RowType rowType, TimestampFormat timestampFormat, JsonOptions.MapNullKeyMode mapNullKeyMode, String mapNullKeyLiteral, boolean encodeDecimalAsPlainNumber)
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<RowData>
context
- Contextual information that can be used during initialization.Exception
public byte[] serialize(RowData element)
SerializationSchema
serialize
in interface SerializationSchema<RowData>
element
- The incoming element to be serializedCopyright © 2014–2022 The Apache Software Foundation. All rights reserved.