Class ComponentNames
- java.lang.Object
-
- com.snowflake.connectors.taskreactor.ComponentNames
-
public final class ComponentNames extends Object
-
-
Field Summary
Fields Modifier and Type Field Description static String
COMMANDS_QUEUE
static String
COMMANDS_QUEUE_STREAM
static String
CONFIG_TABLE
static String
DISPATCHER_PROCEDURE
static Identifier
DISPATCHER_TASK
static String
QUEUE_STREAM
static String
QUEUE_TABLE
static String
TASK_REACTOR_SCHEMA
static String
WORKER_COMBINED_VIEW
static String
WORKER_REGISTRY_TABLE
static String
WORKER_STATUS_TABLE
-
Constructor Summary
Constructors Constructor Description ComponentNames()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static Identifier
workerQueueStream(WorkerId workerId)
static Identifier
workerQueueTable(WorkerId workerId)
static Identifier
workerTask(WorkerId workerId)
-
-
-
Field Detail
-
TASK_REACTOR_SCHEMA
public static final String TASK_REACTOR_SCHEMA
- See Also:
- Constant Field Values
-
QUEUE_TABLE
public static final String QUEUE_TABLE
- See Also:
- Constant Field Values
-
QUEUE_STREAM
public static final String QUEUE_STREAM
- See Also:
- Constant Field Values
-
COMMANDS_QUEUE
public static final String COMMANDS_QUEUE
- See Also:
- Constant Field Values
-
COMMANDS_QUEUE_STREAM
public static final String COMMANDS_QUEUE_STREAM
- See Also:
- Constant Field Values
-
WORKER_STATUS_TABLE
public static final String WORKER_STATUS_TABLE
- See Also:
- Constant Field Values
-
WORKER_REGISTRY_TABLE
public static final String WORKER_REGISTRY_TABLE
- See Also:
- Constant Field Values
-
WORKER_COMBINED_VIEW
public static final String WORKER_COMBINED_VIEW
- See Also:
- Constant Field Values
-
CONFIG_TABLE
public static final String CONFIG_TABLE
- See Also:
- Constant Field Values
-
DISPATCHER_PROCEDURE
public static final String DISPATCHER_PROCEDURE
- See Also:
- Constant Field Values
-
DISPATCHER_TASK
public static final Identifier DISPATCHER_TASK
-
-
Method Detail
-
workerQueueTable
public static Identifier workerQueueTable(WorkerId workerId)
-
workerQueueStream
public static Identifier workerQueueStream(WorkerId workerId)
-
workerTask
public static Identifier workerTask(WorkerId workerId)
-
-