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

Class PojoPartition

java.lang.Object

com.here.platform.data.client.flink.impl.PojoPartition

public class PojoPartition
extends Object

POJO Class have to https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/stream/state/schema_evolution.html#pojo-types

1. Fields can be removed. Once removed, the previous value for the removed field will be dropped in future checkpoints and savepoints. 2. New fields can be added. The new field will be initialized to the default value for its type, as defined by Java. 3. Declared fields types cannot change. 4. Class name of the POJO type cannot change, including the namespace of the class.

param: version param: partition param: layer param: dataHandle param: checksum param: crc param: dataSize param: compressedDataSize param: additionalMetadata param: timestamp

Constructor Summary

Constructors

Constructor	Description
PojoPartition()
PojoPartition(long version, String partition, String layer, String dataHandle, String checksum, String crc, long dataSize, long compressedDataSize, String additionalMetadata, long timestamp)

Method Summary

Modifier and Type	Method	Description
String	additionalMetadata()
String	checksum()
long	compressedDataSize()
String	crc()
String	dataHandle()
long	dataSize()
String	getAdditionalMetadata()
String	getChecksum()
long	getCompressedDataSize()
String	getCrc()
String	getDataHandle()
long	getDataSize()
String	getLayer()
String	getPartition()
long	getTimestamp()
long	getVersion()
String	layer()
String	partition()
void	setAdditionalMetadata(String x$1)
void	setChecksum(String x$1)
void	setCompressedDataSize(long x$1)
void	setCrc(String x$1)
void	setDataHandle(String x$1)
void	setDataSize(long x$1)
void	setLayer(String x$1)
void	setPartition(String x$1)
void	setTimestamp(long x$1)
void	setVersion(long x$1)
long	timestamp()
long	version()

Methods inherited from class java.lang.Object

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

Constructor Details

PojoPartition

public PojoPartition(long version,
 String partition,
 String layer,
 String dataHandle,
 String checksum,
 String crc,
 long dataSize,
 long compressedDataSize,
 String additionalMetadata,
 long timestamp)

PojoPartition

public PojoPartition()

Method Details

additionalMetadata

public String additionalMetadata()

checksum

public String checksum()

compressedDataSize

public long compressedDataSize()

crc

public String crc()

dataHandle

public String dataHandle()

dataSize

public long dataSize()

getAdditionalMetadata

public String getAdditionalMetadata()

getChecksum

public String getChecksum()

getCompressedDataSize

public long getCompressedDataSize()

getCrc

public String getCrc()

getDataHandle

public String getDataHandle()

getDataSize

public long getDataSize()

getLayer

public String getLayer()

getPartition

public String getPartition()

getTimestamp

public long getTimestamp()

getVersion

public long getVersion()

layer

public String layer()

partition

public String partition()

setAdditionalMetadata

public void setAdditionalMetadata(String x$1)

setChecksum

public void setChecksum(String x$1)

setCompressedDataSize

public void setCompressedDataSize(long x$1)

setCrc

public void setCrc(String x$1)

setDataHandle

public void setDataHandle(String x$1)

setDataSize

public void setDataSize(long x$1)

setLayer

public void setLayer(String x$1)

setPartition

public void setPartition(String x$1)

setTimestamp

public void setTimestamp(long x$1)

setVersion

public void setVersion(long x$1)

timestamp

public long timestamp()

version

public long version()