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

Class RawBlobConverter

java.lang.Object

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

All Implemented Interfaces:

BlobConverter, BlobDecoder, BlobEncoder, Serializable

public class RawBlobConverter
extends Object
implements BlobConverter

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
RawBlobConverter(boolean metadataFields)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.java.typeutils.RowTypeInfo	blobRowTypeInfo()
org.apache.flink.types.Row	decodeRow(byte[] data)
com.here.platform.data.client.scaladsl.NewPartition.BufferedBlob	encodeRow(org.apache.flink.types.Row dataRow)
boolean	expansionType()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.here.platform.data.client.flink.impl.decoders.BlobDecoder

decodeRowCollection

Methods inherited from interface com.here.platform.data.client.flink.impl.decoders.BlobEncoder

encodeRowCollection

Constructor Details

RawBlobConverter

public RawBlobConverter(boolean metadataFields)

Method Details

blobRowTypeInfo

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

Specified by:

blobRowTypeInfo in interface BlobConverter

decodeRow

public org.apache.flink.types.Row decodeRow(byte[] data)

Specified by:

decodeRow in interface BlobDecoder

encodeRow

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

Specified by:

encodeRow in interface BlobEncoder

expansionType

public boolean expansionType()

Specified by:

expansionType in interface BlobConverter