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

Interface PartitionDecoder

All Known Subinterfaces:
PartitionConverter
All Known Implementing Classes:
PartitionConverterImpl, PartitionConverterImplV2
public interface PartitionDecoder

  • Method Summary

    Modifier and Type
    Method
    Description
    scala.collection.immutable.Seq<org.apache.flink.types.Row>
    decodeIndex(com.here.platform.data.client.scaladsl.IndexPartition partition, byte[] data)
     
    org.apache.flink.types.Row
    decodeStream(com.here.platform.data.client.scaladsl.Partition partition, byte[] data)
     
    scala.collection.immutable.Seq<org.apache.flink.types.Row>
    decodeVersion(com.here.platform.data.client.scaladsl.Partition partition, byte[] data)
     
    scala.collection.immutable.Seq<org.apache.flink.types.Row>
    decodeVolatile(com.here.platform.data.client.scaladsl.Partition partition, byte[] data)
     

  • Method Details

    • decodeIndex

      scala.collection.immutable.Seq<org.apache.flink.types.Row> decodeIndex(com.here.platform.data.client.scaladsl.IndexPartition partition, byte[] data)

    • decodeStream

      org.apache.flink.types.Row decodeStream(com.here.platform.data.client.scaladsl.Partition partition, byte[] data)

    • decodeVersion

      scala.collection.immutable.Seq<org.apache.flink.types.Row> decodeVersion(com.here.platform.data.client.scaladsl.Partition partition, byte[] data)

    • decodeVolatile

      scala.collection.immutable.Seq<org.apache.flink.types.Row> decodeVolatile(com.here.platform.data.client.scaladsl.Partition partition, byte[] data)