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

Interface BlobEncoder

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

  • Method Summary

    Modifier and Type
    Method
    Description
    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)
     

  • Method Details

    • encodeRow

      com.here.platform.data.client.scaladsl.NewPartition.BufferedBlob encodeRow(org.apache.flink.types.Row dataRow)

    • encodeRowCollection

      com.here.platform.data.client.scaladsl.NewPartition.BufferedBlob encodeRowCollection(scala.collection.Iterator<org.apache.flink.types.Row> dataRows)