public class ContinuousQueryView extends Object
SystemView
.Constructor and Description |
---|
ContinuousQueryView(UUID routineId,
org.apache.ignite.internal.processors.continuous.GridContinuousProcessor.RoutineInfo qry) |
Modifier and Type | Method and Description |
---|---|
boolean |
autoUnsubscribe() |
int |
bufferSize() |
String |
cacheName() |
boolean |
delayedRegister() |
long |
interval() |
boolean |
isEvents() |
boolean |
isMessaging() |
boolean |
isQuery() |
boolean |
keepBinary() |
long |
lastSendTime() |
String |
localListener() |
String |
localTransformedListener() |
UUID |
nodeId() |
boolean |
notifyExisting() |
boolean |
oldValueRequired() |
String |
remoteFilter() |
String |
remoteTransformer() |
UUID |
routineId() |
String |
topic() |
public ContinuousQueryView(UUID routineId, org.apache.ignite.internal.processors.continuous.GridContinuousProcessor.RoutineInfo qry)
routineId
- Routine id.qry
- Query info.public UUID routineId()
public UUID nodeId()
public String cacheName()
public String topic()
public int bufferSize()
public long interval()
public boolean autoUnsubscribe()
public boolean isEvents()
True
if continuous query registered to receive events.public boolean isMessaging()
True
if continuous query registered for messaging.public boolean isQuery()
True
if regular continuous query.public boolean keepBinary()
True
if keepBinary
mode enabled.IgniteCache.withKeepBinary()
public boolean notifyExisting()
True
if continuous query should receive notification for existing entries.public boolean oldValueRequired()
True
if old value required for listener.public long lastSendTime()
public boolean delayedRegister()
public String localListener()
ContinuousQuery.setLocalListener(CacheEntryUpdatedListener)
public String remoteFilter()
ContinuousQuery.setRemoteFilter(CacheEntryEventSerializableFilter)
,
AbstractContinuousQuery.setRemoteFilterFactory(Factory)
public String remoteTransformer()
ContinuousQueryWithTransformer
,
ContinuousQueryWithTransformer.setRemoteTransformerFactory(Factory)
public String localTransformedListener()
ContinuousQueryWithTransformer
,
ContinuousQueryWithTransformer.setLocalListener(ContinuousQueryWithTransformer.EventListener)
GridGain In-Memory Computing Platform : ver. 8.9.14 Release Date : November 5 2024