Package com.here.platform.data.client.spark.datasources.protobuf.converter

Class MessageOps

java.lang.Object
com.here.platform.data.client.spark.datasources.protobuf.converter.MessageOps
public class MessageOps extends Object
This class adds some convenient operations to Protobuf's message

  • Constructor Summary

    Constructors
    Constructor
    Description
    MessageOps()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static String
    incompatibleMsg()
     
    static <T> void
    setField(org.apache.spark.sql.Row row, com.google.protobuf.Descriptors.FieldDescriptor fd, com.google.protobuf.DynamicMessage.Builder messageBuilder)
     
    static com.google.protobuf.Message
    toMessage(org.apache.spark.sql.Row row, com.google.protobuf.Descriptors.Descriptor messageDescriptor)
     
    static org.apache.spark.sql.Row
    toRow(com.google.protobuf.Message message, com.google.protobuf.Descriptors.Descriptor messageDescriptor)
    Converts the values of a PB message into its Row representation.
    static org.apache.spark.sql.Row
    toRow(com.google.protobuf.Message message, com.google.protobuf.Descriptors.Descriptor messageDescriptor, org.apache.spark.sql.types.StructType schema)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • MessageOps

      public MessageOps()

  • Method Details

    • incompatibleMsg

      public static String incompatibleMsg()

    • toRow

      public static org.apache.spark.sql.Row toRow(com.google.protobuf.Message message, com.google.protobuf.Descriptors.Descriptor messageDescriptor)
      Converts the values of a PB message into its Row representation.

    • toRow

      public static org.apache.spark.sql.Row toRow(com.google.protobuf.Message message, com.google.protobuf.Descriptors.Descriptor messageDescriptor, org.apache.spark.sql.types.StructType schema)

    • toMessage

      public static com.google.protobuf.Message toMessage(org.apache.spark.sql.Row row, com.google.protobuf.Descriptors.Descriptor messageDescriptor)

    • setField

      public static <T> void setField(org.apache.spark.sql.Row row, com.google.protobuf.Descriptors.FieldDescriptor fd, com.google.protobuf.DynamicMessage.Builder messageBuilder)