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 Schema	fromProto(org.apache.beam.model.pipeline.v1.SchemaApi.Schema protoSchema)
static org.apache.beam.model.pipeline.v1.SchemaApi.Row	rowToProto(Row row)
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)

fromProto

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

rowToProto

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