Package org.apache.beam.sdk.schemas

Class SchemaTranslation

java.lang.Object

org.apache.beam.sdk.schemas.SchemaTranslation

public class SchemaTranslation
extends Object

Utility methods for translating schemas.

Constructor Summary

Constructors

Constructor	Description
SchemaTranslation()

Method Summary

Modifier and Type	Method	Description
static Object	rowFromProto(org.apache.beam.model.pipeline.v1.SchemaApi.Row row, Schema.FieldType fieldType)
static org.apache.beam.model.pipeline.v1.SchemaApi.Row	rowToProto(Row row)
static Schema	schemaFromProto(org.apache.beam.model.pipeline.v1.SchemaApi.Schema protoSchema)
static org.apache.beam.model.pipeline.v1.SchemaApi.Schema	schemaToProto(Schema schema, boolean serializeLogicalType)
static org.apache.beam.model.pipeline.v1.SchemaApi.Schema	schemaToProto(Schema schema, boolean serializeLogicalType, boolean serializeUUID)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SchemaTranslation

public SchemaTranslation()

Method Details

schemaToProto

public static org.apache.beam.model.pipeline.v1.SchemaApi.Schema schemaToProto(Schema schema,
 boolean serializeLogicalType)

schemaToProto

public static org.apache.beam.model.pipeline.v1.SchemaApi.Schema schemaToProto(Schema schema,
 boolean serializeLogicalType,
 boolean serializeUUID)

schemaFromProto

public static Schema schemaFromProto(org.apache.beam.model.pipeline.v1.SchemaApi.Schema protoSchema)

rowToProto

public static org.apache.beam.model.pipeline.v1.SchemaApi.Row rowToProto(Row row)

rowFromProto

public static Object rowFromProto(org.apache.beam.model.pipeline.v1.SchemaApi.Row row,
 Schema.FieldType fieldType)