Serialized Form

Package org.apache.geode.cache.query.internal.cq

Class org.apache.geode.cache.query.internal.cq.CqConflatable extends java.lang.Object implements Serializable

serialVersionUID:

-7215022132135862557L

Serialized Fields

key

java.lang.Object key

The key for this entry

value

java.lang.Object value

The value for this entry

id

org.apache.geode.internal.cache.EventID id

The unique EventID object for this entry

conflate

boolean conflate

boolean to indicate whether this entry should be conflated or not

regionname

java.lang.String regionname

The region to which this entry belongs

Class org.apache.geode.cache.query.internal.cq.ServerCQImpl extends CqQueryImpl implements Serializable

Serialized Fields

cqResultKeys

java.util.HashMap<K,V> cqResultKeys

This holds the keys that are part of the CQ query results. Using this CQ engine can determine whether to execute query on old value from EntryEvent, which is an expensive operation. NOTE: In case of RR this map is populated and used as intended. In case of PR this map will not be populated. If executeCQ happens after update operations this map will remain empty.

destroysWhileCqResultsInProgress

java.util.HashSet<E> destroysWhileCqResultsInProgress

This maintains the keys that are destroyed while the Results Cache is getting constructed. This avoids any keys that are destroyed (after query execution) but is still part of the CQs result.

cqResultKeysInitialized

boolean cqResultKeysInitialized

To indicate if the CQ results key cache is initialized.

isPR

boolean isPR

Boolean flag to see if the CQ is on Partitioned Region

clientProxyId

org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID clientProxyId

ccn

org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier ccn

serverCqName

java.lang.String serverCqName

filterID

java.lang.Long filterID

identifier assigned to this query for FilterRoutingInfos