Class ContinuousQueryView
- java.lang.Object
- 
- org.apache.ignite.spi.systemview.view.ContinuousQueryView
 
- 
 public class ContinuousQueryView extends Object Continuous query representation for aSystemView.
- 
- 
Constructor SummaryConstructors Constructor Description ContinuousQueryView(UUID routineId, org.apache.ignite.internal.processors.continuous.GridContinuousProcessor.RoutineInfo qry)
 - 
Method SummaryAll 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- 
ContinuousQueryViewpublic ContinuousQueryView(UUID routineId, org.apache.ignite.internal.processors.continuous.GridContinuousProcessor.RoutineInfo qry) - Parameters:
- routineId- Routine id.
- qry- Query info.
 
 
- 
 - 
Method Detail- 
routineIdpublic UUID routineId() - Returns:
- Continuous query id.
 
 - 
nodeIdpublic UUID nodeId() - Returns:
- Node id.
 
 - 
cacheNamepublic String cacheName() - Returns:
- Cache name.
 
 - 
topicpublic String topic() - Returns:
- Topic for continuous query messages.
 
 - 
bufferSizepublic int bufferSize() - Returns:
- Buffer size.
 
 - 
intervalpublic long interval() - Returns:
- Notify interval.
 
 - 
autoUnsubscribepublic boolean autoUnsubscribe() - Returns:
- Auto unsubscribe flag value.
 
 - 
isEventspublic boolean isEvents() - Returns:
- Trueif continuous query registered to receive events.
 
 - 
isMessagingpublic boolean isMessaging() - Returns:
- Trueif continuous query registered for messaging.
 
 - 
isQuerypublic boolean isQuery() - Returns:
- Trueif regular continuous query.
 
 - 
keepBinarypublic boolean keepBinary() - Returns:
- Trueif- keepBinarymode enabled.
- See Also:
- IgniteCache.withKeepBinary()
 
 - 
notifyExistingpublic boolean notifyExisting() - Returns:
- Trueif continuous query should receive notification for existing entries.
 
 - 
oldValueRequiredpublic boolean oldValueRequired() - Returns:
- Trueif old value required for listener.
 
 - 
lastSendTimepublic long lastSendTime() - Returns:
- Last send time.
 
 - 
delayedRegisterpublic boolean delayedRegister() - Returns:
- Delayed register flag.
 
 - 
localListenerpublic String localListener() - Returns:
- Class name of the local transformed listener.
- See Also:
- ContinuousQuery.setLocalListener(CacheEntryUpdatedListener)
 
 - 
remoteFilterpublic String remoteFilter() - Returns:
- String representation of remote filter.
- See Also:
- ContinuousQuery.setRemoteFilter(CacheEntryEventSerializableFilter),- AbstractContinuousQuery.setRemoteFilterFactory(Factory)
 
 - 
remoteTransformerpublic String remoteTransformer() - Returns:
- String representation of remote transformer.
- See Also:
- ContinuousQueryWithTransformer,- ContinuousQueryWithTransformer.setRemoteTransformerFactory(Factory)
 
 - 
localTransformedListenerpublic String localTransformedListener() - Returns:
- String representation of local transformed listener.
- See Also:
- ContinuousQueryWithTransformer,- ContinuousQueryWithTransformer.setLocalListener(ContinuousQueryWithTransformer.EventListener)
 
 
- 
 
-