Package org.apache.beam.sdk.schemas

Class SchemaTranslation

  • @Experimental(SCHEMAS)
public class SchemaTranslation
extends java.lang.Object
    Utility methods for translating schemas.

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method 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)