Class CacheContinuousQueryHandlerV2<K,V>
- java.lang.Object
-
- org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler<K,V>
-
- org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandlerV2<K,V>
-
- All Implemented Interfaces:
Externalizable,Serializable,Cloneable,GridContinuousHandler
- Direct Known Subclasses:
CacheContinuousQueryHandlerV3
public class CacheContinuousQueryHandlerV2<K,V> extends CacheContinuousQueryHandler<K,V>
Continuous query handler V2 version. ContainsFactoryfor remote listener.- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.ignite.internal.processors.continuous.GridContinuousHandler
GridContinuousHandler.RegisterStatus
-
-
Field Summary
Fields Modifier and Type Field Description protected javax.cache.event.CacheEntryEventFilterfilter-
Fields inherited from class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler
DFLT_CONTINUOUS_QUERY_BACKUP_ACK_THRESHOLD, DFLT_CONTINUOUS_QUERY_LISTENER_MAX_BUFFER_SIZE, IGNITE_CONTINUOUS_QUERY_BACKUP_ACK_THRESHOLD, IGNITE_CONTINUOUS_QUERY_LISTENER_MAX_BUFFER_SIZE, initFut, p2pUnmarshalFut
-
-
Constructor Summary
Constructors Constructor Description CacheContinuousQueryHandlerV2()Required byExternalizable.CacheContinuousQueryHandlerV2(String cacheName, Object topic, @Nullable javax.cache.event.CacheEntryUpdatedListener<K,V> locLsnr, @Nullable javax.cache.configuration.Factory<? extends javax.cache.event.CacheEntryEventFilter<K,V>> rmtFilterFactory, boolean oldValRequired, boolean sync, boolean ignoreExpired, boolean ignoreClsNotFound, @Nullable Byte types)Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description GridContinuousHandlerclone()Clones this handler.protected javax.cache.event.CacheEntryEventFiltergetEventFilter0()Returns an event filter without waiting on the unmarshalling future.booleanisMarshalled()voidp2pMarshal(GridKernalContext ctx)Deploys and marshals inner objects (called only if peer deployment is enabled).voidp2pUnmarshal(UUID nodeId, GridKernalContext ctx)Unmarshals inner objects (called only if peer deployment is enabled).voidreadExternal(ObjectInput in)StringtoString()voidwriteExternal(ObjectOutput out)-
Methods inherited from class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler
cacheName, createBatch, filter, flushOnNodeLeft, getEventFilter, getTransformer, getTransformer0, initRemoteFilter, internal, isEvents, isMessaging, isQuery, keepBinary, keepBinary, localListener, localOnly, localOnly, localTransformedEventListener, notifyCallback, notifyExisting, notifyExisting, oldValueRequired, onBatchAcknowledged, onClientDisconnected, orderedTopic, p2pUnmarshal, register, skipPrimaryCheck, taskNameHash, unregister, updateCounters, updateCounters
-
-
-
-
Constructor Detail
-
CacheContinuousQueryHandlerV2
public CacheContinuousQueryHandlerV2()
Required byExternalizable.
-
CacheContinuousQueryHandlerV2
public CacheContinuousQueryHandlerV2(String cacheName, Object topic, @Nullable @Nullable javax.cache.event.CacheEntryUpdatedListener<K,V> locLsnr, @Nullable @Nullable javax.cache.configuration.Factory<? extends javax.cache.event.CacheEntryEventFilter<K,V>> rmtFilterFactory, boolean oldValRequired, boolean sync, boolean ignoreExpired, boolean ignoreClsNotFound, @Nullable @Nullable Byte types)
Constructor.- Parameters:
cacheName- Cache name.topic- Topic for ordered messages.locLsnr- Local listener.rmtFilterFactory- Remote filter factory.oldValRequired- Old value required flag.sync- Synchronous flag.ignoreExpired- Ignore expired events flag.types- Event types.
-
-
Method Detail
-
getEventFilter0
protected javax.cache.event.CacheEntryEventFilter getEventFilter0()
Returns an event filter without waiting on the unmarshalling future.- Overrides:
getEventFilter0in classCacheContinuousQueryHandler<K,V>- Returns:
- Cache entry event filter.
-
p2pMarshal
public void p2pMarshal(GridKernalContext ctx) throws IgniteCheckedException
Deploys and marshals inner objects (called only if peer deployment is enabled).- Specified by:
p2pMarshalin interfaceGridContinuousHandler- Overrides:
p2pMarshalin classCacheContinuousQueryHandler<K,V>- Parameters:
ctx- Kernal context.- Throws:
IgniteCheckedException- In case of error.
-
p2pUnmarshal
public void p2pUnmarshal(UUID nodeId, GridKernalContext ctx) throws IgniteCheckedException
Unmarshals inner objects (called only if peer deployment is enabled).- Specified by:
p2pUnmarshalin interfaceGridContinuousHandler- Overrides:
p2pUnmarshalin classCacheContinuousQueryHandler<K,V>- Parameters:
nodeId- Sender node ID.ctx- Kernal context.- Throws:
IgniteCheckedException- In case of error.
-
isMarshalled
public boolean isMarshalled()
- Overrides:
isMarshalledin classCacheContinuousQueryHandler<K,V>- Returns:
- Whether the handler is marshalled for peer class loading.
-
clone
public GridContinuousHandler clone()
Clones this handler.- Specified by:
clonein interfaceGridContinuousHandler- Overrides:
clonein classCacheContinuousQueryHandler<K,V>- Returns:
- Clone of this handler.
-
toString
public String toString()
- Overrides:
toStringin classCacheContinuousQueryHandler<K,V>
-
writeExternal
public void writeExternal(ObjectOutput out) throws IOException
- Specified by:
writeExternalin interfaceExternalizable- Overrides:
writeExternalin classCacheContinuousQueryHandler<K,V>- Throws:
IOException
-
readExternal
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
- Specified by:
readExternalin interfaceExternalizable- Overrides:
readExternalin classCacheContinuousQueryHandler<K,V>- Throws:
IOExceptionClassNotFoundException
-
-