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

Class PartitionConverterImpl

java.lang.Object

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

All Implemented Interfaces:

PartitionConverter, PartitionDecoder, PartitionEncoder, Serializable

public class PartitionConverterImpl
extends Object
implements PartitionConverter

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
PartitionConverterImpl(org.apache.flink.api.java.typeutils.RowTypeInfo rowTypeInfo, BlobConverter blobConverter, String layerId, LayerType layerType)

Method Summary

Modifier and Type	Method	Description
BlobConverter	blobConverter()
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)
PendingPartition	encodeIndex(scala.collection.immutable.Seq<org.apache.flink.types.Row> rows)
PendingPartition	encodeStream(org.apache.flink.types.Row row)
PendingPartition	encodeVolatile(scala.collection.immutable.Seq<org.apache.flink.api.java.tuple.Tuple2<Boolean,org.apache.flink.types.Row>> rows)
org.apache.flink.api.java.typeutils.RowTypeInfo	rowTypeInfo()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PartitionConverterImpl

public PartitionConverterImpl(org.apache.flink.api.java.typeutils.RowTypeInfo rowTypeInfo,
 BlobConverter blobConverter,
 String layerId,
 LayerType layerType)

Method Details

blobConverter

public BlobConverter blobConverter()

Specified by:

blobConverter in interface PartitionConverter

decodeIndex

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

Specified by:

decodeIndex in interface PartitionDecoder

decodeStream

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

Specified by:

decodeStream in interface PartitionDecoder

decodeVersion

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

Specified by:

decodeVersion in interface PartitionDecoder

decodeVolatile

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

Specified by:

decodeVolatile in interface PartitionDecoder

encodeIndex

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

Specified by:

encodeIndex in interface PartitionEncoder

encodeStream

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

Specified by:

encodeStream in interface PartitionEncoder

encodeVolatile

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

Specified by:

encodeVolatile in interface PartitionEncoder

rowTypeInfo

public org.apache.flink.api.java.typeutils.RowTypeInfo rowTypeInfo()

Specified by:

rowTypeInfo in interface PartitionConverter