getSelectorQueries

Returns a list containing the IDs of the queries that route to this channel in its selector configuration. An empty list will be returned if the selector configuration contains no query IDs. If no query IDs are specified in the selector, events from all queries will be sent to the channel.

Returns:

list of query IDs in the selector configuration of this channel. Empty list will be returned if no query IDs are specified.

Throws:

javax.management.JMException - if an unexpected error occurs

setSelectorQueries

Configures selector for this channel with the given query IDs. If an empty or null list is given, the channel will be configured for no query IDs. Queries do NOT need to exist in source processor. In other words, it is valid to use a queryID for a query that will be added to the processor at a future time.

Parameters:

queryIDs - List of IDs of the queries that should route to this channel

Throws:

javax.management.JMException - if an unexpected error occurs

addSelectorQuery

Adds the specified query ID to the selector configuration for this channel. Queries do NOT need to exist in source processor. In other words, it is valid to use a queryID for a query that will be added to the processor at a future time.

Parameters:

queryID - the ID of the query that is to be added to the channel's selector configuration

setHeartbeatTimeout

Sets the heart-beat timeout for a channel. By default there is no heart-beat timeout. Heart-beat events are used by the processors to advance time.

Heat-beat timeouts only applies to system-timestamped channels.

Heart-beat timeouts are needed when no events arrive in the event channels that are feeding the processors and the processor has been configured with a statement that includes some temporal operator, such it is the case of a time-based window, or a pattern matching with duration.

Parameters:

timeout - interval in nanoseconds after which a heart-beat event is automatically generated.

isSystemTimestamped

public boolean isSystemTimestamped()

Returns if channel is system timestamped, that is, the system is responsible for assigning a timestamp to each event. This is done using System.nanoTime().

Returns:

boolean

isApplicationTimestamped

public boolean isApplicationTimestamped()

Returns if channel is application timestamped, that is, application is responsible for assigning a timestamp to each event. Application may use any time domain.

Returns:

boolean

getPartitionOrderCapacity

public java.lang.Integer getPartitionOrderCapacity()

The capacity (i.e.number of buckets) of partition used for partition-ordered sources (e.g. relation/stream). This is used by downstream processors when executing partition-ordered queries and views. If not set and max-threads is greater than zero, then it is assumed to be equal to max-threads. If max-threads is not greater than zero, then the server's global partition-buckets configuration in the 'cql' section is used. If this is not set, then a default of 4 is used. A channel that is not connected to a processor does not have a partition order capacity and therefore returns null if not explicitly configured with a value.