Class ContinuousQueryView
- java.lang.Object
-
- org.apache.ignite.spi.systemview.view.ContinuousQueryView
-
public class ContinuousQueryView extends Object
Continuous query representation for aSystemView.
-
-
Constructor Summary
Constructors Constructor Description ContinuousQueryView(UUID routineId, org.apache.ignite.internal.processors.continuous.GridContinuousProcessor.RoutineInfo qry)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanautoUnsubscribe()intbufferSize()StringcacheName()booleandelayedRegister()longinterval()booleanisEvents()booleanisMessaging()booleanisQuery()booleankeepBinary()longlastSendTime()StringlocalListener()StringlocalTransformedListener()UUIDnodeId()booleannotifyExisting()booleanoldValueRequired()StringremoteFilter()StringremoteTransformer()UUIDroutineId()Stringtopic()
-
-
-
Constructor Detail
-
ContinuousQueryView
public ContinuousQueryView(UUID routineId, org.apache.ignite.internal.processors.continuous.GridContinuousProcessor.RoutineInfo qry)
- Parameters:
routineId- Routine id.qry- Query info.
-
-
Method Detail
-
routineId
public UUID routineId()
- Returns:
- Continuous query id.
-
nodeId
public UUID nodeId()
- Returns:
- Node id.
-
cacheName
public String cacheName()
- Returns:
- Cache name.
-
topic
public String topic()
- Returns:
- Topic for continuous query messages.
-
bufferSize
public int bufferSize()
- Returns:
- Buffer size.
-
interval
public long interval()
- Returns:
- Notify interval.
-
autoUnsubscribe
public boolean autoUnsubscribe()
- Returns:
- Auto unsubscribe flag value.
-
isEvents
public boolean isEvents()
- Returns:
Trueif continuous query registered to receive events.
-
isMessaging
public boolean isMessaging()
- Returns:
Trueif continuous query registered for messaging.
-
isQuery
public boolean isQuery()
- Returns:
Trueif regular continuous query.
-
keepBinary
public boolean keepBinary()
- Returns:
TrueifkeepBinarymode enabled.- See Also:
IgniteCache.withKeepBinary()
-
notifyExisting
public boolean notifyExisting()
- Returns:
Trueif continuous query should receive notification for existing entries.
-
oldValueRequired
public boolean oldValueRequired()
- Returns:
Trueif old value required for listener.
-
lastSendTime
public long lastSendTime()
- Returns:
- Last send time.
-
delayedRegister
public boolean delayedRegister()
- Returns:
- Delayed register flag.
-
localListener
public String localListener()
- Returns:
- Class name of the local transformed listener.
- See Also:
ContinuousQuery.setLocalListener(CacheEntryUpdatedListener)
-
remoteFilter
public String remoteFilter()
- Returns:
- String representation of remote filter.
- See Also:
ContinuousQuery.setRemoteFilter(CacheEntryEventSerializableFilter),AbstractContinuousQuery.setRemoteFilterFactory(Factory)
-
remoteTransformer
public String remoteTransformer()
- Returns:
- String representation of remote transformer.
- See Also:
ContinuousQueryWithTransformer,ContinuousQueryWithTransformer.setRemoteTransformerFactory(Factory)
-
localTransformedListener
public String localTransformedListener()
- Returns:
- String representation of local transformed listener.
- See Also:
ContinuousQueryWithTransformer,ContinuousQueryWithTransformer.setLocalListener(ContinuousQueryWithTransformer.EventListener)
-
-