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

Class PojoQuery

java.lang.Object

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

public class PojoQuery
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: typeQuery param: batchIdsLeft_1 param: batchIdsLeft_2 param: batchIdsInProcess_1 param: batchIdsInProcess_2 param: batchIdsUsed_1 param: batchIdsUsed_2 param: next param: sinceTime param: additionalFields

Constructor Summary

Constructors

Constructor	Description
PojoQuery()
PojoQuery(String typeQuery, scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>> batchIdsLeft_1, scala.collection.immutable.Seq<Object> batchIdsLeft_2, scala.collection.immutable.Seq<String> batchIdsInProcess_1, long batchIdsInProcess_2, scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>> batchIdsUsed_1, scala.collection.immutable.Seq<Object> batchIdsUsed_2, String next, long sinceTime, scala.collection.immutable.Set<AdditionalField> additionalFields)

Method Summary

Modifier and Type	Method	Description
scala.collection.immutable.Set<AdditionalField>	additionalFields()
scala.collection.immutable.Seq<String>	batchIdsInProcess_1()
long	batchIdsInProcess_2()
scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>>	batchIdsLeft_1()
scala.collection.immutable.Seq<Object>	batchIdsLeft_2()
scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>>	batchIdsUsed_1()
scala.collection.immutable.Seq<Object>	batchIdsUsed_2()
scala.collection.immutable.Set<AdditionalField>	getAdditionalFields()
scala.collection.immutable.Seq<String>	getBatchIdsInProcess_1()
long	getBatchIdsInProcess_2()
scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>>	getBatchIdsLeft_1()
scala.collection.immutable.Seq<Object>	getBatchIdsLeft_2()
scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>>	getBatchIdsUsed_1()
scala.collection.immutable.Seq<Object>	getBatchIdsUsed_2()
String	getNext()
long	getSinceTime()
String	getTypeQuery()
String	next()
void	setAdditionalFields(scala.collection.immutable.Set<AdditionalField> x$1)
void	setBatchIdsInProcess_1(scala.collection.immutable.Seq<String> x$1)
void	setBatchIdsInProcess_2(long x$1)
void	setBatchIdsLeft_1(scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>> x$1)
void	setBatchIdsLeft_2(scala.collection.immutable.Seq<Object> x$1)
void	setBatchIdsUsed_1(scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>> x$1)
void	setBatchIdsUsed_2(scala.collection.immutable.Seq<Object> x$1)
void	setNext(String x$1)
void	setSinceTime(long x$1)
void	setTypeQuery(String x$1)
long	sinceTime()
String	typeQuery()

Methods inherited from class java.lang.Object

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

Constructor Details

PojoQuery

public PojoQuery(String typeQuery,
 scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>> batchIdsLeft_1,
 scala.collection.immutable.Seq<Object> batchIdsLeft_2,
 scala.collection.immutable.Seq<String> batchIdsInProcess_1,
 long batchIdsInProcess_2,
 scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>> batchIdsUsed_1,
 scala.collection.immutable.Seq<Object> batchIdsUsed_2,
 String next,
 long sinceTime,
 scala.collection.immutable.Set<AdditionalField> additionalFields)

PojoQuery

public PojoQuery()

Method Details

additionalFields

public scala.collection.immutable.Set<AdditionalField> additionalFields()

batchIdsInProcess_1

public scala.collection.immutable.Seq<String> batchIdsInProcess_1()

batchIdsInProcess_2

public long batchIdsInProcess_2()

batchIdsLeft_1

public scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>> batchIdsLeft_1()

batchIdsLeft_2

public scala.collection.immutable.Seq<Object> batchIdsLeft_2()

batchIdsUsed_1

public scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>> batchIdsUsed_1()

batchIdsUsed_2

public scala.collection.immutable.Seq<Object> batchIdsUsed_2()

getAdditionalFields

public scala.collection.immutable.Set<AdditionalField> getAdditionalFields()

getBatchIdsInProcess_1

public scala.collection.immutable.Seq<String> getBatchIdsInProcess_1()

getBatchIdsInProcess_2

public long getBatchIdsInProcess_2()

getBatchIdsLeft_1

public scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>> getBatchIdsLeft_1()

getBatchIdsLeft_2

public scala.collection.immutable.Seq<Object> getBatchIdsLeft_2()

getBatchIdsUsed_1

public scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>> getBatchIdsUsed_1()

getBatchIdsUsed_2

public scala.collection.immutable.Seq<Object> getBatchIdsUsed_2()

getNext

public String getNext()

getSinceTime

public long getSinceTime()

getTypeQuery

public String getTypeQuery()

next

public String next()

setAdditionalFields

public void setAdditionalFields(scala.collection.immutable.Set<AdditionalField> x$1)

setBatchIdsInProcess_1

public void setBatchIdsInProcess_1(scala.collection.immutable.Seq<String> x$1)

setBatchIdsInProcess_2

public void setBatchIdsInProcess_2(long x$1)

setBatchIdsLeft_1

public void setBatchIdsLeft_1(scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>> x$1)

setBatchIdsLeft_2

public void setBatchIdsLeft_2(scala.collection.immutable.Seq<Object> x$1)

setBatchIdsUsed_1

public void setBatchIdsUsed_1(scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>> x$1)

setBatchIdsUsed_2

public void setBatchIdsUsed_2(scala.collection.immutable.Seq<Object> x$1)

setNext

public void setNext(String x$1)

setSinceTime

public void setSinceTime(long x$1)

setTypeQuery

public void setTypeQuery(String x$1)

sinceTime

public long sinceTime()

typeQuery

public String typeQuery()