Package com.here.platform.data.client.flink.impl.decoders

Class ProtobufBlobConverter

java.lang.Object
com.here.platform.data.client.flink.impl.decoders.ProtobufBlobConverter
All Implemented Interfaces:
BlobConverter, BlobDecoder, BlobEncoder, Serializable
public class ProtobufBlobConverter extends Object implements BlobConverter
See Also:

  • Constructor Summary

    Constructors
    Constructor
    Description
    ProtobufBlobConverter(PartitionDescriptorHolder descriptorHolder, boolean metadataFields)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.flink.api.java.typeutils.RowTypeInfo
    blobRowTypeInfo()
     
    org.apache.flink.types.Row
    decodeRow(byte[] data)
     
    static org.apache.flink.api.java.typeutils.RowTypeInfo
    deriveFlinkDescriptor(com.google.protobuf.Descriptors.Descriptor message, int referentialDepth)
    derives a name and a type for a flink column from protobuf field description
    org.apache.flink.api.java.typeutils.RowTypeInfo
    emptyProtobufRowType()
     
    com.here.platform.data.client.scaladsl.NewPartition.BufferedBlob
    encodeRow(org.apache.flink.types.Row dataRow)
     
    boolean
    expansionType()
     
    static int
    maxReferentialDepth()
     
    com.google.protobuf.Message
    rowToProtobufMessage(org.apache.flink.types.Row row, org.apache.flink.api.java.typeutils.RowTypeInfo rowTypeInfo, com.google.protobuf.Descriptors.Descriptor messageDescriptor)
     
    <T> void
    setField(org.apache.flink.types.Row row, org.apache.flink.api.java.typeutils.RowTypeInfo rowTypeInfo, com.google.protobuf.Descriptors.FieldDescriptor fd, com.google.protobuf.DynamicMessage.Builder messageBuilder)
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface com.here.platform.data.client.flink.impl.decoders.BlobDecoder

    decodeRowCollection

    Methods inherited from interface com.here.platform.data.client.flink.impl.decoders.BlobEncoder

    encodeRowCollection

  • Constructor Details

  • Method Details

    • maxReferentialDepth

      public static int maxReferentialDepth()

    • deriveFlinkDescriptor

      public static org.apache.flink.api.java.typeutils.RowTypeInfo deriveFlinkDescriptor(com.google.protobuf.Descriptors.Descriptor message, int referentialDepth)
      derives a name and a type for a flink column from protobuf field description

    • expansionType

      public boolean expansionType()
      Specified by:
      expansionType in interface BlobConverter

    • blobRowTypeInfo

      public org.apache.flink.api.java.typeutils.RowTypeInfo blobRowTypeInfo()
      Specified by:
      blobRowTypeInfo in interface BlobConverter

    • emptyProtobufRowType

      public org.apache.flink.api.java.typeutils.RowTypeInfo emptyProtobufRowType()

    • decodeRow

      public org.apache.flink.types.Row decodeRow(byte[] data)
      Specified by:
      decodeRow in interface BlobDecoder

    • encodeRow

      public com.here.platform.data.client.scaladsl.NewPartition.BufferedBlob encodeRow(org.apache.flink.types.Row dataRow)
      Specified by:
      encodeRow in interface BlobEncoder

    • rowToProtobufMessage

      public com.google.protobuf.Message rowToProtobufMessage(org.apache.flink.types.Row row, org.apache.flink.api.java.typeutils.RowTypeInfo rowTypeInfo, com.google.protobuf.Descriptors.Descriptor messageDescriptor)

    • setField

      public <T> void setField(org.apache.flink.types.Row row, org.apache.flink.api.java.typeutils.RowTypeInfo rowTypeInfo, com.google.protobuf.Descriptors.FieldDescriptor fd, com.google.protobuf.DynamicMessage.Builder messageBuilder)