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

Class QueryNotification

java.lang.Object

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

All Implemented Interfaces:

Serializable, scala.Equals, scala.Product

public class QueryNotification
extends Object
implements scala.Product, Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
QueryNotification(scala.Option<ParsedQuery> parsedQueryOpt, scala.collection.immutable.List<scala.Tuple2<scala.Option<String>,Object>> initial, scala.Option<PartitionVersionState> versionState, scala.Option<BatchPublicationNotification> notificationOpt, scala.collection.immutable.Seq<String> idsForSubscription, scala.Option<Object> latestCompletedVersion)

Method Summary

Modifier and Type	Method	Description
abstract static R	apply(T1 v1, T2 v2, T3 v3, T4 v4, T5 v5, T6 v6)
scala.collection.immutable.Seq<String>	idsForSubscription()
scala.collection.immutable.List<scala.Tuple2<scala.Option<String>,Object>>	initial()
scala.Option<Object>	latestCompletedVersion()
scala.Option<BatchPublicationNotification>	notificationOpt()
scala.Option<ParsedQuery>	parsedQueryOpt()
static String	toString()
scala.Option<PartitionVersionState>	versionState()

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface scala.Product

productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Constructor Details

QueryNotification

public QueryNotification(scala.Option<ParsedQuery> parsedQueryOpt,
 scala.collection.immutable.List<scala.Tuple2<scala.Option<String>,Object>> initial,
 scala.Option<PartitionVersionState> versionState,
 scala.Option<BatchPublicationNotification> notificationOpt,
 scala.collection.immutable.Seq<String> idsForSubscription,
 scala.Option<Object> latestCompletedVersion)

Method Details

apply

public abstract static R apply(T1 v1,
 T2 v2,
 T3 v3,
 T4 v4,
 T5 v5,
 T6 v6)

toString

public static String toString()

parsedQueryOpt

public scala.Option<ParsedQuery> parsedQueryOpt()

initial

public scala.collection.immutable.List<scala.Tuple2<scala.Option<String>,Object>> initial()

versionState

public scala.Option<PartitionVersionState> versionState()

notificationOpt

public scala.Option<BatchPublicationNotification> notificationOpt()

idsForSubscription

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

latestCompletedVersion

public scala.Option<Object> latestCompletedVersion()