Class CacheQueryReadEvent<K,​V>

    • Constructor Detail

      • CacheQueryReadEvent

        public CacheQueryReadEvent​(ClusterNode node,
                                   String msg,
                                   int type,
                                   String qryType,
                                   @Nullable
                                   @Nullable String cacheName,
                                   @Nullable
                                   @Nullable String clsName,
                                   @Nullable
                                   @Nullable String clause,
                                   @Nullable
                                   @Nullable IgniteBiPredicate<K,​V> scanQryFilter,
                                   @Nullable
                                   @Nullable CacheEntryEventSerializableFilter<K,​V> contQryFilter,
                                   @Nullable
                                   @Nullable Object[] args,
                                   @Nullable
                                   @Nullable UUID subjId,
                                   @Nullable
                                   @Nullable String taskName,
                                   @Nullable
                                   K key,
                                   @Nullable
                                   V val,
                                   @Nullable
                                   V oldVal,
                                   @Nullable
                                   @Nullable Object row)
        Parameters:
        node - Node where event was fired.
        msg - Event message.
        type - Event type.
        cacheName - Cache name.
        clsName - Class name.
        clause - Clause.
        scanQryFilter - Scan query filter.
        args - Query arguments.
        subjId - Security subject ID.
        key - Key.
        val - Value.
        oldVal - Old value.
        qryType - Type of the query.
        contQryFilter - Continuous query filter.
        taskName - Name of the task if event was caused by an operation initiated within task execution.
        row - Result set read row.
    • Method Detail

      • queryType

        public String queryType()
        Gets query type.
        Returns:
        Query type. Can be "SQL", "SQL_FIELDS", "FULL_TEXT", "SCAN", "CONTINUOUS" or "SPI".
      • cacheName

        @Nullable
        public @Nullable String cacheName()
        Gets cache name on which query was executed.
        Returns:
        Cache name.
      • className

        @Nullable
        public @Nullable String className()
        Gets queried class name.

        Applicable for SQL and @{code full text} queries.

        Returns:
        Queried class name.
      • clause

        @Nullable
        public @Nullable String clause()
        Gets query clause.

        Applicable for SQL, SQL fields and @{code full text} queries.

        Returns:
        Query clause.
      • scanQueryFilter

        @Nullable
        public @Nullable IgniteBiPredicate<K,​V> scanQueryFilter()
        Gets scan query filter.

        Applicable for scan queries.

        Returns:
        Scan query filter.
      • continuousQueryFilter

        @Nullable
        public @Nullable CacheEntryEventSerializableFilter<K,​V> continuousQueryFilter()
        Gets continuous query filter.

        Applicable for continuous queries.

        Returns:
        Continuous query filter.
      • arguments

        @Nullable
        public @Nullable Object[] arguments()
        Gets query arguments.

        Applicable for SQL and SQL fields queries.

        Returns:
        Query arguments.
      • subjectId

        @Nullable
        public @Nullable UUID subjectId()
        Gets security subject ID.
        Returns:
        Subject ID if security is enabled, otherwise null.
        See Also:
        IgniteSecurity.enabled()
      • taskName

        @Nullable
        public @Nullable String taskName()
        Gets the name of the task that executed the query (if any).
        Returns:
        Task name.
      • key

        @Nullable
        public K key()
        Gets read entry key.
        Returns:
        Key.
      • value

        @Nullable
        public V value()
        Gets read entry value.
        Returns:
        Value.
      • oldValue

        @Nullable
        public V oldValue()
        Gets read entry old value (applicable for continuous queries).
        Returns:
        Old value.
      • row

        @Nullable
        public @Nullable Object row()
        Gets read results set row.
        Returns:
        Result row.