Package com.snowflake.connectors.taskreactor

Class ComponentNames

  • public final class ComponentNames
extends Object
    Helper class containing common Task Reactor object names.

    • Field Detail

      • TASK_REACTOR_SCHEMA

        public static final String TASK_REACTOR_SCHEMA
        Name of the main Task Reactor schema.
        See Also:
        Constant Field Values

      • QUEUE_TABLE

        public static final String QUEUE_TABLE
        Name of the work item queue table in a Task Reactor instance.
        See Also:
        Constant Field Values

      • QUEUE_STREAM

        public static final String QUEUE_STREAM
        Name of the work item queue stream in a Task Reactor instance.
        See Also:
        Constant Field Values

      • COMMANDS_QUEUE

        public static final String COMMANDS_QUEUE
        Name of the command queue table in a Task Reactor instance.
        See Also:
        Constant Field Values

      • COMMANDS_QUEUE_STREAM

        public static final String COMMANDS_QUEUE_STREAM
        Name of the command queue stream in a Task Reactor instance.
        See Also:
        Constant Field Values

      • WORKER_STATUS_TABLE

        public static final String WORKER_STATUS_TABLE
        Name of the worker status table in a Task Reactor instance.
        See Also:
        Constant Field Values

      • WORKER_REGISTRY_TABLE

        public static final String WORKER_REGISTRY_TABLE
        Name of the worker registry table in a Task Reactor instance.
        See Also:
        Constant Field Values

      • WORKER_COMBINED_VIEW

        public static final String WORKER_COMBINED_VIEW
        Name of the combined worker queues view in a Task Reactor instance.
        See Also:
        Constant Field Values

      • CONFIG_TABLE

        public static final String CONFIG_TABLE
        Name of the config table in a Task Reactor instance.
        See Also:
        Constant Field Values

      • DISPATCHER_PROCEDURE

        public static final String DISPATCHER_PROCEDURE
        Name of the dispatcher procedure in a Task Reactor instance.
        See Also:
        Constant Field Values

      • DISPATCHER_TASK

        public static final Identifier DISPATCHER_TASK
        Name of the dispatcher task in a Task Reactor instance.

    • Constructor Detail

      • ComponentNames

        public ComponentNames()

    • Method Detail

      • workerQueueTable

        public static Identifier workerQueueTable​(WorkerId workerId)
        Creates a name of a queue table for a worker with a given worked id.
        Parameters:
        workerId - worker id
        Returns:
        name of a worker queue table

      • workerQueueStream

        public static Identifier workerQueueStream​(WorkerId workerId)
        Creates a name of a queue stream for a worker with a given worked id.
        Parameters:
        workerId - worker id
        Returns:
        name of a worker queue stream

      • workerTask

        public static Identifier workerTask​(WorkerId workerId)
        Creates a name of a task for a worker with a given worked id.
        Parameters:
        workerId - worker id
        Returns:
        name of a worker task