org.apache.beam.sdk.schemas

Class SchemaTranslation

java.lang.Object

org.apache.beam.sdk.schemas.SchemaTranslation

@Experimental(value=SCHEMAS)
public class SchemaTranslation
extends java.lang.Object

Utility methods for translating schemas.

Constructor Summary

Constructors

Constructor and Description
SchemaTranslation()

Method Summary

Modifier and Type	Method and Description
static java.lang.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)

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaTranslation

public SchemaTranslation()

Method Detail

schemaToProto

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

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 java.lang.Object rowFromProto(org.apache.beam.model.pipeline.v1.SchemaApi.Row row,
                                            Schema.FieldType fieldType)