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

Class ParquetBlobConverter

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

  • Constructor Summary

    Constructors
    Constructor
    Description
    ParquetBlobConverter(String schemaString)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.flink.api.java.typeutils.RowTypeInfo
    blobRowTypeInfo()
     
    org.apache.avro.generic.GenericDatumReader<org.apache.avro.generic.GenericRecord>
    datumReader()
     
    org.apache.avro.generic.GenericDatumWriter<org.apache.avro.generic.GenericRecord>
    datumWriter()
     
    org.apache.flink.types.Row
    decodeRow(byte[] data)
     
    scala.collection.immutable.Seq<org.apache.flink.types.Row>
    decodeRowCollection(byte[] data)
     
    com.here.platform.data.client.scaladsl.NewPartition.BufferedBlob
    encodeRow(org.apache.flink.types.Row dataRow)
     
    com.here.platform.data.client.scaladsl.NewPartition.BufferedBlob
    encodeRowCollection(scala.collection.Iterator<org.apache.flink.types.Row> dataRows)
     
    boolean
    expansionType()
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ParquetBlobConverter

      public ParquetBlobConverter(String schemaString)

  • Method Details

    • blobRowTypeInfo

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

    • datumReader

      public org.apache.avro.generic.GenericDatumReader<org.apache.avro.generic.GenericRecord> datumReader()

    • datumWriter

      public org.apache.avro.generic.GenericDatumWriter<org.apache.avro.generic.GenericRecord> datumWriter()

    • decodeRow

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

    • decodeRowCollection

      public scala.collection.immutable.Seq<org.apache.flink.types.Row> decodeRowCollection(byte[] data)
      Specified by:
      decodeRowCollection 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

    • encodeRowCollection

      public com.here.platform.data.client.scaladsl.NewPartition.BufferedBlob encodeRowCollection(scala.collection.Iterator<org.apache.flink.types.Row> dataRows)
      Specified by:
      encodeRowCollection in interface BlobEncoder

    • expansionType

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