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

Interface PartitionEncoder

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

  • Method Details

    • encodeIndex

      PendingPartition encodeIndex(scala.collection.immutable.Seq<org.apache.flink.types.Row> rows)

    • encodeStream

      PendingPartition encodeStream(org.apache.flink.types.Row row)

    • encodeVolatile

      PendingPartition encodeVolatile(scala.collection.immutable.Seq<org.apache.flink.api.java.tuple.Tuple2<Boolean,org.apache.flink.types.Row>> rows)