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

Class PojoPartVersionState

java.lang.Object

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

public class PojoPartVersionState
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: partId param: startVersion param: endVersion

Constructor Summary

Constructors

Constructor	Description
PojoPartVersionState()
PojoPartVersionState(String partId, long startVersion, long endVersion)

Method Summary

Modifier and Type	Method	Description
long	endVersion()
long	getEndVersion()
String	getPartId()
long	getStartVersion()
String	partId()
void	setEndVersion(long x$1)
void	setPartId(String x$1)
void	setStartVersion(long x$1)
long	startVersion()

Methods inherited from class java.lang.Object

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

Constructor Details

PojoPartVersionState

public PojoPartVersionState(String partId,
 long startVersion,
 long endVersion)

PojoPartVersionState

public PojoPartVersionState()

Method Details

endVersion

public long endVersion()

getEndVersion

public long getEndVersion()

getPartId

public String getPartId()

getStartVersion

public long getStartVersion()

partId

public String partId()

setEndVersion

public void setEndVersion(long x$1)

setPartId

public void setPartId(String x$1)

setStartVersion

public void setStartVersion(long x$1)

startVersion

public long startVersion()