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

Class PojoPartitionVersionState

java.lang.Object

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

public class PojoPartitionVersionState
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: partition param: version

Constructor Summary

Constructors

Constructor	Description
PojoPartitionVersionState()
PojoPartitionVersionState(String partition, long version)

Method Summary

Modifier and Type	Method	Description
String	getPartition()
long	getVersion()
String	partition()
void	setPartition(String x$1)
void	setVersion(long x$1)
long	version()

Methods inherited from class java.lang.Object

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

Constructor Details

PojoPartitionVersionState

public PojoPartitionVersionState(String partition,
 long version)

PojoPartitionVersionState

public PojoPartitionVersionState()

Method Details

getPartition

public String getPartition()

getVersion

public long getVersion()

partition

public String partition()

setPartition

public void setPartition(String x$1)

setVersion

public void setVersion(long x$1)

version

public long version()