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

Interface BlobDecoder

All Superinterfaces:
Serializable
All Known Subinterfaces:
BlobConverter
All Known Implementing Classes:
AvroBlobConverter, ParquetBlobConverter, ProtobufBlobConverter, RawBlobConverter
public interface BlobDecoder extends Serializable

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.flink.types.Row
    decodeRow(byte[] data)
     
    scala.collection.immutable.Seq<org.apache.flink.types.Row>
    decodeRowCollection(byte[] data)
     

  • Method Details

    • decodeRow

      org.apache.flink.types.Row decodeRow(byte[] data)

    • decodeRowCollection

      scala.collection.immutable.Seq<org.apache.flink.types.Row> decodeRowCollection(byte[] data)