Class CacheContinuousQueryHandlerV3<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>
-
- org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandlerV3<K,V>
-
- All Implemented Interfaces:
Externalizable,Serializable,Cloneable,GridContinuousHandler
public class CacheContinuousQueryHandlerV3<K,V> extends CacheContinuousQueryHandlerV2<K,V>
Continuous query handler V3 version. ContainsFactoryfor remote transformer andContinuousQueryWithTransformer.EventListener.- See Also:
ContinuousQueryWithTransformer, Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.ignite.internal.processors.continuous.GridContinuousHandler
GridContinuousHandler.RegisterStatus
-
-
Field Summary
-
Fields inherited from class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandlerV2
filter
-
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 CacheContinuousQueryHandlerV3()Empty constructor.CacheContinuousQueryHandlerV3(String cacheName, Object topic, ContinuousQueryWithTransformer.EventListener<?> locTransLsnr, @Nullable javax.cache.configuration.Factory<? extends javax.cache.event.CacheEntryEventFilter<K,V>> rmtFilterFactory, javax.cache.configuration.Factory<? extends IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,?>> rmtTransFactory, boolean oldValRequired, boolean sync, boolean ignoreExpired, boolean ignoreClsNotFound)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected javax.cache.event.CacheEntryEventFiltergetEventFilter0()Returns an event filter without waiting on the unmarshalling future.IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,?>getTransformer0()booleanisMarshalled()ContinuousQueryWithTransformer.EventListener<?>localTransformedEventListener()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)GridContinuousHandler.RegisterStatusregister(UUID nodeId, UUID routineId, GridKernalContext ctx)Registers listener.voidwriteExternal(ObjectOutput out)-
Methods inherited from class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandlerV2
clone, toString
-
Methods inherited from class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler
cacheName, createBatch, filter, flushOnNodeLeft, getEventFilter, getTransformer, initRemoteFilter, internal, isEvents, isMessaging, isQuery, keepBinary, keepBinary, localListener, localOnly, localOnly, notifyCallback, notifyExisting, notifyExisting, oldValueRequired, onBatchAcknowledged, onClientDisconnected, orderedTopic, p2pUnmarshal, skipPrimaryCheck, taskNameHash, unregister, updateCounters, updateCounters
-
-
-
-
Constructor Detail
-
CacheContinuousQueryHandlerV3
public CacheContinuousQueryHandlerV3()
Empty constructor.
-
CacheContinuousQueryHandlerV3
public CacheContinuousQueryHandlerV3(String cacheName, Object topic, ContinuousQueryWithTransformer.EventListener<?> locTransLsnr, @Nullable @Nullable javax.cache.configuration.Factory<? extends javax.cache.event.CacheEntryEventFilter<K,V>> rmtFilterFactory, javax.cache.configuration.Factory<? extends IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,?>> rmtTransFactory, boolean oldValRequired, boolean sync, boolean ignoreExpired, boolean ignoreClsNotFound)
- Parameters:
cacheName- Cache name.topic- Topic.locTransLsnr- Local listener of transformed eventsrmtFilterFactory- Remote filter factory.rmtTransFactory- Remote transformer factory.oldValRequired- OldValRequired flag.sync- Sync flag.ignoreExpired- IgnoreExpired flag.ignoreClsNotFound- IgnoreClassNotFoundException flag.
-
-
Method Detail
-
getTransformer0
public IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,?> getTransformer0()
- Overrides:
getTransformer0in classCacheContinuousQueryHandler<K,V>- Returns:
- Cache entry event transformer.
-
localTransformedEventListener
public ContinuousQueryWithTransformer.EventListener<?> localTransformedEventListener()
- Overrides:
localTransformedEventListenerin classCacheContinuousQueryHandler<K,V>- Returns:
- Local listener of transformed events.
-
getEventFilter0
protected javax.cache.event.CacheEntryEventFilter getEventFilter0()
Returns an event filter without waiting on the unmarshalling future.- Overrides:
getEventFilter0in classCacheContinuousQueryHandlerV2<K,V>- Returns:
- Cache entry event filter.
-
register
public GridContinuousHandler.RegisterStatus register(UUID nodeId, UUID routineId, GridKernalContext ctx) throws IgniteCheckedException
Registers listener.- Specified by:
registerin interfaceGridContinuousHandler- Overrides:
registerin classCacheContinuousQueryHandler<K,V>- Parameters:
nodeId- ID of the node that started routine.routineId- Routine ID.ctx- Kernal context.- Returns:
- Whether listener was actually registered.
- Throws:
IgniteCheckedException- In case of error.
-
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 classCacheContinuousQueryHandlerV2<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 classCacheContinuousQueryHandlerV2<K,V>- Parameters:
nodeId- Sender node ID.ctx- Kernal context.- Throws:
IgniteCheckedException- In case of error.
-
isMarshalled
public boolean isMarshalled()
- Overrides:
isMarshalledin classCacheContinuousQueryHandlerV2<K,V>- Returns:
- Whether the handler is marshalled for peer class loading.
-
writeExternal
public void writeExternal(ObjectOutput out) throws IOException
- Specified by:
writeExternalin interfaceExternalizable- Overrides:
writeExternalin classCacheContinuousQueryHandlerV2<K,V>- Throws:
IOException
-
readExternal
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
- Specified by:
readExternalin interfaceExternalizable- Overrides:
readExternalin classCacheContinuousQueryHandlerV2<K,V>- Throws:
IOExceptionClassNotFoundException
-
-