Package org.apache.beam.sdk.util
Class RowJson.RowJsonSerializer
- java.lang.Object
-
- com.fasterxml.jackson.databind.JsonSerializer<T>
-
- com.fasterxml.jackson.databind.ser.std.StdSerializer<Row>
-
- org.apache.beam.sdk.util.RowJson.RowJsonSerializer
-
- All Implemented Interfaces:
com.fasterxml.jackson.databind.jsonFormatVisitors.JsonFormatVisitable
,com.fasterxml.jackson.databind.jsonschema.SchemaAware
,java.io.Serializable
- Enclosing class:
- RowJson
public static class RowJson.RowJsonSerializer extends com.fasterxml.jackson.databind.ser.std.StdSerializer<Row>
Jackson serializer for convertingRows
to JSON.- See Also:
- Serialized Form
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static RowJson.RowJsonSerializer
forSchema(Schema schema)
void
serialize(Row value, com.fasterxml.jackson.core.JsonGenerator gen, com.fasterxml.jackson.databind.SerializerProvider provider)
RowJson.RowJsonSerializer
withDropNullsOnWrite(java.lang.Boolean dropNullsOnWrite)
Serializer drops nulls on write if set to true instead of writing fieldName: null.-
Methods inherited from class com.fasterxml.jackson.databind.ser.std.StdSerializer
_neitherNull, _nonEmpty, acceptJsonFormatVisitor, createSchemaNode, createSchemaNode, findAnnotatedContentSerializer, findContextualConvertingSerializer, findConvertingContentSerializer, findFormatFeature, findFormatOverrides, findIncludeOverrides, findPropertyFilter, getSchema, getSchema, handledType, isDefaultSerializer, visitArrayFormat, visitArrayFormat, visitFloatFormat, visitIntFormat, visitIntFormat, visitStringFormat, visitStringFormat, wrapAndThrow, wrapAndThrow
-
-
-
-
Method Detail
-
forSchema
public static RowJson.RowJsonSerializer forSchema(Schema schema)
-
withDropNullsOnWrite
public RowJson.RowJsonSerializer withDropNullsOnWrite(java.lang.Boolean dropNullsOnWrite)
Serializer drops nulls on write if set to true instead of writing fieldName: null.
-
-