Package com.here.platform.data.client.spark.javadsl

Interface DataConverter

All Superinterfaces:
Serializable
All Known Implementing Classes:
IndexDataConverter, VersionedDataConverter, VolatileDataConverter
public interface DataConverter extends Serializable
User may provide a DataConverter implementation to specify how data which has been grouped can be aggregated into a single data file (byte array).

  • Method Summary

    Modifier and Type
    Method
    Description
    <M extends com.here.platform.data.client.spark.scaladsl.RowMetadata>
    com.here.platform.data.client.spark.scaladsl.GroupedData<M>
    serializeGroup(M rowMetadata, Iterator<org.apache.spark.sql.Row> rows)
     

  • Method Details

    • serializeGroup

      <M extends com.here.platform.data.client.spark.scaladsl.RowMetadata> com.here.platform.data.client.spark.scaladsl.GroupedData<M> serializeGroup(M rowMetadata, Iterator<org.apache.spark.sql.Row> rows)