Class PartitionConverterImplV2
java.lang.Object
com.here.platform.data.client.flink.impl.decoders.PartitionConverterImplV2
- All Implemented Interfaces:
PartitionConverter,PartitionDecoder,PartitionEncoder,Serializable
- See Also:
-
Constructor Summary
ConstructorsConstructorDescriptionPartitionConverterImplV2(org.apache.flink.api.java.typeutils.RowTypeInfo rowTypeInfo, BlobConverter blobConverter, String layerId, LayerType layerType) -
Method Summary
Modifier and TypeMethodDescriptionscala.collection.immutable.Seq<org.apache.flink.types.Row>decodeIndex(com.here.platform.data.client.scaladsl.IndexPartition partition, byte[] data) org.apache.flink.types.RowdecodeStream(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) encodeIndex(scala.collection.immutable.Seq<org.apache.flink.types.Row> rows) encodeStream(org.apache.flink.types.Row row) 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
-
Constructor Details
-
PartitionConverterImplV2
public PartitionConverterImplV2(org.apache.flink.api.java.typeutils.RowTypeInfo rowTypeInfo, BlobConverter blobConverter, String layerId, LayerType layerType)
-
-
Method Details
-
blobConverter
- Specified by:
blobConverterin interfacePartitionConverter
-
decodeIndex
public scala.collection.immutable.Seq<org.apache.flink.types.Row> decodeIndex(com.here.platform.data.client.scaladsl.IndexPartition partition, byte[] data) - Specified by:
decodeIndexin interfacePartitionDecoder
-
decodeStream
public org.apache.flink.types.Row decodeStream(com.here.platform.data.client.scaladsl.Partition partition, byte[] data) - Specified by:
decodeStreamin interfacePartitionDecoder
-
decodeVersion
public scala.collection.immutable.Seq<org.apache.flink.types.Row> decodeVersion(com.here.platform.data.client.scaladsl.Partition partition, byte[] data) - Specified by:
decodeVersionin interfacePartitionDecoder
-
decodeVolatile
public scala.collection.immutable.Seq<org.apache.flink.types.Row> decodeVolatile(com.here.platform.data.client.scaladsl.Partition partition, byte[] data) - Specified by:
decodeVolatilein interfacePartitionDecoder
-
encodeIndex
public PendingPartition encodeIndex(scala.collection.immutable.Seq<org.apache.flink.types.Row> rows) - Specified by:
encodeIndexin interfacePartitionEncoder
-
encodeStream
- Specified by:
encodeStreamin interfacePartitionEncoder
-
encodeVolatile
public PendingPartition encodeVolatile(scala.collection.immutable.Seq<org.apache.flink.api.java.tuple.Tuple2<Boolean, org.apache.flink.types.Row>> rows) - Specified by:
encodeVolatilein interfacePartitionEncoder
-
rowTypeInfo
public org.apache.flink.api.java.typeutils.RowTypeInfo rowTypeInfo()- Specified by:
rowTypeInfoin interfacePartitionConverter
-