Index (Snowflake Native SDK for Connectors - Java API Reference (2.1.0))

A B C D E F G H I K L M N O P Q R S T U V W
All Classes All Packages

A

AccessTools - Interface in com.snowflake.connectors.util.snowflake: A set of basic Snowflake access tools.
ACTIVE - com.snowflake.connectors.taskreactor.worker.registry.WorkerLifecycleStatus: Worker is created and fully operational.
add(Command.CommandType, Variant) - Method in interface com.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository: Creates a new command.
add(Command.CommandType, Variant) - Method in class com.snowflake.connectors.taskreactor.commands.queue.DefaultCommandsQueueRepository: Creates a new command.
ADD - com.snowflake.connectors.application.observability.IngestionRunRepository.Mode: Add the new value to the currently persisted number of rows.
addCommandWithEmptyPayload(Command.CommandType) - Method in interface com.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository: Creates a new command with empty payload.
addEvent(String, long) - Static method in class com.snowflake.connectors.taskreactor.telemetry.TaskReactorTelemetry: Adds a new telemetry event.
addNewWorkers(int) - Method in class com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistryService: Adds the specified numbers of workers to the instance.
addWorkerIdleTimeEvent(Instant, Instant) - Static method in class com.snowflake.connectors.taskreactor.telemetry.TaskReactorTelemetry: Adds a new event for the worker idle time.
addWorkerWorkingTimeEvent(Instant, Instant) - Static method in class com.snowflake.connectors.taskreactor.telemetry.TaskReactorTelemetry: Adds a new event for the worker working time.
AGENT_ROLE - com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationKey: Role which is used by db connector's agent when connecting with Snowflake.
AGENT_USERNAME - com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationKey: Username which is used by db connector's agent when connecting with Snowflake.
ALLOWED_PROPERTY_NAMES - Static variable in enum com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationKey: A collection containing names of all allowed connector configuration property keys.
allowOverlappingExecution() - Method in class com.snowflake.connectors.common.task.TaskProperties: Returns whether the task allows overlapping execution.
alterSchedule(String) - Method in class com.snowflake.connectors.common.task.DefaultTaskRef
alterSchedule(String) - Method in interface com.snowflake.connectors.common.task.TaskRef: Changes schedule of referenced task.
alterScheduleIfExists(String) - Method in class com.snowflake.connectors.common.task.DefaultTaskRef
alterScheduleIfExists(String) - Method in interface com.snowflake.connectors.common.task.TaskRef: Changes schedule of referenced task if it exists.
alterWarehouse(WorkerId, String) - Method in class com.snowflake.connectors.taskreactor.worker.WorkerTaskManager: Alters a worker task warehouse
alterWarehouse(String) - Method in class com.snowflake.connectors.common.task.DefaultTaskRef
alterWarehouse(String) - Method in interface com.snowflake.connectors.common.task.TaskRef: Changes warehouse of referenced task.
alterWarehouseIfExists(String) - Method in class com.snowflake.connectors.common.task.DefaultTaskRef
alterWarehouseIfExists(String) - Method in interface com.snowflake.connectors.common.task.TaskRef: Changes warehouse of referenced task if it exists.
AppendOnlyKeyValueTable - Class in com.snowflake.connectors.common.table: Default implementation of AppendOnlyTable, which stores the data as key-value pairs, similarly to the default implementation of KeyValueTable.
AppendOnlyKeyValueTable(Session, String) - Constructor for class com.snowflake.connectors.common.table.AppendOnlyKeyValueTable: Creates a new AppendOnlyKeyValueTable, backed by the provided Snowflake table.
AppendOnlyStateRepository<T> - Interface in com.snowflake.connectors.common.state: An append-only repository for the connector state.
AppendOnlyTable - Interface in com.snowflake.connectors.common.table: A representation of a table to which the records can only be appended, never updated.
applyToAllInitializedTaskReactorInstances(Consumer<Identifier>) - Method in class com.snowflake.connectors.taskreactor.TaskReactorInstanceActionExecutor: Executes the specified actions for all initialized Task Reactor instances.
asCommaSeparatedSqlList(Collection<String>) - Static method in class com.snowflake.connectors.util.sql.SqlTools: Quotes each string using quote and joins them into one separated by commas.
asMap() - Method in class com.snowflake.connectors.common.exception.context.EmptyExceptionContext: Returns properties of this context as a map.
asMap() - Method in interface com.snowflake.connectors.common.exception.context.ExceptionContext: Returns properties of this context as a map.
asMap() - Method in class com.snowflake.connectors.common.exception.context.MutableExceptionContext: Returns properties of this context as a map.
Assert - Class in com.snowflake.connectors.util.snowflake.assertions: Utility class to allow for basic sanity checks.
Assert() - Constructor for class com.snowflake.connectors.util.snowflake.assertions.Assert
asVarchar(String) - Static method in class com.snowflake.connectors.util.sql.SqlTools: Returns the provided String wrapped in single quotes, so it can be treated as a SQL varchar.
asVariant(Variant) - Static method in class com.snowflake.connectors.util.sql.SqlTools: Returns the provided Variant changed to a JSON String and wrapped in the PARSE_JSON function, so it can be used as a SQL Variant.
AVAILABLE - com.snowflake.connectors.taskreactor.worker.status.WorkerStatus: Worker is operational and work could be assigned to it.

B

build() - Method in class com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationHandlerBuilder: Builds a new handler instance.
build() - Method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandlerBuilder: Builds a new handler instance.
build() - Method in class com.snowflake.connectors.application.configuration.connector.ConfigureConnectorHandlerBuilder: Builds a new handler instance.
build() - Method in class com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorHandlerBuilder: Builds a new handler instance.
build() - Method in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerBuilder: Builds a new handler instance.
build() - Method in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerBuilder: Builds a new handler instance.
build() - Method in class com.snowflake.connectors.application.ingestion.disable.DisableResourceHandlerBuilder: Builds a new handler instance.
build() - Method in class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandlerBuilder: Builds a new handler instance.
build() - Method in class com.snowflake.connectors.application.ingestion.update.UpdateResourceHandlerBuilder: Builds a new handler instance.
build() - Method in class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandlerBuilder: Builds a new handler instance.
build() - Method in class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandlerBuilder: Builds a new handler instance.
build() - Method in class com.snowflake.connectors.application.scheduler.CreateSchedulerHandlerBuilder: Builds a new handler instance.
build() - Method in class com.snowflake.connectors.application.scheduler.RunSchedulerIterationHandlerBuilder: Builds a new handler instance.
build() - Method in class com.snowflake.connectors.common.exception.helper.ConnectorErrorHelperBuilder: Builds a new error helper instance.
build() - Method in class com.snowflake.connectors.common.task.TaskProperties.Builder: Build new task properties.
build() - Method in class com.snowflake.connectors.taskreactor.api.PauseInstanceHandlerBuilder: Builds a new handler instance.
build() - Method in class com.snowflake.connectors.taskreactor.api.ResumeInstanceHandlerBuilder: Builds a new handler instance.
build() - Method in class com.snowflake.connectors.taskreactor.api.UpdateWarehouseInstanceHandlerBuilder: Builds a new handler instance.
buildDefault(Session, String) - Static method in interface com.snowflake.connectors.common.exception.helper.ConnectorErrorHelper: Builds a default instance of the ConnectorErrorHelper.
builder(Session) - Static method in class com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationHandler: Returns a new instance of ConnectionConfigurationHandlerBuilder.
builder(Session) - Static method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandler: Returns a new instance of ConnectionConfigurationHandlerBuilder.
builder(Session) - Static method in class com.snowflake.connectors.application.configuration.connector.ConfigureConnectorHandler: Returns a new instance of ConfigureConnectorHandlerBuilder.
builder(Session) - Static method in class com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorHandler: Returns a new instance of FinalizeConnectorHandlerBuilder.
builder(Session) - Static method in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandler: Returns a new instance of UpdateWarehouseHandlerBuilder.
builder(Session) - Static method in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandler: Returns a new instance of CreateResourceHandlerBuilder.
builder(Session) - Static method in class com.snowflake.connectors.application.ingestion.disable.DisableResourceHandler: Returns a new instance of DisableResourceHandlerBuilder.
builder(Session) - Static method in class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandler: Returns a new instance of EnableResourceHandlerBuilder.
builder(Session) - Static method in class com.snowflake.connectors.application.ingestion.update.UpdateResourceHandler: Returns a new instance of UpdateResourceHandlerBuilder.
builder(Session) - Static method in class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandler: Returns a new instance of PauseConnectorHandlerBuilder.
builder(Session) - Static method in class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandler: Returns a new instance of ResumeConnectorHandlerBuilder.
builder(Session) - Static method in class com.snowflake.connectors.application.scheduler.CreateSchedulerHandler: Returns a new instance of CreateSchedulerHandlerBuilder.
builder(Session) - Static method in class com.snowflake.connectors.application.scheduler.RunSchedulerIterationHandler: Returns a new instance of RunSchedulerIterationHandlerBuilder.
builder(Session) - Static method in class com.snowflake.connectors.taskreactor.api.UpdateWarehouseInstanceHandler: Returns a new instance of UpdateWarehouseInstanceHandlerBuilder.
builder(Session, String) - Static method in interface com.snowflake.connectors.common.exception.helper.ConnectorErrorHelper: Returns a new instance of ConnectorErrorHelperBuilder.
Builder(ObjectName, String, String) - Constructor for class com.snowflake.connectors.common.task.TaskProperties.Builder: Creates a new TaskProperties.Builder.
Builder(TaskProperties) - Constructor for class com.snowflake.connectors.common.task.TaskProperties.Builder: Creates a new TaskProperties.Builder.

C

callback - Variable in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerBuilder
callProcedure(Session, String, String, String...) - Static method in class com.snowflake.connectors.util.sql.SqlTools: Calls the specified application procedure with the provided arguments.
callPublicProcedure(Session, String, String...) - Static method in class com.snowflake.connectors.util.sql.SqlTools: Calls the specified application procedure, created in the PUBLIC schema, with the provided arguments.
CANCEL_ONGOING_EXECUTIONS - com.snowflake.connectors.taskreactor.commands.queue.Command.CommandType
CANCELED - com.snowflake.connectors.application.observability.IngestionRun.IngestionStatus: Ingestion cancelled.
cancelOngoingExecution - Variable in class com.snowflake.connectors.taskreactor.queue.QueueItem: Should ongoing executions of the resource ingestion be cancelled.
cancelOngoingExecution(QueueItem) - Method in class com.snowflake.connectors.taskreactor.Dispatcher: Cancels ongoing executions for items with the same resource id as a provided queue item.
cancelOngoingExecution(String) - Method in interface com.snowflake.connectors.taskreactor.queue.WorkItemQueue: Pushes cancel ongoing ingestion's item to work item queue.
cancelOngoingExecutions(List<String>) - Method in class com.snowflake.connectors.taskreactor.queue.DefaultWorkItemQueue
cancelOngoingExecutions(List<String>) - Method in interface com.snowflake.connectors.taskreactor.queue.WorkItemQueue: Pushes cancel ongoing ingestion's items to work item queue.
CancelOngoingExecutionsExecutor - Class in com.snowflake.connectors.taskreactor.commands.processor.executors: Executor of the CANCEL_ONGOING_EXECUTIONS command.
CancelOngoingExecutionsExecutor() - Constructor for class com.snowflake.connectors.taskreactor.commands.processor.executors.CancelOngoingExecutionsExecutor
canDeleteWorker(WorkerId) - Method in class com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistryService: Returns whether a worker with the specified id can be deleted.
canProvisionWorker(WorkerId) - Method in class com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistryService: Returns whether a worker with the specified id can be requested.
checkIfExists() - Method in class com.snowflake.connectors.common.task.DefaultTaskRef
checkIfExists() - Method in interface com.snowflake.connectors.common.task.TaskRef
checkThat(boolean) - Static method in class com.snowflake.connectors.util.snowflake.assertions.Assert: Function throws IllegalArgumentException when given boolean value is false
checkThat(boolean, String) - Static method in class com.snowflake.connectors.util.snowflake.assertions.Assert: Function throws IllegalArgumentException when first boolean argument is false
checkThat(BooleanSupplier) - Static method in class com.snowflake.connectors.util.snowflake.assertions.Assert: Function throws IllegalArgumentException when given boolean supplier returns false
checkThat(BooleanSupplier, String) - Static method in class com.snowflake.connectors.util.snowflake.assertions.Assert: Function throws IllegalArgumentException when given boolean supplier returns false
clean() - Method in class com.snowflake.connectors.taskreactor.queue.cleaner.QueueItemCleaner: Removes obsolete items from WorkItemQueue.
ColumnName() - Constructor for class com.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository.ColumnName
ColumnNames() - Constructor for class com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository.ColumnNames
com.snowflake.connectors.application.configuration - package com.snowflake.connectors.application.configuration: Backend implementations for configuration management and wizard procedures.
com.snowflake.connectors.application.configuration.connection - package com.snowflake.connectors.application.configuration.connection: Backend implementations for the connection configuration wizard step.
com.snowflake.connectors.application.configuration.connector - package com.snowflake.connectors.application.configuration.connector: Backend implementations for the connector configuration wizard step.
com.snowflake.connectors.application.configuration.finalization - package com.snowflake.connectors.application.configuration.finalization: Backend implementations for the configuration finalization wizard step.
com.snowflake.connectors.application.configuration.warehouse - package com.snowflake.connectors.application.configuration.warehouse: Backend implementations for the warehouse update process.
com.snowflake.connectors.application.ingestion.create - package com.snowflake.connectors.application.ingestion.create: Backend implementation of ingestion resource creation.
com.snowflake.connectors.application.ingestion.definition - package com.snowflake.connectors.application.ingestion.definition: Resource ingestion definition management.
com.snowflake.connectors.application.ingestion.disable - package com.snowflake.connectors.application.ingestion.disable: Backend implementation of ingestion resource disabling.
com.snowflake.connectors.application.ingestion.enable - package com.snowflake.connectors.application.ingestion.enable: Backend implementation of ingestion resource enabling.
com.snowflake.connectors.application.ingestion.process - package com.snowflake.connectors.application.ingestion.process: Resource ingestion process management.
com.snowflake.connectors.application.ingestion.update - package com.snowflake.connectors.application.ingestion.update: Update resource ingestion configuration.
com.snowflake.connectors.application.integration - package com.snowflake.connectors.application.integration: Task reactor compatible implementations of the task scheduler.
com.snowflake.connectors.application.lifecycle - package com.snowflake.connectors.application.lifecycle: Backend implementations for the connector lifecycle processes.
com.snowflake.connectors.application.lifecycle.pause - package com.snowflake.connectors.application.lifecycle.pause: Backend implementations for the connector pausing process.
com.snowflake.connectors.application.lifecycle.resume - package com.snowflake.connectors.application.lifecycle.resume: Backend implementations for the connector resuming process.
com.snowflake.connectors.application.observability - package com.snowflake.connectors.application.observability: Ingestion observability management.
com.snowflake.connectors.application.observability.exception - package com.snowflake.connectors.application.observability.exception: Exceptions for ingestion observability management.
com.snowflake.connectors.application.scheduler - package com.snowflake.connectors.application.scheduler: Task scheduler implementation.
com.snowflake.connectors.application.status - package com.snowflake.connectors.application.status: Connector and connector configuration status management.
com.snowflake.connectors.application.status.exception - package com.snowflake.connectors.application.status.exception: Exceptions for connector and connector configuration status management.
com.snowflake.connectors.common.exception - package com.snowflake.connectors.common.exception: Common connector exceptions.
com.snowflake.connectors.common.exception.context - package com.snowflake.connectors.common.exception.context: Exception context classes for the ConnectorException.
com.snowflake.connectors.common.exception.helper - package com.snowflake.connectors.common.exception.helper: Error handling and logging implementations for the ConnectorException.
com.snowflake.connectors.common.object - package com.snowflake.connectors.common.object: Representation of Snowflake objects.
com.snowflake.connectors.common.response - package com.snowflake.connectors.common.response: Standard connector response.
com.snowflake.connectors.common.state - package com.snowflake.connectors.common.state: Common connector state management.
com.snowflake.connectors.common.table - package com.snowflake.connectors.common.table: Common data table representations.
com.snowflake.connectors.common.task - package com.snowflake.connectors.common.task: Snowflake task management.
com.snowflake.connectors.taskreactor - package com.snowflake.connectors.taskreactor: Task reactor dispatcher and utilities.
com.snowflake.connectors.taskreactor.api - package com.snowflake.connectors.taskreactor.api: Backend implementation for the Task Reactor API.
com.snowflake.connectors.taskreactor.commands.processor - package com.snowflake.connectors.taskreactor.commands.processor: Task reactor commands processor.
com.snowflake.connectors.taskreactor.commands.processor.executors - package com.snowflake.connectors.taskreactor.commands.processor.executors: Task reactor command executors.
com.snowflake.connectors.taskreactor.commands.queue - package com.snowflake.connectors.taskreactor.commands.queue: Task reactor command queue.
com.snowflake.connectors.taskreactor.config - package com.snowflake.connectors.taskreactor.config: Task Reactor instance configuration management.
com.snowflake.connectors.taskreactor.dispatcher - package com.snowflake.connectors.taskreactor.dispatcher: Task Reactor instance dispatcher management.
com.snowflake.connectors.taskreactor.lifecycle - package com.snowflake.connectors.taskreactor.lifecycle: Task Reactor lifecycle management.
com.snowflake.connectors.taskreactor.log - package com.snowflake.connectors.taskreactor.log
com.snowflake.connectors.taskreactor.queue - package com.snowflake.connectors.taskreactor.queue: Task reactor queue.
com.snowflake.connectors.taskreactor.queue.cleaner - package com.snowflake.connectors.taskreactor.queue.cleaner: Task reactor expired work items cleaner.
com.snowflake.connectors.taskreactor.queue.selector - package com.snowflake.connectors.taskreactor.queue.selector: Task reactor work selector.
com.snowflake.connectors.taskreactor.registry - package com.snowflake.connectors.taskreactor.registry: Task reactor instance registry.
com.snowflake.connectors.taskreactor.telemetry - package com.snowflake.connectors.taskreactor.telemetry: Task reactor telemetry.
com.snowflake.connectors.taskreactor.troubleshooting - package com.snowflake.connectors.taskreactor.troubleshooting: Task reactor troubleshooting.
com.snowflake.connectors.taskreactor.worker - package com.snowflake.connectors.taskreactor.worker: Task reactor worker management.
com.snowflake.connectors.taskreactor.worker.ingestion - package com.snowflake.connectors.taskreactor.worker.ingestion: Task reactor ingestion.
com.snowflake.connectors.taskreactor.worker.queue - package com.snowflake.connectors.taskreactor.worker.queue: Task Reactor worker queue.
com.snowflake.connectors.taskreactor.worker.registry - package com.snowflake.connectors.taskreactor.worker.registry: Task reactor worker registry.
com.snowflake.connectors.taskreactor.worker.simpletask - package com.snowflake.connectors.taskreactor.worker.simpletask: Task reactor simple tasks.
com.snowflake.connectors.taskreactor.worker.status - package com.snowflake.connectors.taskreactor.worker.status: Task reactor worker status management.
com.snowflake.connectors.util.log - package com.snowflake.connectors.util.log
com.snowflake.connectors.util.snowflake - package com.snowflake.connectors.util.snowflake: Various utilities for Snowflake-related operations.
com.snowflake.connectors.util.snowflake.assertions - package com.snowflake.connectors.util.snowflake.assertions: Assertion utilities.
com.snowflake.connectors.util.sql - package com.snowflake.connectors.util.sql: Various utilities for SQL operations.
com.snowflake.connectors.util.time - package com.snowflake.connectors.util.time: Utilities for time management.
com.snowflake.connectors.util.variant - package com.snowflake.connectors.util.variant: Various utilities for Variant operations.
Command - Class in com.snowflake.connectors.taskreactor.commands.queue: Representation of the command entity from the command queue table.
Command(String, String, Variant, long) - Constructor for class com.snowflake.connectors.taskreactor.commands.queue.Command: Creates a Command object with all fields initialized.
Command.CommandType - Enum in com.snowflake.connectors.taskreactor.commands.queue: Valid command types that are recognized and supported by the command processor.
CommandExecutor - Interface in com.snowflake.connectors.taskreactor.commands.processor.executors: Task Reactor command executor.
COMMANDS_QUEUE - Static variable in class com.snowflake.connectors.taskreactor.ComponentNames
COMMANDS_QUEUE_STREAM - Static variable in class com.snowflake.connectors.taskreactor.ComponentNames
CommandsProcessor - Interface in com.snowflake.connectors.taskreactor.commands.processor: Task Reactor Commands Processor mechanism that processes commands added to the commands queue.
commandsQueueRepository(Identifier) - Method in interface com.snowflake.connectors.taskreactor.TaskReactorInstanceComponentProvider: Creates a new instance of CommandsQueueRepository for a given Task Reactor instance
CommandsQueueRepository - Interface in com.snowflake.connectors.taskreactor.commands.queue: Task Reactor repository that works with the commands queue table.
CommandsQueueRepository.ColumnName - Class in com.snowflake.connectors.taskreactor.commands.queue: Column names of the commands queue table.
CommandTypeUnsupportedByCommandsExecutorException - Exception in com.snowflake.connectors.taskreactor.commands.processor: Exception thrown when the particular value of the Command.CommandType is not supported by the implementation of the ExecutorStrategies.
CommandTypeUnsupportedByCommandsExecutorException(Command.CommandType) - Constructor for exception com.snowflake.connectors.taskreactor.commands.processor.CommandTypeUnsupportedByCommandsExecutorException: Creates a CommandTypeUnsupportedByCommandsExecutorException object with all fields initialized
COMPLETED - com.snowflake.connectors.application.observability.IngestionRun.IngestionStatus: Ingestion successfully completed.
ComponentNames - Class in com.snowflake.connectors.taskreactor
ComponentNames() - Constructor for class com.snowflake.connectors.taskreactor.ComponentNames
condition() - Method in class com.snowflake.connectors.common.task.TaskProperties: Returns the task condition.
CONFIG_TABLE - Static variable in class com.snowflake.connectors.taskreactor.ComponentNames
ConfigRepository - Interface in com.snowflake.connectors.taskreactor.config: Task reactor configuration repository utility.
ConfigurationMap - Interface in com.snowflake.connectors.application.configuration: A collection of key-value pairs, with an additional mapping for values.
ConfigurationRepository - Interface in com.snowflake.connectors.application.configuration: A repository for basic storage of the configuration.
configureConnector(Session, Variant) - Static method in class com.snowflake.connectors.application.configuration.connector.ConfigureConnectorHandler: Default handler method for the PUBLIC.CONFIGURE_CONNECTOR procedure.
configureConnector(Variant) - Method in class com.snowflake.connectors.application.configuration.connector.ConfigureConnectorHandler: Executes the main logic of the handler, with logging using withExceptionLogging.
ConfigureConnectorCallback - Interface in com.snowflake.connectors.application.configuration.connector: Callback called during the ConfigureConnectorHandler execution, may be used to provide custom connector configuration logic.
ConfigureConnectorHandler - Class in com.snowflake.connectors.application.configuration.connector: Handler for the connector configuration process.
ConfigureConnectorHandlerBuilder - Class in com.snowflake.connectors.application.configuration.connector: Builder for the ConfigureConnectorHandler.
ConfigureConnectorHandlerBuilder(Session) - Constructor for class com.snowflake.connectors.application.configuration.connector.ConfigureConnectorHandlerBuilder: Creates a new ConfigureConnectorHandlerBuilder.
ConfigureConnectorInputValidator - Interface in com.snowflake.connectors.application.configuration.connector: A validator for the input of ConfigureConnectorHandler, may be used to provide custom connector configuration validation.
CONFIGURED - com.snowflake.connectors.application.status.ConnectorStatus.ConnectorConfigurationStatus: Connector configuration wizard phase has been completed.
CONFIGURING - com.snowflake.connectors.application.status.ConnectorStatus: Connector is being configured (during the wizard phase).
CONNECTED - com.snowflake.connectors.application.status.ConnectorStatus.ConnectorConfigurationStatus: Connection configuration wizard phase has been completed.
CONNECTION_CONFIGURATION_KEY - Static variable in interface com.snowflake.connectors.application.configuration.ConfigurationRepository: Key of connection configuration record.
ConnectionConfigurationCallback - Interface in com.snowflake.connectors.application.configuration.connection: Callback called during the ConnectionConfigurationHandler and UpdateConnectionConfigurationHandler execution, may be used to provide custom connection configuration logic.
ConnectionConfigurationHandler - Class in com.snowflake.connectors.application.configuration.connection: Handler for the connection configuration process.
ConnectionConfigurationHandlerBuilder - Class in com.snowflake.connectors.application.configuration.connection: Builder for the ConnectionConfigurationHandler.
ConnectionConfigurationInputValidator - Interface in com.snowflake.connectors.application.configuration.connection: A validator for the input of ConnectionConfigurationHandler and UpdateConnectionConfigurationHandler, may be used to provide custom connection configuration validation.
ConnectionConfigurationNotFoundException - Exception in com.snowflake.connectors.application.configuration.connection: Exception thrown when connection configuration record was not found in the configuration table.
ConnectionConfigurationNotFoundException() - Constructor for exception com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationNotFoundException: Creates a new ConnectionConfigurationNotFoundException.
ConnectionConfigurationService - Interface in com.snowflake.connectors.application.configuration.connection: A service for basic management of the connection configuration.
ConnectionValidator - Interface in com.snowflake.connectors.application.configuration.connection: A validator for the connection configured during the ConnectionConfigurationHandler or UpdateConnectionConfigurationHandler execution.
CONNECTOR_CONFIGURATION_KEY - Static variable in interface com.snowflake.connectors.application.configuration.ConfigurationRepository: Key of connector configuration record.
CONNECTOR_STATUS_KEY - Static variable in interface com.snowflake.connectors.application.status.ConnectorStatusRepository: Key of status record.
ConnectorConfigurationKey - Enum in com.snowflake.connectors.application.configuration.connector: All keys allowed for the connector configuration properties.
ConnectorConfigurationNotFoundException - Exception in com.snowflake.connectors.application.configuration.connector: Exception thrown when connector configuration record was not found in the configuration table.
ConnectorConfigurationNotFoundException() - Constructor for exception com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationNotFoundException: Creates a new ConnectorConfigurationNotFoundException.
ConnectorConfigurationParsingException - Exception in com.snowflake.connectors.application.configuration.connector: Exception thrown when provided connector configuration is not valid.
ConnectorConfigurationParsingException(String) - Constructor for exception com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationParsingException: Creates a new ConnectorConfigurationParsingException.
connectorConfigurationService - Variable in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerBuilder
ConnectorConfigurationService - Interface in com.snowflake.connectors.application.configuration.connector: A service for basic management of the connector configuration.
ConnectorErrorHelper - Interface in com.snowflake.connectors.common.exception.helper: Provides utility methods for catching, logging and mapping exceptions within the connector.
ConnectorErrorHelperBuilder - Class in com.snowflake.connectors.common.exception.helper: Builder for the ConnectorErrorHelper.
ConnectorException - Exception in com.snowflake.connectors.common.exception: Main exception for the connector errors.
ConnectorException(ConnectorResponse) - Constructor for exception com.snowflake.connectors.common.exception.ConnectorException: Creates a new ConnectorException, with a provided response and an empty exception context.
ConnectorException(ConnectorResponse, ExceptionContext) - Constructor for exception com.snowflake.connectors.common.exception.ConnectorException: Creates a new ConnectorException, with a provided response and exception context.
ConnectorException(ConnectorResponse, ExceptionContext, Throwable) - Constructor for exception com.snowflake.connectors.common.exception.ConnectorException: Creates a new ConnectorException, with a provided response, exception context and an exception cause.
ConnectorException(ConnectorResponse, Throwable) - Constructor for exception com.snowflake.connectors.common.exception.ConnectorException: Creates a new ConnectorException, with a provided response and an exception cause.
ConnectorException(String, String) - Constructor for exception com.snowflake.connectors.common.exception.ConnectorException: Creates a new ConnectorException, with a provided response code, message and an empty exception context.
ConnectorException(String, String, ExceptionContext) - Constructor for exception com.snowflake.connectors.common.exception.ConnectorException: Creates a new ConnectorException, with a provided response code, message and exception context.
ConnectorException(String, String, ExceptionContext, Throwable) - Constructor for exception com.snowflake.connectors.common.exception.ConnectorException: Creates a new ConnectorException, with a provided response code, message, exception context and an exception cause.
ConnectorException(String, String, Throwable) - Constructor for exception com.snowflake.connectors.common.exception.ConnectorException: Creates a new ConnectorException, with a provided response code, message, an empty exception context and an exception cause.
ConnectorResponse - Class in com.snowflake.connectors.common.response: A standard response format used by the connectors sdk, consisting of a response code, a message, and a custom additional payload.
ConnectorResponse(String, String) - Constructor for class com.snowflake.connectors.common.response.ConnectorResponse: Creates a new ConnectorResponse, with the provided response code, message, and no additional response payload.
ConnectorResponse(String, String, Map<String, Variant>) - Constructor for class com.snowflake.connectors.common.response.ConnectorResponse: Creates a new ConnectorResponse, with the provided response code, message, and additional response payload.
ConnectorStatus - Enum in com.snowflake.connectors.application.status: Connector status.
ConnectorStatus.ConnectorConfigurationStatus - Enum in com.snowflake.connectors.application.status: Connector configuration status.
ConnectorStatusNotFoundException - Exception in com.snowflake.connectors.application.status.exception: Exception thrown when no connector status data was found in the database.
ConnectorStatusNotFoundException() - Constructor for exception com.snowflake.connectors.application.status.exception.ConnectorStatusNotFoundException: Creates a new ConnectorStatusNotFoundException.
ConnectorStatusRepository - Interface in com.snowflake.connectors.application.status: Repository for basic storage of the connector and connector configuration statuses.
connectorStatusService - Variable in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerBuilder
ConnectorStatusService - Interface in com.snowflake.connectors.application.status: Service for basic management of the connector and connector configuration statuses.
countEnabled() - Method in interface com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinitionRepository: Counts all resource ingestion definitions which have the ingestion for the resource enabled.
create(TaskDefinition, boolean, boolean) - Method in class com.snowflake.connectors.common.task.DefaultTaskRepository
create(TaskDefinition, boolean, boolean) - Method in interface com.snowflake.connectors.common.task.TaskRepository: Creates or replaces task with given definition in the database.
create(Session, Class<R>) - Static method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinitionRepositoryFactory: Creates a new instance of the default ResourceIngestionDefinitionRepository implementation, created for the given ResourceIngestionDefinition implementation.
createProcess(String, String, String, String, Variant) - Method in class com.snowflake.connectors.application.ingestion.process.DefaultIngestionProcessRepository
createProcess(String, String, String, String, Variant) - Method in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository: Creates a new ingestion process.
createResource(Session, String, Variant, Variant, String, boolean, Variant) - Static method in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandler: Default handler method for the PUBLIC.CREATE_RESOURCE procedure.
createResource(String, String, boolean, Variant, Variant, Variant) - Method in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandler: Executes the main logic of the handler, with logging using withExceptionLogging.
CreateResourceHandler - Class in com.snowflake.connectors.application.ingestion.create: Handler for the ingestion resource creation process.
CreateResourceHandlerBuilder - Class in com.snowflake.connectors.application.ingestion.create: Builder for the CreateResourceHandler.
CreateResourceHandlerBuilder(Session) - Constructor for class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerBuilder: Creates a new CreateResourceHandlerBuilder.
CreateResourceValidator - Interface in com.snowflake.connectors.application.ingestion.create: Callback which is called at the beginning of creating a resource
createScheduler() - Method in class com.snowflake.connectors.application.scheduler.CreateSchedulerHandler: Executes the main logic of the handler, with logging using withExceptionLogging.
createScheduler() - Method in interface com.snowflake.connectors.application.scheduler.SchedulerCreator: Creates a new scheduler instance.
createScheduler(Session) - Static method in class com.snowflake.connectors.application.scheduler.CreateSchedulerHandler: Default handler method for the PUBLIC.CREATE_SCHEDULER procedure.
CreateSchedulerHandler - Class in com.snowflake.connectors.application.scheduler: Handler for creating a new scheduler.
CreateSchedulerHandlerBuilder - Class in com.snowflake.connectors.application.scheduler: Builder for the CreateSchedulerHandler.
CreateSchedulerHandlerBuilder(Session) - Constructor for class com.snowflake.connectors.application.scheduler.CreateSchedulerHandlerBuilder: Creates a new CreateSchedulerHandlerBuilder.
CreateSchedulerHandlerTestBuilder - Class in com.snowflake.connectors.application.scheduler: Builder for the CreateSchedulerHandler.
CreateSchedulerHandlerTestBuilder() - Constructor for class com.snowflake.connectors.application.scheduler.CreateSchedulerHandlerTestBuilder: Constructor used by the test builder implementation.
CreateSchedulerHandlerTestBuilder(Session) - Constructor for class com.snowflake.connectors.application.scheduler.CreateSchedulerHandlerTestBuilder: Creates a new CreateSchedulerHandlerTestBuilder.
createWorkerQueueIfNotExist(WorkerId) - Method in interface com.snowflake.connectors.taskreactor.worker.queue.WorkerQueueManager: Creates queue table and snowflake stream on this table if objects do not exist.
createWorkerTask(WorkerId) - Method in class com.snowflake.connectors.taskreactor.worker.WorkerTaskManager: Creates a new worker task.
CRON - com.snowflake.connectors.application.ingestion.definition.ScheduleType: Cron interval schedule, mathing the standard cron pattern.
CrudIngestionProcessRepository - Interface in com.snowflake.connectors.application.ingestion.process: A repository for basic storage of the ingestion processes.
CrudIngestionRunRepository - Interface in com.snowflake.connectors.application.observability: A repository for basic storage of the ingestion run information.

D

DATA_OWNER_ROLE - com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationKey: Name of the role, which is the owner of the connector data.
debug(String) - Method in class com.snowflake.connectors.util.log.PrefixLogger
debug(String, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
debug(String, Object...) - Method in class com.snowflake.connectors.util.log.PrefixLogger
debug(String, Object, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
debug(String, Throwable) - Method in class com.snowflake.connectors.util.log.PrefixLogger
debug(Marker, String) - Method in class com.snowflake.connectors.util.log.PrefixLogger
debug(Marker, String, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
debug(Marker, String, Object...) - Method in class com.snowflake.connectors.util.log.PrefixLogger
debug(Marker, String, Object, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
debug(Marker, String, Throwable) - Method in class com.snowflake.connectors.util.log.PrefixLogger
DefaultAppendOnlyStateRepository<T> - Class in com.snowflake.connectors.common.state: Default implementation of AppendOnlyStateRepository.
DefaultAppendOnlyStateRepository(AppendOnlyTable, Class<T>) - Constructor for class com.snowflake.connectors.common.state.DefaultAppendOnlyStateRepository: Creates a new DefaultAppendOnlyStateRepository, using the provided table for data storage.
DefaultCommandsProcessor - Class in com.snowflake.connectors.taskreactor.commands.processor: Default implementation of CommandsProcessor used by the Task Reactor.
DefaultCommandsQueueRepository - Class in com.snowflake.connectors.taskreactor.commands.queue: Default implementation of the CommandsQueueRepository used by the Task Reactor.
DefaultCommandsQueueRepository(Session, Identifier) - Constructor for class com.snowflake.connectors.taskreactor.commands.queue.DefaultCommandsQueueRepository: Creates a DefaultCommandsQueueRepository object with all fields initialized.
DefaultConfigurationMap - Class in com.snowflake.connectors.application.configuration: Default implementation of ConfigurationMap, which uses VariantMapper for value mapping.
DefaultConfigurationMap(Map<String, Variant>) - Constructor for class com.snowflake.connectors.application.configuration.DefaultConfigurationMap: Creates a new DefaultConfigurationMap, backed by the provided map.
DefaultConfigurationRepository - Class in com.snowflake.connectors.application.configuration: Default implementation of ConfigurationRepository, which uses the KeyValueTable for data storage.
DefaultConfigurationRepository(KeyValueTable) - Constructor for class com.snowflake.connectors.application.configuration.DefaultConfigurationRepository: Creates a new DefaultConfigurationRepository, using the provided table for data storage.
DefaultConnectorStatusService - Class in com.snowflake.connectors.application.status: Default implementation of ConnectorStatusService.
DefaultConnectorStatusService(ConnectorStatusRepository) - Constructor for class com.snowflake.connectors.application.status.DefaultConnectorStatusService
DefaultExpiredWorkSelector - Class in com.snowflake.connectors.taskreactor.queue.cleaner: Default implementation onf ExpiredWorkSelector.
DefaultIngestionProcessRepository - Class in com.snowflake.connectors.application.ingestion.process: Default implementation of IngestionProcessRepository and CrudIngestionProcessRepository.
DefaultIngestionProcessRepository(Session) - Constructor for class com.snowflake.connectors.application.ingestion.process.DefaultIngestionProcessRepository
DefaultIngestionRunRepository - Class in com.snowflake.connectors.application.observability: Default implementation of IngestionRunRepository and CrudIngestionRunRepository.
DefaultIngestionRunRepository(Session) - Constructor for class com.snowflake.connectors.application.observability.DefaultIngestionRunRepository
DefaultKeyValueStateRepository<T> - Class in com.snowflake.connectors.common.state: Default implementation of KeyValueStateRepository.
DefaultKeyValueStateRepository(KeyValueTable, Class<T>) - Constructor for class com.snowflake.connectors.common.state.DefaultKeyValueStateRepository: Creates a new DefaultKeyValueStateRepository, using the provided table for data storage.
DefaultKeyValueTable - Class in com.snowflake.connectors.common.table: Default implementation of KeyValueTable.
DefaultKeyValueTable(Session, String) - Constructor for class com.snowflake.connectors.common.table.DefaultKeyValueTable: Creates a new DefaultKeyValueTable, backed by the provided Snowflake table.
DefaultLifecycleService - Class in com.snowflake.connectors.application.lifecycle: Default implementation of LifecycleService.
DefaultLifecycleService(PrivilegeTools, ConnectorStatusService, ConnectorStatus) - Constructor for class com.snowflake.connectors.application.lifecycle.DefaultLifecycleService
DefaultTableLister - Class in com.snowflake.connectors.common.table: This implementation uses SHOW TABLES ...
DefaultTableLister(Session) - Constructor for class com.snowflake.connectors.common.table.DefaultTableLister
DefaultTableRepository - Class in com.snowflake.connectors.common.table: Implements operations on snowflake TABLE objects
DefaultTableRepository(Session) - Constructor for class com.snowflake.connectors.common.table.DefaultTableRepository: Create DefaultTableRepository
DefaultTaskLister - Class in com.snowflake.connectors.common.task: Default implementation of TaskLister.
DefaultTaskLister(Session) - Constructor for class com.snowflake.connectors.common.task.DefaultTaskLister: Creates a new DefaultTaskLister.
DefaultTaskRef - Class in com.snowflake.connectors.common.task: Default implementation of TaskRef.
DefaultTaskRepository - Class in com.snowflake.connectors.common.task: Default implementation of TaskRepository.
DefaultTaskRepository(Session) - Constructor for class com.snowflake.connectors.common.task.DefaultTaskRepository: Creates a new DefaultTaskRepository.
DefaultWorkerCombinedView - Class in com.snowflake.connectors.taskreactor.worker: Default implementation of WorkerCombinedView view.
DefaultWorkItemQueue - Class in com.snowflake.connectors.taskreactor.queue: Default implementation of WorkItemQueue.
definition() - Method in class com.snowflake.connectors.common.task.TaskProperties: Returns the task definition.
delete(WorkerId) - Method in interface com.snowflake.connectors.taskreactor.worker.queue.WorkerQueue: Delete item in given Worker Queue.
delete(String) - Method in interface com.snowflake.connectors.application.configuration.ConfigurationRepository: Deletes the configuration record stored under the provided key.
delete(String) - Method in class com.snowflake.connectors.application.configuration.DefaultConfigurationRepository
delete(String) - Method in class com.snowflake.connectors.common.table.DefaultKeyValueTable
delete(String) - Method in interface com.snowflake.connectors.common.table.KeyValueTable: Deletes the value stored under the provided key from this table.
delete(String) - Method in class com.snowflake.connectors.common.table.ReadOnlyKeyValueTable
delete(String) - Method in interface com.snowflake.connectors.taskreactor.queue.WorkItemQueue: Remove items from work item queue with given id.
delete(List<String>) - Method in class com.snowflake.connectors.taskreactor.queue.DefaultWorkItemQueue
delete(List<String>) - Method in interface com.snowflake.connectors.taskreactor.queue.WorkItemQueue: Remove items from work item queue with given ids.
deleteBefore(String, Timestamp) - Method in class com.snowflake.connectors.taskreactor.queue.DefaultWorkItemQueue
deleteBefore(String, Timestamp) - Method in interface com.snowflake.connectors.taskreactor.queue.WorkItemQueue
deleteById(String) - Method in interface com.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository: Deletes the command with the given id.
deleteById(String) - Method in class com.snowflake.connectors.taskreactor.commands.queue.DefaultCommandsQueueRepository: Deletes the command with the given id.
DELETED - com.snowflake.connectors.taskreactor.worker.registry.WorkerLifecycleStatus: Worker is deleted.
deleteUnsupportedCommands() - Method in interface com.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository: Deletes all commands of type that should not be supported by the commands processor
deleteUnsupportedCommands() - Method in class com.snowflake.connectors.taskreactor.commands.queue.DefaultCommandsQueueRepository: Deletes all commands of type that is not included in the Command.CommandType set of values
deleteWorkers(int) - Method in class com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistryService: Removes specified numbers of workers to the instance.
DELETING - com.snowflake.connectors.taskreactor.worker.registry.WorkerLifecycleStatus: Set by the Dispatcher when starting deleting worker objects.
deserialize(JsonParser, DeserializationContext) - Method in class com.snowflake.connectors.taskreactor.queue.QueueItemDeserializer
deserialize(JsonParser, DeserializationContext) - Method in class com.snowflake.connectors.util.variant.VariantDeserializer
DESTINATION_DATABASE - com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationKey: Database in which the connector data is stored.
DESTINATION_SCHEMA - com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationKey: Schema in which the connector data is stored.
DISABLED - com.snowflake.connectors.common.object.Identifier.AutoQuoting: Never adds any additional quotes to the provided String, never escapes any double quote characters.
disableResource(Session, String) - Static method in class com.snowflake.connectors.application.ingestion.disable.DisableResourceHandler: Default handler method for the PUBLIC.DISABLE_RESOURCE procedure.
disableResource(String) - Method in class com.snowflake.connectors.application.ingestion.disable.DisableResourceHandler: Disables a resource with given id
DisableResourceHandler - Class in com.snowflake.connectors.application.ingestion.disable: Handler for the process of disabling a resource.
DisableResourceHandlerBuilder - Class in com.snowflake.connectors.application.ingestion.disable: Builder for the DisableResourceHandler.
DisableResourceHandlerBuilder(Session) - Constructor for class com.snowflake.connectors.application.ingestion.disable.DisableResourceHandlerBuilder: Creates a new DisableResourceHandlerBuilder.
Dispatcher - Class in com.snowflake.connectors.taskreactor: Main task reactor task dispatcher.
DISPATCHER_PROCEDURE - Static variable in class com.snowflake.connectors.taskreactor.ComponentNames
DISPATCHER_TASK - Static variable in class com.snowflake.connectors.taskreactor.ComponentNames
DispatcherHandler - Class in com.snowflake.connectors.taskreactor.api: Handler for the Task Reactor dispatcher.
DispatcherHandler() - Constructor for class com.snowflake.connectors.taskreactor.api.DispatcherHandler
dispatcherTaskManager(Identifier) - Method in interface com.snowflake.connectors.taskreactor.TaskReactorInstanceComponentProvider: Creates a new instance of DispatcherTaskManager for a given Task Reactor instance
DispatcherTaskManager - Class in com.snowflake.connectors.taskreactor.dispatcher: Component for managing dispatcher task.
dispatchWorkItems(Session, String) - Static method in class com.snowflake.connectors.taskreactor.api.DispatcherHandler: Default handler method for the TASK_REACTOR.DISPATCHER procedure.
DraftConnectionValidator - Interface in com.snowflake.connectors.application.configuration.connection: A validator for the draft connection configured during UpdateConnectionConfigurationHandler execution.
drop() - Method in class com.snowflake.connectors.common.task.DefaultTaskRef
drop() - Method in interface com.snowflake.connectors.common.task.TaskRef: Removes referenced task from the database.
dropIfExists() - Method in class com.snowflake.connectors.common.task.DefaultTaskRef
dropIfExists() - Method in interface com.snowflake.connectors.common.task.TaskRef: Removes referenced task from the database if it exists.
dropTableIfExists(ObjectName) - Method in class com.snowflake.connectors.common.table.DefaultTableRepository: Drops given table if it exists
dropTableIfExists(ObjectName) - Method in interface com.snowflake.connectors.common.table.TableRepository: Drops given table if it exists
dropWorkerQueue(WorkerId) - Method in interface com.snowflake.connectors.taskreactor.worker.queue.WorkerQueueManager: Removes snowflake table and stream for provided workerId.
dropWorkerTask(WorkerId) - Method in class com.snowflake.connectors.taskreactor.worker.WorkerTaskManager: Drops a worker task.
DuplicateKeyException - Exception in com.snowflake.connectors.common.table: Exception thrown when there are duplicated keys in collection
DuplicateKeyException(Set<?>) - Constructor for exception com.snowflake.connectors.common.table.DuplicateKeyException: Creates a new DuplicateKeyException.

E

EMPTY_COMMAND_PAYLOAD - Static variable in interface com.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository
EmptyExceptionContext - Class in com.snowflake.connectors.common.exception.context: Empty implementation of ExceptionContext.
EmptyImplementation - Class in com.snowflake.connectors.application.ingestion.definition: Placeholder class for use as a ResourceIngestionDefinition parameter, when there is no need to define custom properties for a given definition implementation.
EmptyImplementation() - Constructor for class com.snowflake.connectors.application.ingestion.definition.EmptyImplementation: Creates a new EmptyImplementation.
ENABLED - com.snowflake.connectors.common.object.Identifier.AutoQuoting: Adds quotes to the given identifier and escapes any double quote characters if the provided String is not all-uppercase (does not match the pattern).
enableResource(Session, String) - Static method in class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandler: Default handler method for the PUBLIC.ENABLE_RESOURCE procedure.
enableResource(String) - Method in class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandler: Enables a resource with given id.
EnableResourceHandler - Class in com.snowflake.connectors.application.ingestion.enable: Handler for the process of enabling a resource.
EnableResourceHandlerBuilder - Class in com.snowflake.connectors.application.ingestion.enable: Builder for the EnableResourceHandler.
EnableResourceHandlerBuilder(Session) - Constructor for class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandlerBuilder: Creates a new EnableResourceHandlerBuilder.
EnableResourceValidator - Interface in com.snowflake.connectors.application.ingestion.enable: Callback which is called at the beginning of enabling a resource
endProcess(String) - Method in class com.snowflake.connectors.application.ingestion.process.DefaultIngestionProcessRepository: Ends an ingestion process with the specified id.
endProcess(String) - Method in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository: Ends an ingestion process with the specified id.
endProcess(String, String, String) - Method in class com.snowflake.connectors.application.ingestion.process.DefaultIngestionProcessRepository: Ends an ingestion process with the specified resource ingestion definition id, ingestion configuration, and process type.
endProcess(String, String, String) - Method in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository: Ends an ingestion process with the specified resource ingestion definition id, ingestion configuration, and process type.
endRun(String, IngestionRun.IngestionStatus, Long, IngestionRunRepository.Mode, Variant) - Method in class com.snowflake.connectors.application.observability.DefaultIngestionRunRepository
endRun(String, IngestionRun.IngestionStatus, Long, IngestionRunRepository.Mode, Variant) - Method in interface com.snowflake.connectors.application.observability.IngestionRunRepository: Ends the specified ingestion run, setting the run status, number of ingested rows, and metadata.
endRun(String, IngestionRun.IngestionStatus, Long, Variant) - Method in interface com.snowflake.connectors.application.observability.IngestionRunRepository: Ends the specified ingestion run, setting the run status, number of ingested rows, and metadata.
equals(Object) - Method in class com.snowflake.connectors.application.ingestion.definition.EmptyImplementation
equals(Object) - Method in class com.snowflake.connectors.application.ingestion.definition.IngestionConfiguration
equals(Object) - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition
equals(Object) - Method in class com.snowflake.connectors.application.ingestion.definition.VariantResource
equals(Object) - Method in class com.snowflake.connectors.application.ingestion.process.IngestionProcess
equals(Object) - Method in class com.snowflake.connectors.application.observability.IngestionRun
equals(Object) - Method in class com.snowflake.connectors.application.status.FullConnectorStatus
equals(Object) - Method in class com.snowflake.connectors.common.object.Identifier
equals(Object) - Method in class com.snowflake.connectors.common.object.ObjectName
equals(Object) - Method in class com.snowflake.connectors.common.object.Reference
equals(Object) - Method in class com.snowflake.connectors.common.object.SchemaName
equals(Object) - Method in class com.snowflake.connectors.common.response.ConnectorResponse
equals(Object) - Method in class com.snowflake.connectors.common.table.TableProperties
equals(Object) - Method in class com.snowflake.connectors.common.task.TaskProperties
equals(Object) - Method in class com.snowflake.connectors.taskreactor.registry.TaskReactorInstance
equals(Object) - Method in class com.snowflake.connectors.taskreactor.worker.queue.WorkItem
equals(Object) - Method in class com.snowflake.connectors.taskreactor.worker.WorkerId
error(String) - Method in class com.snowflake.connectors.util.log.PrefixLogger
error(String, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
error(String, Object...) - Method in class com.snowflake.connectors.util.log.PrefixLogger
error(String, Object, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
error(String, String) - Static method in class com.snowflake.connectors.common.response.ConnectorResponse: Creates a new error response instance, with provided response code, message, and no additional payload.
error(String, String, Map<String, Variant>) - Static method in class com.snowflake.connectors.common.response.ConnectorResponse: Creates a new error response instance, with provided response code, message, and additional payload.
error(String, Throwable) - Method in class com.snowflake.connectors.util.log.PrefixLogger
error(Marker, String) - Method in class com.snowflake.connectors.util.log.PrefixLogger
error(Marker, String, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
error(Marker, String, Object...) - Method in class com.snowflake.connectors.util.log.PrefixLogger
error(Marker, String, Object, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
error(Marker, String, Throwable) - Method in class com.snowflake.connectors.util.log.PrefixLogger
ERROR - com.snowflake.connectors.application.status.ConnectorStatus: Connector is in an unspecified stated after encountering an irreversible error, it cannot be actively used.
ERROR_CODE - Static variable in exception com.snowflake.connectors.application.ingestion.create.ResourceCreationException: Error code of the exception, used in the underlying response.
ERROR_CODE - Static variable in exception com.snowflake.connectors.application.ingestion.disable.ResourceDisablingException: Error code of the exception, used in the underlying response.
ERROR_CODE - Static variable in exception com.snowflake.connectors.application.ingestion.enable.ResourceEnablingException: Error code of the exception, used in the underlying response.
ERROR_CODE - Static variable in exception com.snowflake.connectors.application.ingestion.update.ResourceUpdateException: Error code of the exception, used in the underlying response.
ERROR_CODE - Static variable in exception com.snowflake.connectors.application.scheduler.SchedulerCreationException: Error code of the exception, used in the underlying response.
ERROR_TYPE - Static variable in class com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationHandler: Error type for the connection configuration failure, used by the ConnectorErrorHelper.
ERROR_TYPE - Static variable in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandler: Error type for the connection configuration failure, used by the ConnectorErrorHelper.
ERROR_TYPE - Static variable in class com.snowflake.connectors.application.configuration.connector.ConfigureConnectorHandler: Error type for the connector configuration failure, used by the ConnectorErrorHelper.
ERROR_TYPE - Static variable in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandler: Error type for the warehouse update failure, used by the ConnectorErrorHelper.
ERROR_TYPE - Static variable in class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandler: Error type for the connector pausing failure, used by the ConnectorErrorHelper.
ERROR_TYPE - Static variable in class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandler: Error type for the connector resuming failure, used by the ConnectorErrorHelper.
ERROR_TYPE - Static variable in class com.snowflake.connectors.application.scheduler.CreateSchedulerHandler: Error type for the connector configuration failure, used by the ConnectorErrorHelper.
ERROR_TYPE - Static variable in class com.snowflake.connectors.application.scheduler.RunSchedulerIterationHandler: Error type for the connector configuration failure, used by the ConnectorErrorHelper.
ERROR_TYPE - Static variable in class com.snowflake.connectors.taskreactor.api.PauseInstanceHandler: Error type for the connection configuration failure, used by the ConnectorErrorHelper.
ERROR_TYPE - Static variable in class com.snowflake.connectors.taskreactor.api.ResumeInstanceHandler: Error type for the connection configuration failure, used by the ConnectorErrorHelper.
ERROR_TYPE - Static variable in class com.snowflake.connectors.taskreactor.api.UpdateWarehouseInstanceHandler: Error type for the connector configuration failure, used by the ConnectorErrorHelper.
errorHelper - Variable in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerBuilder
ExceptionContext - Interface in com.snowflake.connectors.common.exception.context: A custom context for the ConnectorException.
ExceptionLogger<E> - Interface in com.snowflake.connectors.common.exception.helper: A generic exception logging implementation.
ExceptionMapper<E> - Interface in com.snowflake.connectors.common.exception.helper: A generic mapper used for changing any exception into an instance of ConnectorException.
execute() - Method in interface com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorSdkCallback: Executes logic custom sdk logic.
execute() - Method in interface com.snowflake.connectors.application.lifecycle.pause.PauseConnectorCallback: Executes the callback logic.
execute() - Method in interface com.snowflake.connectors.application.lifecycle.pause.PauseConnectorSdkCallback: Executes the callback logic.
execute() - Method in interface com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorCallback: Executes the callback logic.
execute() - Method in interface com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorSdkCallback: Executes the callback logic.
execute() - Method in class com.snowflake.connectors.common.task.DefaultTaskRef
execute() - Method in interface com.snowflake.connectors.common.task.TaskRef: Executes immediately the referenced task.
execute() - Method in class com.snowflake.connectors.taskreactor.Dispatcher: Executes the next dispatcher run.
execute(VariantResource) - Method in interface com.snowflake.connectors.application.ingestion.create.PreCreateResourceCallback: Callback which is called before executing the main logic of creating a resource and after validation.
execute(Identifier) - Method in class com.snowflake.connectors.application.configuration.warehouse.InternalUpdateWarehouseCallback
execute(Identifier) - Method in interface com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseCallback: Executes logic using the provided warehouse.
execute(Identifier) - Method in interface com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseSdkCallback: Executes logic using the provided warehouse.
execute(Command) - Method in class com.snowflake.connectors.taskreactor.commands.processor.executors.CancelOngoingExecutionsExecutor
execute(Command) - Method in interface com.snowflake.connectors.taskreactor.commands.processor.executors.CommandExecutor: Executes the logic required by the command passed as an argument.
execute(Command) - Method in class com.snowflake.connectors.taskreactor.commands.processor.executors.PauseInstanceExecutor: Pauses an instance of Task Reactor.
execute(Command) - Method in class com.snowflake.connectors.taskreactor.commands.processor.executors.ResumeInstanceExecutor: Resumes an instance of Task Reactor.
execute(Command) - Method in class com.snowflake.connectors.taskreactor.commands.processor.executors.SetWorkersNumberExecutor
execute(Command) - Method in class com.snowflake.connectors.taskreactor.commands.processor.executors.UpdateWarehouseExecutor
execute(WorkItem) - Method in interface com.snowflake.connectors.taskreactor.worker.simpletask.SimpleTask: Method used for performing simple tasks defined by user.
execute(Variant) - Method in interface com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationCallback: Executes logic using the provided connection configuration.
execute(Variant) - Method in interface com.snowflake.connectors.application.configuration.connector.ConfigureConnectorCallback: Executes logic using the provided connector configuration.
execute(Variant) - Method in interface com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorCallback: Executes logic using the provided configuration.
execute(String) - Method in interface com.snowflake.connectors.application.ingestion.create.PostCreateResourceCallback: Callback which is called at the end of creating a resource.
execute(String) - Method in interface com.snowflake.connectors.application.ingestion.disable.PostDisableResourceCallback: Callback which is called at the end of disabling a resource.
execute(String) - Method in interface com.snowflake.connectors.application.ingestion.disable.PreDisableResourceCallback: Callback which is called at the beginning of disabling a resource.
execute(String) - Method in interface com.snowflake.connectors.application.ingestion.enable.PostEnableResourceCallback: Callback which is called at the end of enabling a resource.
execute(String) - Method in interface com.snowflake.connectors.application.ingestion.enable.PreEnableResourceCallback: Callback which is called before executing the main logic of enabling a resource and after validation (whether a given resource exists and whether the resource is not already enabled).
execute(String, List<IngestionConfiguration<Variant, Variant>>) - Method in interface com.snowflake.connectors.application.ingestion.update.PostUpdateResourceCallback: Callback which is called at the end of updating a resource.
execute(String, List<IngestionConfiguration<Variant, Variant>>) - Method in interface com.snowflake.connectors.application.ingestion.update.PreUpdateResourceCallback: Callback which is called before executing the main logic of resource updating procedure and after validation step.
ExecutorStrategies - Interface in com.snowflake.connectors.taskreactor.commands.processor: The strategy that defines which CommandExecutor implementation is responsible for execution of command of a particular type.
expiredWorkSelector() - Method in class com.snowflake.connectors.taskreactor.config.TaskReactorConfig: Returns the expired work selector object name.
ExpiredWorkSelector - Interface in com.snowflake.connectors.taskreactor.queue.cleaner: Representation of the Task Reactor expired work selector.
EXPRESSION_LIMIT - Static variable in class com.snowflake.connectors.application.ingestion.process.DefaultIngestionProcessRepository: Maximum limit of inserted/updated records.
EXPRESSION_LIMIT - Static variable in class com.snowflake.connectors.common.table.DefaultKeyValueTable: Maximum limit of inserted/updated records.
EXPRESSION_LIMIT - Static variable in class com.snowflake.connectors.util.sql.MergeStatementValidator: Maximum limit of inserted/updated records.

F

FAILED - com.snowflake.connectors.application.observability.IngestionRun.IngestionStatus: Ingestion failed.
fetch() - Method in class com.snowflake.connectors.common.task.DefaultTaskRef
fetch() - Method in interface com.snowflake.connectors.common.task.TaskRef: Fetches properties containing base information about the referenced task.
fetch(Identifier) - Method in interface com.snowflake.connectors.taskreactor.registry.InstanceRegistryRepository: Fetches a Task Reactor instance with given identifier
fetch(ObjectName) - Method in class com.snowflake.connectors.common.task.DefaultTaskRepository
fetch(ObjectName) - Method in interface com.snowflake.connectors.common.task.TaskRepository: Provides database reference to task without executing database call.
fetch(WorkerId) - Method in interface com.snowflake.connectors.taskreactor.worker.queue.WorkerQueue: Fetches exactly one item from a Worker Queue.
fetch(String) - Method in interface com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinitionRepository: Fetches a resource ingestion definition with the specified id.
fetch(String) - Method in interface com.snowflake.connectors.application.ingestion.process.CrudIngestionProcessRepository: Fetches an ingestion process by the specified id.
fetch(String) - Method in class com.snowflake.connectors.application.ingestion.process.DefaultIngestionProcessRepository
fetch(String) - Method in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository: Fetches an ingestion process by the specified id.
fetch(String) - Method in interface com.snowflake.connectors.common.state.AppendOnlyStateRepository: Fetches the most recent state value stored under the provided key in this repository.
fetch(String) - Method in class com.snowflake.connectors.common.state.DefaultAppendOnlyStateRepository
fetch(String) - Method in class com.snowflake.connectors.common.state.DefaultKeyValueStateRepository
fetch(String) - Method in interface com.snowflake.connectors.common.state.KeyValueStateRepository: Fetches the state value stored under the provided key in this repository.
fetch(String) - Method in class com.snowflake.connectors.common.table.AppendOnlyKeyValueTable
fetch(String) - Method in interface com.snowflake.connectors.common.table.AppendOnlyTable: Fetches the most recent value stored under the provided key.
fetch(String) - Method in class com.snowflake.connectors.common.table.DefaultKeyValueTable
fetch(String) - Method in interface com.snowflake.connectors.common.table.KeyValueTable: Fetches the value stored under the provided key.
fetch(String) - Method in class com.snowflake.connectors.common.table.ReadOnlyKeyValueTable
fetch(String, Class<T>) - Method in interface com.snowflake.connectors.application.configuration.ConfigurationRepository: Retrieves configuration properties from the record stored under the provided key, and maps them to the provided class.
fetch(String, Class<T>) - Method in class com.snowflake.connectors.application.configuration.DefaultConfigurationRepository
fetchAll() - Method in interface com.snowflake.connectors.application.configuration.ConfigurationRepository: Retrieves all configuration records and maps them to an ConfigurationMap instance.
fetchAll() - Method in class com.snowflake.connectors.application.configuration.DefaultConfigurationRepository
fetchAll() - Method in interface com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinitionRepository: Fetches all resource ingestion definitions.
fetchAll() - Method in class com.snowflake.connectors.common.table.DefaultKeyValueTable
fetchAll() - Method in interface com.snowflake.connectors.common.table.KeyValueTable: Fetches all key-value pairs and returns them as a Map.
fetchAll() - Method in class com.snowflake.connectors.common.table.ReadOnlyKeyValueTable
fetchAll() - Method in interface com.snowflake.connectors.taskreactor.registry.InstanceRegistryRepository: Fetches all Task Reactor instances registered in the connector
fetchAll(String) - Method in interface com.snowflake.connectors.application.ingestion.process.CrudIngestionProcessRepository: Fetches all ingestion processes with the specified status.
fetchAll(String) - Method in class com.snowflake.connectors.application.ingestion.process.DefaultIngestionProcessRepository
fetchAll(String, String, String) - Method in class com.snowflake.connectors.application.ingestion.process.DefaultIngestionProcessRepository
fetchAll(String, String, String) - Method in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository: Fetches all ingestion processes with the specified resource ingestion definition id, ingestion configuration, and process type.
fetchAll(List<String>) - Method in interface com.snowflake.connectors.application.ingestion.process.CrudIngestionProcessRepository: Fetches all ingestion processes with resource ingestion definition id contained within the specified list of ids.
fetchAll(List<String>) - Method in class com.snowflake.connectors.application.ingestion.process.DefaultIngestionProcessRepository
fetchAllActive(String) - Method in class com.snowflake.connectors.application.ingestion.process.DefaultIngestionProcessRepository
fetchAllActive(String) - Method in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository: Fetches all ingestion processes with the specified resource ingestion definition id and statuses: IngestionProcessStatuses.SCHEDULED, IngestionProcessStatuses.IN_PROGRESS.
fetchAllById(List<String>) - Method in interface com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinitionRepository: Fetches all resource ingestion definitions with resource ingestion definition id contained within the specified list of ids.
fetchAllByProcessId(String) - Method in class com.snowflake.connectors.application.observability.DefaultIngestionRunRepository
fetchAllByProcessId(String) - Method in interface com.snowflake.connectors.application.observability.IngestionRunRepository: Fetches all ingestion runs created for the specified ingestion process id.
fetchAllByResourceId(String) - Method in class com.snowflake.connectors.application.observability.DefaultIngestionRunRepository
fetchAllByResourceId(String) - Method in interface com.snowflake.connectors.application.observability.IngestionRunRepository: Fetches all ingestion runs created for the specified resource ingestion definition id.
fetchAllEnabled() - Method in interface com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinitionRepository: Fetches all resource ingestion definitions which have the ingestion for the resource enabled.
fetchAllInitialized() - Method in interface com.snowflake.connectors.taskreactor.registry.InstanceRegistryRepository: Fetches all initialized Task Reactor instances registered in the connector
fetchAllSupportedOrderedBySeqNo() - Method in interface com.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository: Retrieves all commands of valid type from the commands queue sorted ascending by the command sequence number.
fetchAllSupportedOrderedBySeqNo() - Method in class com.snowflake.connectors.taskreactor.commands.queue.DefaultCommandsQueueRepository: Retrieves all commands of valid type from the commands queue sorted ascending by the command sequence number.
fetchAllWhere(Column) - Method in interface com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinitionRepository: Fetches all resource ingestion definitions satisfying the specified condition.
fetchByResourceId(Object) - Method in interface com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinitionRepository: Fetches a resource ingestion definition with the specified resource id.
fetchConnectorStatus() - Method in interface com.snowflake.connectors.application.status.ConnectorStatusRepository: Fetches the connector and connector configuration statuses.
fetchLastFinished(String, String, String) - Method in class com.snowflake.connectors.application.ingestion.process.DefaultIngestionProcessRepository
fetchLastFinished(String, String, String) - Method in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository: Fetches an ingestion process with the latest finishedAt date and status = FINISHED
fetchNotProcessedAndCancelingItems() - Method in class com.snowflake.connectors.taskreactor.queue.DefaultWorkItemQueue
fetchNotProcessedAndCancelingItems() - Method in interface com.snowflake.connectors.taskreactor.queue.WorkItemQueue: Fetch items currently not processed items and technical items used for other item canceling
FinalizeConnectorCallback - Interface in com.snowflake.connectors.application.configuration.finalization: Callback called during the FinalizeConnectorHandler execution, may be used to provide custom finalization logic (e.g.
finalizeConnectorConfiguration(Session, Variant) - Static method in class com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorHandler: Default handler method for the PUBLIC.FINALIZE_CONNECTOR_CONFIGURATION procedure.
finalizeConnectorConfiguration(Variant) - Method in class com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorHandler: Executes the main logic of the handler, with logging using withExceptionLogging.
FinalizeConnectorHandler - Class in com.snowflake.connectors.application.configuration.finalization: Handler for the configuration finalization process.
FinalizeConnectorHandlerBuilder - Class in com.snowflake.connectors.application.configuration.finalization: Builder for the FinalizeConnectorHandler.
FinalizeConnectorInputValidator - Interface in com.snowflake.connectors.application.configuration.finalization: A validator for the input of FinalizeConnectorHandler, may be used to provide custom configuration validation.
FinalizeConnectorSdkCallback - Interface in com.snowflake.connectors.application.configuration.finalization: Callback called during the FinalizeConnectorHandler execution, may be used to provide custom finalization logic required by the sdk.
FINALIZED - com.snowflake.connectors.application.status.ConnectorStatus.ConnectorConfigurationStatus: Configuration finalization wizard phase has been completed.
findBy(Column, Column) - Method in interface com.snowflake.connectors.application.observability.CrudIngestionRunRepository: Finds first ingestion run matching specified condition from sorted result.
findBy(Column, Column) - Method in class com.snowflake.connectors.application.observability.DefaultIngestionRunRepository
findById(String) - Method in class com.snowflake.connectors.application.observability.DefaultIngestionRunRepository
findById(String) - Method in interface com.snowflake.connectors.application.observability.IngestionRunRepository: Finds an ingestion run with the specified id.
findOngoingIngestionRuns() - Method in interface com.snowflake.connectors.application.observability.CrudIngestionRunRepository: Finds all ingestion runs with the status of IN_PROGRESS.
findOngoingIngestionRuns() - Method in class com.snowflake.connectors.application.observability.DefaultIngestionRunRepository
findOngoingIngestionRuns(String) - Method in interface com.snowflake.connectors.application.observability.CrudIngestionRunRepository: Finds all ingestion runs created for the specified resource ingestion definition id and with the status of IN_PROGRESS.
findOngoingIngestionRuns(String) - Method in class com.snowflake.connectors.application.observability.DefaultIngestionRunRepository
findOngoingIngestionRunsWhere(Column) - Method in interface com.snowflake.connectors.application.observability.CrudIngestionRunRepository: Finds all ingestion runs satisfying the specified condition and with the status of IN_PROGRESS.
findOngoingIngestionRunsWhere(Column) - Method in class com.snowflake.connectors.application.observability.DefaultIngestionRunRepository
findWhere(Column) - Method in interface com.snowflake.connectors.application.observability.CrudIngestionRunRepository: Finds all ingestion runs satisfying the specified condition.
findWhere(Column) - Method in class com.snowflake.connectors.application.observability.DefaultIngestionRunRepository
FINISHED - Static variable in class com.snowflake.connectors.application.ingestion.process.IngestionProcessStatuses: Status which means that the process is finished and no more iterations of ingestion will be scheduled
from(Identifier) - Static method in class com.snowflake.connectors.common.object.ObjectName: Creates a new object name instance from the provided name identifier.
from(Identifier) - Static method in class com.snowflake.connectors.common.object.SchemaName: Creates a new schema name instance from the provided schema identifier.
from(Identifier, Identifier) - Static method in class com.snowflake.connectors.common.object.ObjectName: Creates a new object name instance from the provided schema and name identifiers.
from(Identifier, Identifier) - Static method in class com.snowflake.connectors.common.object.SchemaName: Creates a new schema name instance from the provided database and schema identifiers.
from(Identifier, Identifier, Identifier) - Static method in class com.snowflake.connectors.common.object.ObjectName: Creates a new object name instance from the provided database, schema, and name identifiers.
from(SchemaName, Identifier) - Static method in class com.snowflake.connectors.common.object.ObjectName: Creates a new object name instance from the provided schema name and name identifier.
from(QueueItem) - Static method in class com.snowflake.connectors.taskreactor.worker.queue.WorkItem: Creates a new WorkItem from a given QueueItem.
from(Session, Identifier) - Static method in class com.snowflake.connectors.taskreactor.dispatcher.DispatcherTaskManager: Creates a new DispatcherTaskManager.
from(Session, Identifier) - Static method in class com.snowflake.connectors.taskreactor.Dispatcher: Create a new Dispatcher.
from(Session, Identifier) - Static method in class com.snowflake.connectors.taskreactor.queue.cleaner.QueueItemCleaner: Returns a new instance of the QueueItemCleaner
from(Session, Identifier) - Static method in class com.snowflake.connectors.taskreactor.queue.selector.QueueItemSelector: Returns a new instance of the QueueItemSelector
from(Session, Identifier) - Static method in class com.snowflake.connectors.taskreactor.worker.registry.WorkerOrchestrator: Creates a new WorkerOrchestrator.
from(Session, Identifier) - Static method in class com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistryService: Creates a new WorkerRegistryService.
from(Session, Identifier) - Static method in class com.snowflake.connectors.taskreactor.worker.WorkerManager: Creates a new WorkerManager.
from(Session, Identifier) - Static method in class com.snowflake.connectors.taskreactor.worker.WorkerTaskManager: Creates a new WorkerTaskManager.
from(Session, Ingestion<T>, WorkerId, Identifier) - Static method in class com.snowflake.connectors.taskreactor.worker.ingestion.IngestionWorker: Creates a new IngestionWorker.
from(Session, SimpleTask<T>, WorkerId, Identifier) - Static method in class com.snowflake.connectors.taskreactor.worker.simpletask.SimpleTaskWorker: Creates a new SimpleTaskWorker.
from(String) - Static method in class com.snowflake.connectors.common.object.Identifier: Creates a new identifier instance from the provided String, without any additional quoting.
from(String) - Static method in class com.snowflake.connectors.common.object.Reference: Creates a new reference instance from the provided reference name.
from(String, Identifier.AutoQuoting) - Static method in class com.snowflake.connectors.common.object.Identifier: Creates a new identifier instance from the provided String, with possible additional auto quoting if enabled.
from(String, String) - Static method in class com.snowflake.connectors.common.object.ObjectName: Creates a new object name instance from the provided raw schema and name identifiers.
from(String, String) - Static method in class com.snowflake.connectors.common.object.SchemaName: Creates a new schema name instance from the provided raw database and schema identifiers.
from(String, String, String) - Static method in class com.snowflake.connectors.common.object.ObjectName: Creates a new object name instance from the provided raw database, schema, and name identifiers.
fromException(String) - Static method in class com.snowflake.connectors.common.response.ConnectorResponse: Creates a new error response instance by parsing the provided exception body.
fromMap(Map<String, Variant>) - Static method in class com.snowflake.connectors.taskreactor.queue.QueueItem: Creates a new queue item from a specified map.
fromRow(Row) - Static method in class com.snowflake.connectors.taskreactor.queue.QueueItem: Creates a new queue item from a specified row.
fromString(String) - Static method in class com.snowflake.connectors.common.object.ObjectName: Creates a new object name instance from the provided raw object name (fully qualified or not).
fromString(String) - Static method in class com.snowflake.connectors.common.object.SchemaName: Creates a new schema name instance from the provided raw schema name.
fromVariant(Variant) - Static method in class com.snowflake.connectors.common.response.ConnectorResponse: Creates a new error response instance from the provided Variant.
FullConnectorStatus - Class in com.snowflake.connectors.application.status: Representation of the full connector status, comprised of the connector and connector configuration statuses.
FullConnectorStatus() - Constructor for class com.snowflake.connectors.application.status.FullConnectorStatus: Creates an empty FullConnectorStatus.
FullConnectorStatus(ConnectorStatus, ConnectorStatus.ConnectorConfigurationStatus) - Constructor for class com.snowflake.connectors.application.status.FullConnectorStatus: Creates a new FullConnectorStatus.

G

get(String, Class<T>) - Method in interface com.snowflake.connectors.application.configuration.ConfigurationMap: Returns the value stored under the provided key and maps it to the provided class.
get(String, Class<T>) - Method in class com.snowflake.connectors.application.configuration.DefaultConfigurationMap
getActiveOrRequestedWorkersCount() - Method in class com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistryService: Returns the number of active and requested workers.
getActiveOrUpForDeletionWorkers() - Method in class com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistryService: Returns ids of active or up for deletion workers.
getActiveProvisioningOrUpForDeletionWorkers() - Method in class com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistryService: Returns ids of active, provisioning or up for deletion workers.
getActiveWorkers() - Method in class com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistryService: Returns ids of active workers.
getAdditionalPayload() - Method in class com.snowflake.connectors.common.response.ConnectorResponse: Returns the additional response payload.
getAllWhere(Column) - Method in class com.snowflake.connectors.common.table.AppendOnlyKeyValueTable
getAllWhere(Column) - Method in interface com.snowflake.connectors.common.table.AppendOnlyTable: Returns all values from this table where the record matches the provided filter.
getAllWhere(Column) - Method in class com.snowflake.connectors.common.table.DefaultKeyValueTable
getAllWhere(Column) - Method in interface com.snowflake.connectors.common.table.KeyValueTable: Returns all values from this table where the record matches the provided filter.
getAllWhere(Column) - Method in class com.snowflake.connectors.common.table.ReadOnlyKeyValueTable
getAllWorkers() - Method in class com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistryService
getAvailableWorkers() - Method in interface com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository: Returns the ids of all available workers.
getCompletedAt() - Method in class com.snowflake.connectors.application.observability.IngestionRun: Returns the timestamp of the ingestion run end.
getConfig() - Method in interface com.snowflake.connectors.taskreactor.config.ConfigRepository: Returns a task reactor configuration.
getConfiguration() - Method in interface com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationService: Returns current connection configuration properties.
getConfiguration() - Method in interface com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationService: Retrieves current connector configuration properties.
getConfigurationStatus() - Method in class com.snowflake.connectors.application.status.FullConnectorStatus: Returns this connector configuration status.
getConnectorStatus() - Method in interface com.snowflake.connectors.application.status.ConnectorStatusService: Returns the connector and connector configuration statuses.
getConnectorStatus() - Method in class com.snowflake.connectors.application.status.DefaultConnectorStatusService
getContext() - Method in exception com.snowflake.connectors.common.exception.ConnectorException: Context of this exception.
getCreatedAt() - Method in class com.snowflake.connectors.application.ingestion.process.IngestionProcess: Returns the timestamp of the process creation.
getCreatedOn() - Method in class com.snowflake.connectors.common.table.TableProperties: TableProperties.createdOn property accessor
getCustomIngestionConfiguration() - Method in class com.snowflake.connectors.application.ingestion.definition.IngestionConfiguration: Returns the custom ingestion properties.
getDatabase() - Method in class com.snowflake.connectors.common.object.ObjectName: Returns the database of this object name.
getDatabase() - Method in class com.snowflake.connectors.common.object.SchemaName: Returns the database of this schema name.
getDestination() - Method in class com.snowflake.connectors.application.ingestion.definition.IngestionConfiguration: Returns the properties describing where the ingested data should be stored.
getExpired(String) - Method in class com.snowflake.connectors.taskreactor.queue.cleaner.DefaultExpiredWorkSelector
getExpired(String) - Method in interface com.snowflake.connectors.taskreactor.queue.cleaner.ExpiredWorkSelector: Fetches all unreachable items from the WorkItemQueue.
getFinishedAt() - Method in class com.snowflake.connectors.application.ingestion.process.IngestionProcess: Returns the timestamp of the process end.
getId() - Method in class com.snowflake.connectors.application.ingestion.definition.IngestionConfiguration: Returns the ingestion configuration id.
getId() - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Returns the resource ingestion definition id.
getId() - Method in class com.snowflake.connectors.application.ingestion.process.IngestionProcess: Returns the id of this ingestion process.
getId() - Method in class com.snowflake.connectors.application.observability.IngestionRun: Returns the id of this ingestion run.
getId() - Method in class com.snowflake.connectors.taskreactor.commands.queue.Command: Returns the command id.
getIngestedRows() - Method in class com.snowflake.connectors.application.observability.IngestionRun: Returns the number of ingested rows.
getIngestionConfigurationId() - Method in class com.snowflake.connectors.application.ingestion.process.IngestionProcess: Returns the ingestion configuration id.
getIngestionConfigurationId() - Method in class com.snowflake.connectors.application.observability.IngestionRun: Returns the ingestion configuration id.
getIngestionConfigurations() - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Returns the ingestion configurations.
getIngestionDefinitionId() - Method in class com.snowflake.connectors.application.observability.IngestionRun: Returns the resource ingestion definition id.
getIngestionProcessId() - Method in class com.snowflake.connectors.application.observability.IngestionRun: Returns the ingestion process id.
getIngestionStrategy() - Method in class com.snowflake.connectors.application.ingestion.definition.IngestionConfiguration: Returns the ingestion strategy.
getInstance(KeyValueTable) - Static method in interface com.snowflake.connectors.application.status.ConnectorStatusRepository: Returns a new instance of the default repository implementation.
getInstance(Session) - Static method in interface com.snowflake.connectors.application.configuration.ConfigurationRepository: Returns a new instance of the default repository implementation.
getInstance(Session) - Static method in interface com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationService: Returns a new instance of the default service implementation.
getInstance(Session) - Static method in interface com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationService: Returns a new instance of the default service implementation.
getInstance(Session) - Static method in interface com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseInputValidator: Returns a new instance of UpdateWarehouseInputValidator.
getInstance(Session) - Static method in class com.snowflake.connectors.application.integration.SchedulerTaskReactorOnIngestionFinishedCallback: Returns a new instance of the default callback implementation.
getInstance(Session) - Static method in interface com.snowflake.connectors.application.observability.CrudIngestionRunRepository: Returns a new instance of the default repository implementation.
getInstance(Session) - Static method in interface com.snowflake.connectors.application.observability.IngestionRunRepository: Returns a new instance of the default repository implementation.
getInstance(Session) - Static method in interface com.snowflake.connectors.application.scheduler.OnIngestionFinishedCallback: Returns a new instance of the default callback implementation.
getInstance(Session) - Static method in interface com.snowflake.connectors.application.scheduler.OnIngestionScheduledCallback: Returns a new instance of the default callback implementation.
getInstance(Session) - Static method in interface com.snowflake.connectors.application.scheduler.SchedulerCreator: Gets a new instance of the default scheduler creator implementation.
getInstance(Session) - Static method in interface com.snowflake.connectors.application.status.ConnectorStatusService: Returns a new instance of the default service implementation.
getInstance(Session) - Static method in interface com.snowflake.connectors.common.task.TaskLister: Returns a new instance of the default implementation for TaskLister.
getInstance(Session) - Static method in interface com.snowflake.connectors.common.task.TaskRepository: Returns a new instance of the default implementation for TaskRepository
getInstance(Session) - Static method in interface com.snowflake.connectors.common.task.UpdateTaskReactorTasks: Returns a new instance of the default implementation.
getInstance(Session) - Static method in interface com.snowflake.connectors.taskreactor.InstanceStreamService: Deprecated.

The method provides the default implementation of the instance stream service.
getInstance(Session) - Static method in class com.snowflake.connectors.taskreactor.lifecycle.PauseTaskReactorService: Creates a new instance of the PauseTaskReactorService.
getInstance(Session) - Static method in class com.snowflake.connectors.taskreactor.lifecycle.ResumeTaskReactorService: Creates a new instance of the ResumeTaskReactorService.
getInstance(Session) - Static method in interface com.snowflake.connectors.taskreactor.queue.cleaner.ExpiredWorkSelector: Returns a new instance of the default selector implementation.
getInstance(Session) - Static method in interface com.snowflake.connectors.taskreactor.queue.selector.WorkSelector: Gets a new instance of the default selector implementation.
getInstance(Session) - Static method in interface com.snowflake.connectors.taskreactor.registry.InstanceRegistryRepository: Creates a new instance of InstanceRegistryRepository
getInstance(Session) - Static method in interface com.snowflake.connectors.taskreactor.TaskReactorExistenceVerifier: Gets a new instance of the default task reactor existence verifier.
getInstance(Session) - Static method in class com.snowflake.connectors.taskreactor.TaskReactorInstanceActionExecutor: Returns a new instance of the default executor implementation.
getInstance(Session) - Static method in interface com.snowflake.connectors.taskreactor.TaskReactorInstanceComponentProvider: Creates a new instance of TaskReactorInstanceComponentProvider
getInstance(Session) - Static method in interface com.snowflake.connectors.util.snowflake.AccessTools: Returns a new instance of the default tools implementation.
getInstance(Session) - Static method in interface com.snowflake.connectors.util.snowflake.PrivilegeTools: Returns a new instance of the default tools implementation.
getInstance(Session) - Static method in interface com.snowflake.connectors.util.snowflake.TransactionManager: Creates new instance of Transaction Manager
getInstance(Session, ConnectorStatus) - Static method in interface com.snowflake.connectors.application.lifecycle.LifecycleService: Returns a new instance of the default service implementation.
getInstance(Session, Identifier) - Static method in class com.snowflake.connectors.application.integration.SchedulerTaskReactorOnIngestionScheduled: Returns a new instance of the default callback implementation.
getInstance(Session, Identifier) - Static method in interface com.snowflake.connectors.taskreactor.commands.processor.CommandsProcessor: Returns a new instance of the DefaultCommandsProcessor that is used by the Task Reactor.
getInstance(Session, Identifier) - Static method in class com.snowflake.connectors.taskreactor.commands.processor.executors.PauseInstanceExecutor: Creates new instance of PauseInstanceExecutor.
getInstance(Session, Identifier) - Static method in class com.snowflake.connectors.taskreactor.commands.processor.executors.ResumeInstanceExecutor: Creates new instance of ResumeInstanceExecutor
getInstance(Session, Identifier) - Static method in class com.snowflake.connectors.taskreactor.commands.processor.executors.UpdateWarehouseExecutor: Creates new instance of UpdateWarehouseExecutor
getInstance(Session, Identifier) - Static method in interface com.snowflake.connectors.taskreactor.commands.processor.ExecutorStrategies: Returns a new instance of the default ExecutorStrategies implementation used by the Task Reactor.
getInstance(Session, Identifier) - Static method in interface com.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository: Returns a new instance of the DefaultCommandsQueueRepository which is default implementation.
getInstance(Session, Identifier) - Static method in interface com.snowflake.connectors.taskreactor.config.ConfigRepository: Returns a new instance of the default repository implementation.
getInstance(Session, Identifier) - Static method in interface com.snowflake.connectors.taskreactor.queue.WorkItemQueue: Gets a new instance of the default queue implementation.
getInstance(Session, Identifier) - Static method in interface com.snowflake.connectors.taskreactor.worker.queue.WorkerQueue: Returns a new instance of the default queue implementation.
getInstance(Session, Identifier) - Static method in interface com.snowflake.connectors.taskreactor.worker.queue.WorkerQueueManager: Returns a new instance of the default manager implementation.
getInstance(Session, Identifier) - Static method in interface com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistry: Returns a new instance of the default repository implementation.
getInstance(Session, Identifier) - Static method in interface com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository: Returns a new instance of the default repository implementation.
getInstance(Session, Identifier) - Static method in interface com.snowflake.connectors.taskreactor.worker.WorkerCombinedView: Returns a new instance of the default view implementation.
getKind() - Method in class com.snowflake.connectors.common.table.TableProperties: TableProperties.kind property accessor
getLastAvailable(WorkerId) - Method in interface com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository: Returns the last timestamp when given worker was in available status
getLogger(Class<?>) - Static method in class com.snowflake.connectors.taskreactor.log.TaskReactorLogger: Creates a new logger for a given class
getMessage() - Method in class com.snowflake.connectors.common.response.ConnectorResponse: Returns the response message.
getMetadata() - Method in class com.snowflake.connectors.application.ingestion.process.IngestionProcess: Returns the process metadata.
getMetadata() - Method in class com.snowflake.connectors.application.observability.IngestionRun: Returns the ingestion run metadata.
getName() - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Returns the resource name.
getName() - Method in class com.snowflake.connectors.common.object.ObjectName: Returns the name of this object name.
getName() - Method in class com.snowflake.connectors.common.object.Reference: Returns the reference name.
getName() - Method in class com.snowflake.connectors.common.table.TableProperties: Returns String name of the table
getName() - Method in class com.snowflake.connectors.util.log.PrefixLogger
getObjectName() - Method in class com.snowflake.connectors.common.table.TableProperties: TableProperties.objectName property accessor
getOwner() - Method in class com.snowflake.connectors.common.table.TableProperties: TableProperties.owner property accessor
getParameter(String) - Method in class com.snowflake.connectors.common.task.TaskParameters
getParentId() - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Returns the id of the parent definition.
getPayload() - Method in class com.snowflake.connectors.taskreactor.commands.queue.Command: Returns the custom payload.
getPropertyName() - Method in enum com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationKey: Returns the name of the connector configuration property key.
getQuotedValue() - Method in class com.snowflake.connectors.common.object.Identifier: Returns the identifier value in a quoted form.
getResourceId() - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Returns the properties which identify the resource in the source system.
getResourceIngestionDefinitionId() - Method in class com.snowflake.connectors.application.ingestion.process.IngestionProcess: Returns the resource ingestion definition id.
getResourceMetadata() - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Returns the resource metadata.
getResponse() - Method in exception com.snowflake.connectors.common.exception.ConnectorException: Connector response of this exception.
getResponseCode() - Method in class com.snowflake.connectors.common.response.ConnectorResponse: Returns the response code.
getScheduleDefinition() - Method in class com.snowflake.connectors.application.ingestion.definition.IngestionConfiguration: Returns the schedule definition.
getScheduleType() - Method in class com.snowflake.connectors.application.ingestion.definition.IngestionConfiguration: Returns the schedule type.
getSchema() - Method in class com.snowflake.connectors.common.object.ObjectName: Returns the schema of this object name.
getSchema() - Method in class com.snowflake.connectors.common.object.SchemaName: Returns the schema of this schema name.
getSchemaName() - Method in class com.snowflake.connectors.common.object.ObjectName: Returns the schema name of this object name.
getSelectedItemsFromQueue() - Method in class com.snowflake.connectors.taskreactor.queue.selector.QueueItemSelector: Selects items from WorkItemQueue based on Task Reactor configuration.
getSeqNo() - Method in class com.snowflake.connectors.taskreactor.commands.queue.Command: Returns the sequence number.
getStartedAt() - Method in class com.snowflake.connectors.application.observability.IngestionRun: Returns the timestamp of the ingestion run start.
getStatus() - Method in class com.snowflake.connectors.application.ingestion.process.IngestionProcess: Returns the process status.
getStatus() - Method in class com.snowflake.connectors.application.observability.IngestionRun: Returns the ingestion status.
getStatus() - Method in class com.snowflake.connectors.application.status.FullConnectorStatus: Returns this connector status.
getStatusesExcluding(ConnectorStatus.ConnectorConfigurationStatus...) - Static method in enum com.snowflake.connectors.application.status.ConnectorStatus.ConnectorConfigurationStatus: Returns all possible configuration statuses excluding the ones provided.
getStatusFor(WorkerId) - Method in interface com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository: Returns the status of a worker with the specified id.
getStrategy(Command.CommandType) - Method in interface com.snowflake.connectors.taskreactor.commands.processor.ExecutorStrategies: Provides the proper implementation of CommandExecutor for the given value of Command.CommandType
getTroubleshootingData(long, long) - Method in class com.snowflake.connectors.taskreactor.troubleshooting.TaskReactorGetTroubleshootingDataService: Returns Task Reactor troubleshooting data.
getTroubleshootingData(Session, long, long) - Static method in class com.snowflake.connectors.taskreactor.troubleshooting.TaskReactorGetTroubleshootingDataService: Returns Task Reactor troubleshooting data.
getType() - Method in class com.snowflake.connectors.application.ingestion.process.IngestionProcess: Returns the process type.
getType() - Method in class com.snowflake.connectors.taskreactor.commands.queue.Command: Returns the command type.
getUnquotedValue() - Method in class com.snowflake.connectors.common.object.Identifier: Returns the identifier value in an unquoted form.
getUpdatedAt() - Method in class com.snowflake.connectors.application.observability.IngestionRun: Returns the timestamp of the last ingestion run update.
getValidationErrors() - Method in exception com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinitionValidationException: Returns a list of encountered validation errors.
getValue() - Method in class com.snowflake.connectors.common.object.Identifier: Returns the identifier value.
getValue() - Method in class com.snowflake.connectors.common.object.ObjectName: Returns the object name value.
getValue() - Method in class com.snowflake.connectors.common.object.Reference: Returns the reference value.
getValue() - Method in class com.snowflake.connectors.common.object.SchemaName: Returns the schema name value.
getVariantValue() - Method in class com.snowflake.connectors.common.object.Identifier: Returns the identifier value wrapped in a Snowpark Variant object.
getVariantValue() - Method in class com.snowflake.connectors.common.object.ObjectName: Returns the object name value as a Snowpark Variant object.
getWorkerCountWithStatuses(WorkerLifecycleStatus...) - Method in interface com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistry: Fetches amount of workers with given states.
getWorkerIds(WorkerLifecycleStatus...) - Method in interface com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistry: Fetches workers which are in given status.
getWorkersExecuting(String) - Method in class com.snowflake.connectors.taskreactor.worker.DefaultWorkerCombinedView
getWorkersExecuting(String) - Method in interface com.snowflake.connectors.taskreactor.worker.WorkerCombinedView: Returns the ids of workers executing ingestion of a specified resource.
getWorkersExecuting(List<String>) - Method in class com.snowflake.connectors.taskreactor.worker.DefaultWorkerCombinedView
getWorkersExecuting(List<String>) - Method in interface com.snowflake.connectors.taskreactor.worker.WorkerCombinedView: Returns the ids of workers executing ingestion of a specified resource.
getWorkersToDelete() - Method in class com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistryService: Returns ids of workers waiting for deletion.
getWorkersToProvision() - Method in class com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistryService: Returns ids of requested workers.
GLOBAL - com.snowflake.connectors.application.ingestion.definition.ScheduleType: The ingestion schedule will be derived from the global connector schedule.
GLOBAL_SCHEDULE - com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationKey: Global schedule for the connector data ingestion.
grantMonitorPrivilegeToRole(String) - Method in class com.snowflake.connectors.common.task.DefaultTaskRef
grantMonitorPrivilegeToRole(String) - Method in interface com.snowflake.connectors.common.task.TaskRef: Grants monitor privilege to given application role.

H

hasConfigurationStatus(ConnectorStatus.ConnectorConfigurationStatus) - Method in class com.snowflake.connectors.application.status.FullConnectorStatus: Returns whether this connector configuration status is equal to the provided one.
hasDatabaseAccess(Identifier) - Method in interface com.snowflake.connectors.util.snowflake.AccessTools: Returns whether the application has access to the specified database.
hashCode() - Method in class com.snowflake.connectors.application.ingestion.definition.EmptyImplementation
hashCode() - Method in class com.snowflake.connectors.application.ingestion.definition.IngestionConfiguration
hashCode() - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition
hashCode() - Method in class com.snowflake.connectors.application.ingestion.definition.VariantResource
hashCode() - Method in class com.snowflake.connectors.application.ingestion.process.IngestionProcess
hashCode() - Method in class com.snowflake.connectors.application.observability.IngestionRun
hashCode() - Method in class com.snowflake.connectors.application.status.FullConnectorStatus
hashCode() - Method in class com.snowflake.connectors.common.object.Identifier
hashCode() - Method in class com.snowflake.connectors.common.object.ObjectName
hashCode() - Method in class com.snowflake.connectors.common.object.Reference
hashCode() - Method in class com.snowflake.connectors.common.object.SchemaName
hashCode() - Method in class com.snowflake.connectors.common.response.ConnectorResponse
hashCode() - Method in class com.snowflake.connectors.common.table.TableProperties
hashCode() - Method in class com.snowflake.connectors.common.task.TaskProperties
hashCode() - Method in class com.snowflake.connectors.taskreactor.registry.TaskReactorInstance
hashCode() - Method in class com.snowflake.connectors.taskreactor.worker.queue.WorkItem
hashCode() - Method in class com.snowflake.connectors.taskreactor.worker.WorkerId
hasPrivilege(String) - Method in interface com.snowflake.connectors.util.snowflake.PrivilegeTools: Returns whether the application instance has been granted the specified account privilege.
hasSchemaAccess(SchemaName) - Method in interface com.snowflake.connectors.util.snowflake.AccessTools: Returns whether the application has access to the specified schema in the specified database.
hasSecretAccess(ObjectName) - Method in interface com.snowflake.connectors.util.snowflake.AccessTools: Returns whether the application has access to the specified secret.
hasStatus(ConnectorStatus...) - Method in class com.snowflake.connectors.application.status.FullConnectorStatus: Returns whether this connector status contains the provided ones.
hasWarehouseAccess(Identifier) - Method in interface com.snowflake.connectors.util.snowflake.AccessTools: Returns whether the application has access to the specified warehouse.

I

id - Variable in class com.snowflake.connectors.taskreactor.queue.QueueItem: Item id.
id - Variable in class com.snowflake.connectors.taskreactor.worker.queue.WorkItem: Surrogate key for the row in the input queue.
ID - Static variable in class com.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository.ColumnName: Representation of the ID column.
Identifier - Class in com.snowflake.connectors.common.object: Representation of a Snowflake object identifier.
Identifier.AutoQuoting - Enum in com.snowflake.connectors.common.object: Setting for auto quoting on identifier instance creation.
IN_PROGRESS - com.snowflake.connectors.application.observability.IngestionRun.IngestionStatus: Ingestion ongoing, in progress.
IN_PROGRESS - com.snowflake.connectors.taskreactor.worker.status.WorkerStatus: Worker class sets this status on the beginning of execution.
IN_PROGRESS - Static variable in class com.snowflake.connectors.application.ingestion.process.IngestionProcessStatuses: Status which means that the ingestion for a given process is being processed at the moment
InaccessibleWarehouseException - Exception in com.snowflake.connectors.application.configuration.warehouse: Exception thrown when the specified warehouse is inaccessible to the application.
InaccessibleWarehouseException(Identifier) - Constructor for exception com.snowflake.connectors.application.configuration.warehouse.InaccessibleWarehouseException: Creates a new InaccessibleWarehouseException.
INCREMENTAL - com.snowflake.connectors.application.ingestion.definition.IngestionStrategy: Increment previously ingested data with the new data.
info(String) - Method in class com.snowflake.connectors.util.log.PrefixLogger
info(String, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
info(String, Object...) - Method in class com.snowflake.connectors.util.log.PrefixLogger
info(String, Object, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
info(String, Throwable) - Method in class com.snowflake.connectors.util.log.PrefixLogger
info(Marker, String) - Method in class com.snowflake.connectors.util.log.PrefixLogger
info(Marker, String, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
info(Marker, String, Object...) - Method in class com.snowflake.connectors.util.log.PrefixLogger
info(Marker, String, Object, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
info(Marker, String, Throwable) - Method in class com.snowflake.connectors.util.log.PrefixLogger
Ingestion<STATE> - Interface in com.snowflake.connectors.taskreactor.worker.ingestion: Interface that should be implemented by users of task reactor and passed over to IngestionWorker instance.
ingestionCancelled(WorkItem, STATE) - Method in interface com.snowflake.connectors.taskreactor.worker.ingestion.Ingestion: This method is invoked in case when the ingestion gets cancelled in the middle of the execution.
IngestionConfiguration<C,D> - Class in com.snowflake.connectors.application.ingestion.definition: Representation of an ingestion configuration.
IngestionConfiguration() - Constructor for class com.snowflake.connectors.application.ingestion.definition.IngestionConfiguration: Creates an empty IngestionConfiguration.
IngestionConfiguration(String, IngestionStrategy, C, ScheduleType, String, D) - Constructor for class com.snowflake.connectors.application.ingestion.definition.IngestionConfiguration: Creates a new IngestionConfiguration.
IngestionConfigurationMapper - Class in com.snowflake.connectors.application.ingestion.definition: Mapper that is used for mapping the ingestion configurations as a raw Variant to the List of IngestionConfiguration objects.
IngestionConfigurationMapper() - Constructor for class com.snowflake.connectors.application.ingestion.definition.IngestionConfigurationMapper
IngestionProcess - Class in com.snowflake.connectors.application.ingestion.process: Representation of an ingestion process.
IngestionProcess(String, String, String, String, String, Instant, Instant, Variant) - Constructor for class com.snowflake.connectors.application.ingestion.process.IngestionProcess: Creates a new IngestionProcess.
IngestionProcessRepository - Interface in com.snowflake.connectors.application.ingestion.process: A repository for basic storage of the ingestion processes.
IngestionProcessStatuses - Class in com.snowflake.connectors.application.ingestion.process: Class which contains available statuses of IngestionProcess which are used by the SDK
IngestionProcessStatuses() - Constructor for class com.snowflake.connectors.application.ingestion.process.IngestionProcessStatuses
IngestionProcessUpdateException - Exception in com.snowflake.connectors.application.ingestion.process: Exception thrown when more or less than one ingestion process row is updated.
IngestionProcessUpdateException(Long) - Constructor for exception com.snowflake.connectors.application.ingestion.process.IngestionProcessUpdateException: Creates a new IngestionProcessUpdateException.
IngestionRun - Class in com.snowflake.connectors.application.observability: Representation of an ingestion run.
IngestionRun(String, String, String, IngestionRun.IngestionStatus, Instant, Instant, long, Instant, String, Variant) - Constructor for class com.snowflake.connectors.application.observability.IngestionRun: Creates a new IngestionRun.
IngestionRun.IngestionStatus - Enum in com.snowflake.connectors.application.observability: Ingestion run status.
IngestionRunRepository - Interface in com.snowflake.connectors.application.observability: A repository for basic storage of the ingestion run information.
IngestionRunRepository.Mode - Enum in com.snowflake.connectors.application.observability: Update mode for the number of rows ingested during an ingestion run.
IngestionRunsBadStatusException - Exception in com.snowflake.connectors.application.observability.exception: Exception thrown when an invalid status is provided when ending an ingestion run.
IngestionRunsBadStatusException(IngestionRun.IngestionStatus) - Constructor for exception com.snowflake.connectors.application.observability.exception.IngestionRunsBadStatusException: Creates a new IngestionRunsBadStatusException.
IngestionRunsReferenceException - Exception in com.snowflake.connectors.application.observability.exception: Exception thrown when insufficient ingestion information when starting an ingestion run.
IngestionRunsReferenceException() - Constructor for exception com.snowflake.connectors.application.observability.exception.IngestionRunsReferenceException: Creates a new IngestionRunsReferenceException.
IngestionRunsUpdateException - Exception in com.snowflake.connectors.application.observability.exception: Exception thrown when more or less than one ingestion run row is updated.
IngestionRunsUpdateException(Long) - Constructor for exception com.snowflake.connectors.application.observability.exception.IngestionRunsUpdateException: Creates a new IngestionRunsUpdateException.
IngestionStrategy - Enum in com.snowflake.connectors.application.ingestion.definition: Resource ingestion strategy.
IngestionWorker<T> - Class in com.snowflake.connectors.taskreactor.worker.ingestion: A worker executing an Ingestion.
initialState(WorkItem) - Method in interface com.snowflake.connectors.taskreactor.worker.ingestion.Ingestion: Used to initialize or load the initial state for the ingestion.
inputValidator - Variable in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerBuilder
InputValidator - Class in com.snowflake.connectors.common.exception.helper: Validator for input parameters in handlers.
InputValidator() - Constructor for class com.snowflake.connectors.common.exception.helper.InputValidator
insert(String, Variant) - Method in class com.snowflake.connectors.common.table.AppendOnlyKeyValueTable
insert(String, Variant) - Method in interface com.snowflake.connectors.common.table.AppendOnlyTable: Inserts the provided value under the provided key into this table.
insert(String, T) - Method in interface com.snowflake.connectors.common.state.AppendOnlyStateRepository: Appends the provided state value, with the provided key, to this repository.
insert(String, T) - Method in class com.snowflake.connectors.common.state.DefaultAppendOnlyStateRepository
insertWorkers(int) - Method in interface com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistry: Requests given amount of workers to be created.
INSTALLED - com.snowflake.connectors.application.status.ConnectorStatus.ConnectorConfigurationStatus: Connector has just been installed.
INSTANCE - Static variable in class com.snowflake.connectors.common.exception.context.EmptyExceptionContext: An instance of the EmptyExceptionContext.
instanceName() - Method in class com.snowflake.connectors.taskreactor.registry.TaskReactorInstance: Returns the instance name.
InstanceNotFoundException - Exception in com.snowflake.connectors.common.task: Exception thrown when a nonexistent Task Reactor instance name was provided.
InstanceNotFoundException(String) - Constructor for exception com.snowflake.connectors.common.task.InstanceNotFoundException: Creates a new InstanceNotFoundException.
InstanceRegistryRepository - Interface in com.snowflake.connectors.taskreactor.registry: Repository for managing TASK_REACTOR.INSTANCE_REGISTRY table
InstanceStreamService - Interface in com.snowflake.connectors.taskreactor: Deprecated.
InternalConnectorException - Exception in com.snowflake.connectors.common.exception: Exception thrown when an internal error has occurred.
InternalConnectorException(String) - Constructor for exception com.snowflake.connectors.common.exception.InternalConnectorException: Creates a new InternalConnectorException.
InternalConnectorException(String, Throwable) - Constructor for exception com.snowflake.connectors.common.exception.InternalConnectorException
InternalUpdateWarehouseCallback - Class in com.snowflake.connectors.application.configuration.warehouse: Default implementation of UpdateWarehouseCallback.
INTERVAL - com.snowflake.connectors.application.ingestion.definition.ScheduleType: Constant interval schedule, mathing the regex pattern of [1-9][0-9]*[dhm].
InvalidCommandException - Exception in com.snowflake.connectors.taskreactor.commands.processor.executors: Exception thrown when the particular value of the Command cannot be found during execution process.
InvalidCommandException(Command) - Constructor for exception com.snowflake.connectors.taskreactor.commands.processor.executors.InvalidCommandException: Creates a new InvalidCommandException.
InvalidCommandTypeException - Exception in com.snowflake.connectors.taskreactor.commands.queue: Exception thrown when the command type is not included in the predefined set represented by the Command.CommandType.
InvalidCommandTypeException(String, String) - Constructor for exception com.snowflake.connectors.taskreactor.commands.queue.InvalidCommandTypeException: Creates a InvalidCommandTypeException object with all fields initialized.
InvalidConnectorConfigurationStatusException - Exception in com.snowflake.connectors.application.status.exception: Exception thrown when an invalid connector configuration status is encountered.
InvalidConnectorConfigurationStatusException(ConnectorStatus.ConnectorConfigurationStatus, ConnectorStatus.ConnectorConfigurationStatus...) - Constructor for exception com.snowflake.connectors.application.status.exception.InvalidConnectorConfigurationStatusException: Creates a new InvalidConnectorStatusException.
InvalidConnectorResponseException - Exception in com.snowflake.connectors.common.response: Exception thrown when an invalid connector response is encountered.
InvalidConnectorResponseException(String) - Constructor for exception com.snowflake.connectors.common.response.InvalidConnectorResponseException: Creates a new InvalidConnectorResponseException.
InvalidConnectorStatusException - Exception in com.snowflake.connectors.application.status.exception: Exception thrown when an invalid connector status is encountered.
InvalidConnectorStatusException(ConnectorStatus, ConnectorStatus...) - Constructor for exception com.snowflake.connectors.application.status.exception.InvalidConnectorStatusException: Creates a new InvalidConnectorStatusException.
InvalidIdentifierException - Exception in com.snowflake.connectors.common.object: Exception thrown when an invalid identifier is encountered.
InvalidIdentifierException(String) - Constructor for exception com.snowflake.connectors.common.object.InvalidIdentifierException: Creates a new InvalidIdentifierException.
InvalidIngestionProcessException - Exception in com.snowflake.connectors.application.integration: Exception thrown when an invalid ingestion process is encountered.
InvalidIngestionProcessException(String) - Constructor for exception com.snowflake.connectors.application.integration.InvalidIngestionProcessException: Creates a new InvalidIngestionProcessException.
InvalidInputException - Exception in com.snowflake.connectors.common.exception: Exception thrown when an invalid input is encountered.
InvalidInputException(String) - Constructor for exception com.snowflake.connectors.common.exception.InvalidInputException: Creates a new InvalidInputException.
InvalidObjectNameException - Exception in com.snowflake.connectors.common.object: Exception thrown when an invalid object name is encountered.
InvalidObjectNameException(String) - Constructor for exception com.snowflake.connectors.common.object.InvalidObjectNameException: Creates a new InvalidObjectNameException.
InvalidReferenceException - Exception in com.snowflake.connectors.common.object: Exception thrown when an invalid reference is encountered.
InvalidReferenceException(String) - Constructor for exception com.snowflake.connectors.common.object.InvalidReferenceException: Creates a new InvalidReferenceException.
InvalidReferenceNameException - Exception in com.snowflake.connectors.common.object: Exception thrown when an invalid reference name is encountered.
InvalidReferenceNameException(String) - Constructor for exception com.snowflake.connectors.common.object.InvalidReferenceNameException: Creates a new InvalidReferenceNameException.
InvalidSchemaNameException - Exception in com.snowflake.connectors.common.object: Exception thrown when an invalid schema name is encountered.
InvalidSchemaNameException(String) - Constructor for exception com.snowflake.connectors.common.object.InvalidSchemaNameException: Creates a new InvalidSchemaNameException.
is(String) - Method in class com.snowflake.connectors.common.response.ConnectorResponse: Returns whether the code of this response is equal to the provided code.
isActive() - Method in class com.snowflake.connectors.taskreactor.registry.TaskReactorInstance: Returns whether the instance is active.
isAfter(ConnectorStatus.ConnectorConfigurationStatus) - Method in enum com.snowflake.connectors.application.status.ConnectorStatus.ConnectorConfigurationStatus: Returns whether this status is after the provided configuration status during the wizard phase.
isBefore(ConnectorStatus.ConnectorConfigurationStatus) - Method in enum com.snowflake.connectors.application.status.ConnectorStatus.ConnectorConfigurationStatus: Returns whether this status is before the provided configuration status during the wizard phase.
isDebugEnabled() - Method in class com.snowflake.connectors.util.log.PrefixLogger
isDebugEnabled(Marker) - Method in class com.snowflake.connectors.util.log.PrefixLogger
isDisabled() - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Returns whether the ingestion for the resource is disabled.
isEnabled() - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Returns whether the ingestion for the resource is enabled.
isErrorEnabled() - Method in class com.snowflake.connectors.util.log.PrefixLogger
isErrorEnabled(Marker) - Method in class com.snowflake.connectors.util.log.PrefixLogger
isFullyQualified() - Method in class com.snowflake.connectors.common.object.ObjectName: Returns whether this object name is fully qualified.
isFullyQualified() - Method in class com.snowflake.connectors.common.object.SchemaName: Returns whether this schema name is fully qualified.
isInfoEnabled() - Method in class com.snowflake.connectors.util.log.PrefixLogger
isInfoEnabled(Marker) - Method in class com.snowflake.connectors.util.log.PrefixLogger
isIngestionCompleted(WorkItem, STATE) - Method in interface com.snowflake.connectors.taskreactor.worker.ingestion.Ingestion: The worker calls Ingestion.performIngestion(WorkItem, Object) as long as the value returned from this method is true.
isInitialized() - Method in class com.snowflake.connectors.taskreactor.registry.TaskReactorInstance: Returns whether the instance is initialized.
isNotEmpty() - Method in class com.snowflake.connectors.common.task.TaskParameters
isNotOk() - Method in class com.snowflake.connectors.common.response.ConnectorResponse: Returns whether the code of this response is not equal to OK.
isOk() - Method in class com.snowflake.connectors.common.response.ConnectorResponse: Returns whether the code of this response is equal to OK.
isQuoted() - Method in class com.snowflake.connectors.common.object.Identifier: Returns whether the identifier is quoted.
isQuoted(String) - Static method in class com.snowflake.connectors.common.object.Identifier: Returns whether the provided String is a valid quoted identifier.
isTaskReactorConfigured() - Method in interface com.snowflake.connectors.taskreactor.TaskReactorExistenceVerifier: The method that check if the Task Reactor is used by the application.
isTraceEnabled() - Method in class com.snowflake.connectors.util.log.PrefixLogger
isTraceEnabled(Marker) - Method in class com.snowflake.connectors.util.log.PrefixLogger
isUnquoted() - Method in class com.snowflake.connectors.common.object.Identifier: Returns whether the identifier is unquoted.
isUnquoted(String) - Static method in class com.snowflake.connectors.common.object.Identifier: Returns whether the provided String is a valid unquoted identifier.
isValid(String) - Static method in class com.snowflake.connectors.common.object.Identifier: Returns whether the provided String matches is a valid identifier.
isValid(String) - Static method in class com.snowflake.connectors.common.object.ObjectName: Returns whether the provided String is a valid object name.
isValid(String) - Static method in class com.snowflake.connectors.common.object.Reference: Returns whether the provided String is a valid reference.
isValid(String) - Static method in class com.snowflake.connectors.common.object.SchemaName: Returns whether the provided String is a valid schema name.
isValidType(String) - Static method in enum com.snowflake.connectors.taskreactor.commands.queue.Command.CommandType
isWarnEnabled() - Method in class com.snowflake.connectors.util.log.PrefixLogger
isWarnEnabled(Marker) - Method in class com.snowflake.connectors.util.log.PrefixLogger

K

key() - Method in class com.snowflake.connectors.common.table.KeyValue: Returns the key of this key-value pair.
KeyNotFoundException - Exception in com.snowflake.connectors.common.table: Exception thrown when no object under provided key exists.
KeyNotFoundException(String) - Constructor for exception com.snowflake.connectors.common.table.KeyNotFoundException: Creates a new KeyNotFoundException.
KeyValue - Class in com.snowflake.connectors.common.table: A key-value pair representation.
KeyValue(String, Variant) - Constructor for class com.snowflake.connectors.common.table.KeyValue: Creates a new KeyValue with the provided key and value.
KeyValueStateRepository<T> - Interface in com.snowflake.connectors.common.state: A key-value repository for the connector state.
KeyValueTable - Interface in com.snowflake.connectors.common.table: A representation of a table which holds key-value pairs.

L

LifecycleService - Interface in com.snowflake.connectors.application.lifecycle: A service for basic management of the connector lifecycle processes.
lit(Object) - Static method in class com.snowflake.connectors.util.sql.SnowparkFunctions: Creates a Column expression for a literal value.
lit(Instant) - Static method in class com.snowflake.connectors.util.sql.SnowparkFunctions: Deprecated.
log(E) - Method in interface com.snowflake.connectors.common.exception.helper.ExceptionLogger: Logs the provided exception.

M

map(Variant) - Static method in class com.snowflake.connectors.application.ingestion.definition.IngestionConfigurationMapper: Mapper main method that maps raw Variant to the List of IngestionConfiguration objects.
map(E) - Method in interface com.snowflake.connectors.common.exception.helper.ExceptionMapper: Maps the provided exception into an instance of ConnectorException.
mapToVariant(T) - Static method in class com.snowflake.connectors.util.variant.VariantMapper: Maps the provided value to Variant.
mapVariant(Variant, JavaType) - Static method in class com.snowflake.connectors.util.variant.VariantMapper: Maps the provided Variant to an instance of the provided JavaType.
mapVariant(Variant, Class<T>) - Static method in class com.snowflake.connectors.util.variant.VariantMapper: Maps the provided Variant to an instance of the provided class.
MergeStatementValidator - Class in com.snowflake.connectors.util.sql: Validator for merge statements executed in Snowflake.
MutableExceptionContext - Class in com.snowflake.connectors.common.exception.context: A mutable implementation of ExceptionContext.
MutableExceptionContext() - Constructor for class com.snowflake.connectors.common.exception.context.MutableExceptionContext

N

name() - Method in class com.snowflake.connectors.common.task.DefaultTaskRef
name() - Method in class com.snowflake.connectors.common.task.TaskProperties: Returns the task object name.
name() - Method in interface com.snowflake.connectors.common.task.TaskRef
NonexistentProcedureCallException - Exception in com.snowflake.connectors.util.sql: Exception thrown when a non-existent SQL procedure is called.
NonexistentProcedureCallException(String) - Constructor for exception com.snowflake.connectors.util.sql.NonexistentProcedureCallException: Creates a new NonexistentProcedureCallException.
NOT_FOUND - com.snowflake.connectors.application.observability.IngestionRun.IngestionStatus: Ingestion resource not found in the source system.

O

ObjectName - Class in com.snowflake.connectors.common.object: Representation of a Snowflake object name.
of(Session, ObjectName) - Static method in interface com.snowflake.connectors.common.task.TaskRef: Returns a new instance of the default implementation for TaskRef.
of(String) - Static method in class com.snowflake.connectors.common.object.Reference: Creates a new reference instance from the provided String.
onIngestionFinished(String, Variant) - Method in class com.snowflake.connectors.application.integration.SchedulerTaskReactorOnIngestionFinishedCallback
onIngestionFinished(String, Variant) - Method in interface com.snowflake.connectors.application.scheduler.OnIngestionFinishedCallback: Action executed when the next ingestion is finished.
onIngestionFinished(String, Variant) - Method in interface com.snowflake.connectors.taskreactor.OnIngestionFinishedCallback: Method which is called when Task Reactor finishes an ingestion
OnIngestionFinishedCallback - Interface in com.snowflake.connectors.application.scheduler: Callback called when ingestion has been finished.
OnIngestionFinishedCallback - Interface in com.snowflake.connectors.taskreactor: Callback called when ingestion is finished.
onIngestionScheduled(String) - Method in class com.snowflake.connectors.application.integration.SchedulerTaskReactorOnIngestionScheduled
onIngestionScheduled(String) - Method in interface com.snowflake.connectors.application.scheduler.OnIngestionScheduledCallback: Action executed when the next scheduler iteration is run.
OnIngestionScheduledCallback - Interface in com.snowflake.connectors.application.scheduler: Callback called when the next scheduler iteration is run.
OPERATIONAL_WAREHOUSE - com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationKey: Operational warehouse used by the connector.
OVERWRITE - com.snowflake.connectors.application.observability.IngestionRunRepository.Mode: Overwrite the currently persisted number of rows with the new value.

P

parameters() - Method in class com.snowflake.connectors.common.task.TaskDefinition: Returns the additional task parameters.
PAUSE_INSTANCE - com.snowflake.connectors.taskreactor.commands.queue.Command.CommandType
pauseAllInstances() - Method in class com.snowflake.connectors.taskreactor.lifecycle.PauseTaskReactorService: Pauses all Task Reactor instances defined in Instance Registry
pauseConnector() - Method in class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandler: Executes the main logic of the handler, with logging using withExceptionLogging.
pauseConnector(Session) - Static method in class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandler: Default handler method for the PUBLIC.PAUSE_CONNECTOR procedure.
PauseConnectorCallback - Interface in com.snowflake.connectors.application.lifecycle.pause: Callback called during the PauseConnectorHandler execution, may be used to provide custom pausing logic.
PauseConnectorHandler - Class in com.snowflake.connectors.application.lifecycle.pause: Handler for the connector pausing process.
PauseConnectorHandlerBuilder - Class in com.snowflake.connectors.application.lifecycle.pause: Builder for the PauseConnectorHandler.
PauseConnectorHandlerBuilder(Session) - Constructor for class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandlerBuilder: Creates a new PauseConnectorHandlerBuilder.
PauseConnectorSdkCallback - Interface in com.snowflake.connectors.application.lifecycle.pause: Callback called during the PauseConnectorHandler execution, may be used to provide custom pausing logic required by the sdk.
PauseConnectorStateValidator - Interface in com.snowflake.connectors.application.lifecycle.pause: Validator called during the PauseConnectorHandler execution, may be used to provide custom connector state validation.
PAUSED - com.snowflake.connectors.application.status.ConnectorStatus: Connector is paused.
pauseInstance(Identifier) - Method in class com.snowflake.connectors.taskreactor.api.PauseInstanceHandler: Executes the main logic of the handler, with logging using withExceptionLogging.
pauseInstance(Identifier) - Method in class com.snowflake.connectors.taskreactor.lifecycle.PauseTaskReactorService: Pauses a given Task Reactor instance
pauseInstance(Session, String) - Static method in class com.snowflake.connectors.taskreactor.api.PauseInstanceHandler: Default handler method for the TASK_REACTOR.PAUSE_INSTANCE procedure.
PauseInstanceExecutor - Class in com.snowflake.connectors.taskreactor.commands.processor.executors: Executor of the PAUSE_INSTANCE command.
PauseInstanceHandler - Class in com.snowflake.connectors.taskreactor.api: Handler for the Task Reactor instance pausing process.
PauseInstanceHandlerBuilder - Class in com.snowflake.connectors.taskreactor.api: Builder for the PauseInstanceHandler.
PauseInstanceHandlerBuilder(Session) - Constructor for class com.snowflake.connectors.taskreactor.api.PauseInstanceHandlerBuilder: Creates a new PauseInstanceHandlerBuilder.
PauseTaskReactorService - Class in com.snowflake.connectors.taskreactor.lifecycle: Service which is used to start the process of pausing the Task Reactor.
PAUSING - com.snowflake.connectors.application.status.ConnectorStatus: Connector is being paused.
payload - Variable in class com.snowflake.connectors.taskreactor.worker.queue.WorkItem: Value of the WORKER_PAYLOAD column inserted to the input queue.
PAYLOAD - Static variable in class com.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository.ColumnName: Representation of the PAYLOAD column.
performIngestion(WorkItem, STATE) - Method in interface com.snowflake.connectors.taskreactor.worker.ingestion.Ingestion: This is where the actual data ingestion should happen.
performWork(WorkItem) - Method in class com.snowflake.connectors.taskreactor.worker.ingestion.IngestionWorker
performWork(WorkItem) - Method in class com.snowflake.connectors.taskreactor.worker.simpletask.SimpleTaskWorker
performWork(WorkItem) - Method in class com.snowflake.connectors.taskreactor.worker.Worker
PostCreateResourceCallback - Interface in com.snowflake.connectors.application.ingestion.create: Callback which is called at the end of creating a resource
PostDisableResourceCallback - Interface in com.snowflake.connectors.application.ingestion.disable: Callback which is called at the end of disabling a resource
PostEnableResourceCallback - Interface in com.snowflake.connectors.application.ingestion.enable: Callback which is called at the end of enabling a resource
postIngestion(WorkItem, STATE) - Method in interface com.snowflake.connectors.taskreactor.worker.ingestion.Ingestion: Logic that needs to be executed after ingestion ends.
PostUpdateResourceCallback - Interface in com.snowflake.connectors.application.ingestion.update: Callback which is called at the end of updating a resource
PreCreateResourceCallback - Interface in com.snowflake.connectors.application.ingestion.create: Callback which is called before executing the main logic of creating a resource
PreDisableResourceCallback - Interface in com.snowflake.connectors.application.ingestion.disable: Callback which is called at the beginning of disabling a resource
PreEnableResourceCallback - Interface in com.snowflake.connectors.application.ingestion.enable: Callback which is called before executing the main logic of enabling a resource
PrefixLogger - Class in com.snowflake.connectors.util.log: Logger which adds a given prefix to all logged messages
PrefixLogger(String, Logger) - Constructor for class com.snowflake.connectors.util.log.PrefixLogger
preIngestion(WorkItem) - Method in interface com.snowflake.connectors.taskreactor.worker.ingestion.Ingestion: Logic that needs to be executed before ingestion begins.
PREREQUISITES_DONE - com.snowflake.connectors.application.status.ConnectorStatus.ConnectorConfigurationStatus: Prerequisites wizard phase has been completed.
PreUpdateResourceCallback - Interface in com.snowflake.connectors.application.ingestion.update: Callback that is called before executing the main logic of resource updating procedure
PrivilegeTools - Interface in com.snowflake.connectors.util.snowflake: Set of basic privileges/grants utilities.
PROCEDURE - com.snowflake.connectors.taskreactor.WorkSelectorType: Work selector provided using a procedure.
processCommands() - Method in interface com.snowflake.connectors.taskreactor.commands.processor.CommandsProcessor: Processes commands from the COMMANDS_QUEUE table.
processCommands() - Method in class com.snowflake.connectors.taskreactor.commands.processor.DefaultCommandsProcessor: Fetches all pending, valid commands from the commands queue and executes them using proper CommandExecutor defined by the implementation of the ExecutorStrategies.
properties() - Method in class com.snowflake.connectors.common.task.TaskDefinition: Returns the task properties.
PROVISIONING - com.snowflake.connectors.taskreactor.worker.registry.WorkerLifecycleStatus: Set by the Dispatcher when starting creating worker objects.
push(QueueItem, WorkerId) - Method in interface com.snowflake.connectors.taskreactor.worker.queue.WorkerQueue: Pushes provided item to the queue.
push(WorkItem) - Method in interface com.snowflake.connectors.taskreactor.queue.WorkItemQueue: Pushes singular work item to the queue.
push(List<WorkItem>) - Method in class com.snowflake.connectors.taskreactor.queue.DefaultWorkItemQueue
push(List<WorkItem>) - Method in interface com.snowflake.connectors.taskreactor.queue.WorkItemQueue: Pushes group of work items to the queue.
put(String, String) - Method in class com.snowflake.connectors.common.exception.context.MutableExceptionContext: Puts a new key-value pair into the properties of this context.

Q

QUEUE_STREAM - Static variable in class com.snowflake.connectors.taskreactor.ComponentNames
QUEUE_TABLE - Static variable in class com.snowflake.connectors.taskreactor.ComponentNames
QueueItem - Class in com.snowflake.connectors.taskreactor.queue: Representation of an item inserted into a task reactor queue.
QueueItemCleaner - Class in com.snowflake.connectors.taskreactor.queue.cleaner: Class responsible for removal of obsolete items from the WorkItemQueue.
QueueItemDeserializer - Class in com.snowflake.connectors.taskreactor.queue: Jackson JSON deserializer for QueueItem.
QueueItemDeserializer() - Constructor for class com.snowflake.connectors.taskreactor.queue.QueueItemDeserializer
QueueItemSelector - Class in com.snowflake.connectors.taskreactor.queue.selector: Class responsible for selection of items from the WorkItemQueue.
QueueItemSerializer - Class in com.snowflake.connectors.taskreactor.queue: Jackson JSON serializer for QueueItem.
QueueItemSerializer() - Constructor for class com.snowflake.connectors.taskreactor.queue.QueueItemSerializer
quoted(String) - Static method in class com.snowflake.connectors.util.sql.SqlTools: Wraps input text with double quotes, e.g.

R

ReadOnlyKeyValueTable - Class in com.snowflake.connectors.common.table: Read-only implementation of KeyValueTable.
ReadOnlyKeyValueTable(Session, String) - Constructor for class com.snowflake.connectors.common.table.ReadOnlyKeyValueTable: Creates a new ReadOnlyKeyValueTable, backed by the provided Snowflake table.
reconcileWorkersNumber() - Method in class com.snowflake.connectors.taskreactor.worker.WorkerManager: Recalculates the number of active workers.
RecordsLimitExceededException - Exception in com.snowflake.connectors.common.table: Exception thrown when too many records are inserted/updated.
RecordsLimitExceededException(int) - Constructor for exception com.snowflake.connectors.common.table.RecordsLimitExceededException: Creates a new RecordsLimitExceededException.
recreate(List<WorkerId>) - Method in class com.snowflake.connectors.taskreactor.worker.DefaultWorkerCombinedView
recreate(List<WorkerId>) - Method in interface com.snowflake.connectors.taskreactor.worker.WorkerCombinedView: Replaces current view, with actual state of queues.
recreateStreams(Identifier) - Method in interface com.snowflake.connectors.taskreactor.InstanceStreamService: Deprecated.

The method recreates task reactor instance streams to extend their staleness time.
recreateStreamsIfRequired(Identifier) - Method in interface com.snowflake.connectors.taskreactor.InstanceStreamService: Deprecated.

The method recreate task reactor instance streams to extend their staleness time only when the appropriate time passed since the last recreation.
Reference - Class in com.snowflake.connectors.common.object: Representation of a Snowflake object reference.
removeStatusFor(WorkerId) - Method in interface com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository: Removes the status for a worker with the specified id.
REQUESTED - com.snowflake.connectors.taskreactor.worker.registry.WorkerLifecycleStatus: WorkerOrchestrator sets this status right after the user increased the number of workers.
RequiredPrivilegesMissingException - Exception in com.snowflake.connectors.util.snowflake: Exception thrown when not all required privileges are granted to the application instance.
RequiredPrivilegesMissingException(String...) - Constructor for exception com.snowflake.connectors.util.snowflake.RequiredPrivilegesMissingException: Creates a new RequiredPrivilegesMissingException.
requireNonNull(Variant, String) - Static method in class com.snowflake.connectors.common.exception.helper.InputValidator: Validates whether given input parameter is valid.
ResourceCreationException - Exception in com.snowflake.connectors.application.ingestion.create: Exception thrown when creation of a resource failed.
ResourceCreationException(Throwable) - Constructor for exception com.snowflake.connectors.application.ingestion.create.ResourceCreationException
ResourceDisablingException - Exception in com.snowflake.connectors.application.ingestion.disable: Exception thrown when disabling of a resource failed.
ResourceDisablingException(Throwable) - Constructor for exception com.snowflake.connectors.application.ingestion.disable.ResourceDisablingException
ResourceEnablingException - Exception in com.snowflake.connectors.application.ingestion.enable: Exception thrown when enabling of a resource failed.
ResourceEnablingException(Throwable) - Constructor for exception com.snowflake.connectors.application.ingestion.enable.ResourceEnablingException
resourceId - Variable in class com.snowflake.connectors.taskreactor.queue.QueueItem: Ingested resource id.
resourceId - Variable in class com.snowflake.connectors.taskreactor.worker.queue.WorkItem: Value of the RESOURCE_ID column inserted to the input queue.
ResourceIngestionDefinition<I,M,C,D> - Class in com.snowflake.connectors.application.ingestion.definition: Base class of a resource ingestion definition.
ResourceIngestionDefinition() - Constructor for class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Creates an empty ResourceIngestionDefinition.
ResourceIngestionDefinition(String, String, boolean, String, I, M, List<IngestionConfiguration<C, D>>) - Constructor for class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Creates a new ResourceIngestionDefinition.
ResourceIngestionDefinitionInstantiationException - Exception in com.snowflake.connectors.application.ingestion.definition: Exception thrown when instantiation of an ingestion definition class failed.
ResourceIngestionDefinitionInstantiationException(String, Throwable) - Constructor for exception com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinitionInstantiationException: Creates a new ResourceIngestionDefinitionInstantiationException.
ResourceIngestionDefinitionRepository<R extends ResourceIngestionDefinition<?,?,?,?>> - Interface in com.snowflake.connectors.application.ingestion.definition: A repository for basic storage of the resource ingestion definitions, created for instances of the specified ResourceIngestionDefinition implementations.
ResourceIngestionDefinitionRepositoryFactory - Class in com.snowflake.connectors.application.ingestion.definition: Factory for instances of ResourceIngestionDefinitionRepository.
ResourceIngestionDefinitionRepositoryFactory() - Constructor for class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinitionRepositoryFactory
ResourceIngestionDefinitionValidationException - Exception in com.snowflake.connectors.application.ingestion.definition: Exception thrown when validation of resource ingestion definition fails.
ResourceIngestionDefinitionValidationException(List<String>) - Constructor for exception com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinitionValidationException: Creates a new ResourceIngestionDefinitionValidationException.
ResourceUpdateException - Exception in com.snowflake.connectors.application.ingestion.update: Exception thrown when updating of a resource failed.
ResourceUpdateException(Throwable) - Constructor for exception com.snowflake.connectors.application.ingestion.update.ResourceUpdateException: Creates a new instance of the ResourceUpdateException
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationNotFoundException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationNotFoundException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationParsingException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.application.configuration.warehouse.InaccessibleWarehouseException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.application.configuration.warehouse.WarehouseAlreadyUsedException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.application.status.exception.ConnectorStatusNotFoundException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.application.status.exception.InvalidConnectorConfigurationStatusException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.application.status.exception.InvalidConnectorStatusException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.common.exception.InternalConnectorException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.common.exception.InvalidInputException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.common.exception.UnknownConnectorException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.common.object.InvalidIdentifierException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.common.object.InvalidObjectNameException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.common.object.InvalidReferenceException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.common.object.InvalidReferenceNameException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.common.object.InvalidSchemaNameException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.common.response.InvalidConnectorResponseException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.common.table.DuplicateKeyException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.common.table.KeyNotFoundException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.common.table.RecordsLimitExceededException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.common.task.InstanceNotFoundException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.common.task.TaskCreationException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.common.task.TaskNotFoundException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.common.task.TaskReactorInstanceIsActiveException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.taskreactor.queue.WorkItemQueueException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.taskreactor.worker.WorkerJobCancelledException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.util.snowflake.RequiredPrivilegesMissingException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.util.sql.NonexistentProcedureCallException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.util.sql.UnknownSqlException: Error code of the exception, used in the underlying response.
RESPONSE_CODE - Static variable in exception com.snowflake.connectors.util.variant.VariantMapperException: Error code of the exception, used in the underlying response.
resume() - Method in class com.snowflake.connectors.common.task.DefaultTaskRef
resume() - Method in interface com.snowflake.connectors.common.task.TaskRef: Resumes suspended referenced task.
RESUME_INSTANCE - com.snowflake.connectors.taskreactor.commands.queue.Command.CommandType
resumeAllInstances() - Method in class com.snowflake.connectors.taskreactor.lifecycle.ResumeTaskReactorService: Resumes all Task Reactor instances defined in Instance Registry
resumeConnector() - Method in class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandler: Executes the main logic of the handler, with logging using withExceptionLogging.
resumeConnector(Session) - Static method in class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandler: Default handler method for the PUBLIC.RESUME_CONNECTOR procedure.
ResumeConnectorCallback - Interface in com.snowflake.connectors.application.lifecycle.resume: Callback called during the ResumeConnectorHandler execution, may be used to provide custom resuming logic.
ResumeConnectorHandler - Class in com.snowflake.connectors.application.lifecycle.resume: Handler for the connector resuming process.
ResumeConnectorHandlerBuilder - Class in com.snowflake.connectors.application.lifecycle.resume: Builder for the ResumeConnectorHandler.
ResumeConnectorSdkCallback - Interface in com.snowflake.connectors.application.lifecycle.resume: Callback called during the ResumeConnectorHandler execution, may be used to provide custom resuming logic required by the sdk.
ResumeConnectorStateValidator - Interface in com.snowflake.connectors.application.lifecycle.resume: Validator called during the ResumeConnectorHandler execution, may be used to provide custom connector state validation.
resumeDispatcherTask() - Method in class com.snowflake.connectors.taskreactor.dispatcher.DispatcherTaskManager: Resumes dispatcher task
resumeIfExists() - Method in class com.snowflake.connectors.common.task.DefaultTaskRef
resumeIfExists() - Method in interface com.snowflake.connectors.common.task.TaskRef: Resumes suspended referenced task if it exists.
resumeInstance(Identifier) - Method in class com.snowflake.connectors.taskreactor.api.ResumeInstanceHandler: Executes the main logic of the handler, with logging using withExceptionLogging.
resumeInstance(Identifier) - Method in class com.snowflake.connectors.taskreactor.lifecycle.ResumeTaskReactorService: Resumes a given Task Reactor instance
resumeInstance(Session, String) - Static method in class com.snowflake.connectors.taskreactor.api.ResumeInstanceHandler: Default handler method for the TASK_REACTOR.RESUME_INSTANCE procedure.
ResumeInstanceExecutor - Class in com.snowflake.connectors.taskreactor.commands.processor.executors: Executor of the RESUME_INSTANCE command.
ResumeInstanceHandler - Class in com.snowflake.connectors.taskreactor.api: Handler for the Task Reactor instance resuming process.
ResumeInstanceHandlerBuilder - Class in com.snowflake.connectors.taskreactor.api
ResumeInstanceHandlerBuilder(Session) - Constructor for class com.snowflake.connectors.taskreactor.api.ResumeInstanceHandlerBuilder: Creates a new ResumeInstanceHandlerBuilder.
ResumeTaskReactorService - Class in com.snowflake.connectors.taskreactor.lifecycle: Service which is used to start the process of resuming the Task Reactor which was paused.
resumeWorkerTask(WorkerId) - Method in class com.snowflake.connectors.taskreactor.worker.WorkerTaskManager: Resumes a worker task if it exists.
ROLLBACK_CODE - Static variable in interface com.snowflake.connectors.application.lifecycle.LifecycleService: Response code signifying a rollback operation has occurred
run() - Method in class com.snowflake.connectors.taskreactor.worker.Worker: Generic body of the worker execution job.
runIteration() - Method in class com.snowflake.connectors.application.scheduler.RunSchedulerIterationHandler: Executes the main logic of the handler, with logging using withExceptionLogging.
runIteration() - Method in class com.snowflake.connectors.application.scheduler.Scheduler: Runs the next scheduler iteration.
runIteration(Session) - Static method in class com.snowflake.connectors.application.scheduler.RunSchedulerIterationHandler: Default handler method for the PUBLIC.RUN_SCHEDULER_ITERATION procedure.
RunSchedulerIterationHandler - Class in com.snowflake.connectors.application.scheduler: Handler for running a scheduler iteration.
RunSchedulerIterationHandlerBuilder - Class in com.snowflake.connectors.application.scheduler: Builder for the RunSchedulerIterationHandler.
RunSchedulerIterationHandlerBuilder(Session) - Constructor for class com.snowflake.connectors.application.scheduler.RunSchedulerIterationHandlerBuilder: Creates a new RunSchedulerIterationHandlerBuilder.

S

save(IngestionProcess) - Method in interface com.snowflake.connectors.application.ingestion.process.CrudIngestionProcessRepository: Saves the specified ingestion process.
save(IngestionProcess) - Method in class com.snowflake.connectors.application.ingestion.process.DefaultIngestionProcessRepository
save(IngestionRun) - Method in interface com.snowflake.connectors.application.observability.CrudIngestionRunRepository: Saves the provided ingestion run.
save(IngestionRun) - Method in class com.snowflake.connectors.application.observability.DefaultIngestionRunRepository
save(Collection<IngestionProcess>) - Method in interface com.snowflake.connectors.application.ingestion.process.CrudIngestionProcessRepository: Saves the specified ingestion processes.
save(Collection<IngestionProcess>) - Method in class com.snowflake.connectors.application.ingestion.process.DefaultIngestionProcessRepository
save(R) - Method in interface com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinitionRepository: Saves the specified resource ingestion definition.
saveMany(List<R>) - Method in interface com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinitionRepository: Saves the specified resource ingestion definitions.
schedule() - Method in class com.snowflake.connectors.common.task.TaskProperties: Returns the task schedule.
SCHEDULED - Static variable in class com.snowflake.connectors.application.ingestion.process.IngestionProcessStatuses: Status which means that the next iteration of ingestion for a given process is scheduled and the process will be picked by the scheduler soon
SCHEDULED_FOR_CANCELLATION - com.snowflake.connectors.taskreactor.worker.status.WorkerStatus: If a new row with cancelOngoingExecution: true flag is added to the input queue, worker gets this status assigned by the Dispatcher.
Scheduler - Class in com.snowflake.connectors.application.scheduler: Ingestion process scheduler.
Scheduler(CrudIngestionProcessRepository, OnIngestionScheduledCallback) - Constructor for class com.snowflake.connectors.application.scheduler.Scheduler: Creates a new Scheduler.
SCHEDULER_TASK - Static variable in class com.snowflake.connectors.application.scheduler.Scheduler
SchedulerCreationException - Exception in com.snowflake.connectors.application.scheduler: Exception thrown when scheduler creation failed.
SchedulerCreationException(String) - Constructor for exception com.snowflake.connectors.application.scheduler.SchedulerCreationException: Creates a new SchedulerCreationException.
SchedulerCreator - Interface in com.snowflake.connectors.application.scheduler: Creator for instances of Scheduler.
SchedulerTaskReactorOnIngestionFinishedCallback - Class in com.snowflake.connectors.application.integration: Task reactor compatible implementation of OnIngestionFinishedCallback.
SchedulerTaskReactorOnIngestionFinishedCallback(OnIngestionFinishedCallback) - Constructor for class com.snowflake.connectors.application.integration.SchedulerTaskReactorOnIngestionFinishedCallback: Creates a new SchedulerTaskReactorOnIngestionFinishedCallback.
SchedulerTaskReactorOnIngestionScheduled - Class in com.snowflake.connectors.application.integration: Task reactor compatible implementation of OnIngestionScheduledCallback.
SchedulerTaskReactorOnIngestionScheduled(IngestionProcessRepository, ResourceIngestionDefinitionRepository<VariantResource>, Session, Identifier) - Constructor for class com.snowflake.connectors.application.integration.SchedulerTaskReactorOnIngestionScheduled: Creates a new SchedulerTaskReactorOnIngestionScheduled.
ScheduleType - Enum in com.snowflake.connectors.application.ingestion.definition: Type of the ingestion schedule.
schema() - Method in class com.snowflake.connectors.taskreactor.config.TaskReactorConfig: Returns the Task Reactor instance schema.
SchemaName - Class in com.snowflake.connectors.common.object: Representation of a Snowflake schema name.
sdkCallback - Variable in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerBuilder
SdkClock - Interface in com.snowflake.connectors.util.time: SDK abstraction for the Java Clock.
selectItemsFromView(String) - Method in interface com.snowflake.connectors.taskreactor.queue.selector.WorkSelector: Selects all items returned by the view.
selectItemsUsingProcedure(List<QueueItem>, String) - Method in interface com.snowflake.connectors.taskreactor.queue.selector.WorkSelector: Calls selector procedure with provided queueItems.
SEQ_NO - Static variable in class com.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository.ColumnName: Representation of the SEQ_NO column.
serialize(QueueItem, JsonGenerator, SerializerProvider) - Method in class com.snowflake.connectors.taskreactor.queue.QueueItemSerializer
SET_WORKERS_NUMBER - com.snowflake.connectors.taskreactor.commands.queue.Command.CommandType
setActive(Identifier) - Method in interface com.snowflake.connectors.taskreactor.registry.InstanceRegistryRepository: Changes isActive flag to true for given instance
setConfigurationStatus(ConnectorStatus.ConnectorConfigurationStatus) - Method in class com.snowflake.connectors.application.status.FullConnectorStatus: Sets this connector configuration status.
setConnectionConfiguration(Session, Variant) - Static method in class com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationHandler: Default handler method for the PUBLIC.SET_CONNECTION_CONFIGURATION procedure.
setConnectionConfiguration(Variant) - Method in class com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationHandler: Executes the main logic of the handler, with logging using withExceptionLogging.
setDisabled() - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Sets enabled flag to false
setEnabled() - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Sets enabled flag to true
setEnabled(boolean) - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Sets whether the ingestion for the resource is enabled.
setId(String) - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Sets the resource ingestion definition id.
setInactive(Identifier) - Method in interface com.snowflake.connectors.taskreactor.registry.InstanceRegistryRepository: Changes isActive flag to false for given instance
setIngestionConfigurations(List<IngestionConfiguration<C, D>>) - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Sets the ingestion configurations.
setName(String) - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Sets the resource name.
setParentId(String) - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Sets the id of the parent definition.
setResourceId(I) - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Sets the properties which identify the resource in the source system.
setResourceMetadata(M) - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition: Sets the resource metadata
setStatus(ConnectorStatus) - Method in class com.snowflake.connectors.application.status.FullConnectorStatus: Sets this connector status.
setTaskReactorInstanceNameSpanAttribute(Identifier) - Static method in class com.snowflake.connectors.taskreactor.telemetry.TaskReactorTelemetry: Sets the value of the Task Reactor instance name span attribute.
setWorkerIdSpanAttribute(WorkerId) - Static method in class com.snowflake.connectors.taskreactor.telemetry.TaskReactorTelemetry: Sets the value of the worker id span attribute.
setWorkersNumber(int) - Method in class com.snowflake.connectors.taskreactor.worker.registry.WorkerOrchestrator: Sets the number of workers for the Task Reactor instance.
setWorkersNumber(Session, int, String) - Static method in class com.snowflake.connectors.taskreactor.api.SetWorkersNumberHandler: Default handler method for the TASK_REACTOR.SET_WORKERS_NUMBER procedure.
SetWorkersNumberExecutor - Class in com.snowflake.connectors.taskreactor.commands.processor.executors: Executor of the SET_WORKERS_NUMBER command.
SetWorkersNumberExecutor() - Constructor for class com.snowflake.connectors.taskreactor.commands.processor.executors.SetWorkersNumberExecutor
SetWorkersNumberHandler - Class in com.snowflake.connectors.taskreactor.api: Handler for the Task Reactor worker number update.
SetWorkersNumberHandler() - Constructor for class com.snowflake.connectors.taskreactor.api.SetWorkersNumberHandler
setWorkersStatus(WorkerLifecycleStatus, List<WorkerId>) - Method in interface com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistry: Changes status of workers to provided one.
shouldCancel() - Method in class com.snowflake.connectors.taskreactor.worker.Worker
showTables(SchemaName) - Method in class com.snowflake.connectors.common.table.DefaultTableLister: Returns list of tables for a given schema
showTables(SchemaName) - Method in class com.snowflake.connectors.common.table.DefaultTableRepository: Returns list of tables for a given schema
showTables(SchemaName) - Method in interface com.snowflake.connectors.common.table.TableLister: Returns list of tables for a given schema
showTables(SchemaName, String) - Method in class com.snowflake.connectors.common.table.DefaultTableLister: Returns list of tables for a given schema with additional filter expression.
showTables(SchemaName, String) - Method in class com.snowflake.connectors.common.table.DefaultTableRepository: Returns list of tables for a given schema with additional filter expression.
showTables(SchemaName, String) - Method in interface com.snowflake.connectors.common.table.TableLister: Returns list of tables for a given schema with additional filter expression.
showTask(ObjectName) - Method in class com.snowflake.connectors.common.task.DefaultTaskLister
showTask(ObjectName) - Method in interface com.snowflake.connectors.common.task.TaskLister: Fetches a task for a given object name.
showTasks(String) - Method in class com.snowflake.connectors.common.task.DefaultTaskLister
showTasks(String) - Method in interface com.snowflake.connectors.common.task.TaskLister: Fetches all tasks which are present in given schema.
showTasks(String, String) - Method in class com.snowflake.connectors.common.task.DefaultTaskLister
showTasks(String, String) - Method in interface com.snowflake.connectors.common.task.TaskLister: Fetches tasks which are present in given schema and contains given string.
SimpleTask<T> - Interface in com.snowflake.connectors.taskreactor.worker.simpletask: Interface that should be implemented by users of task reactor and passed over to SimpleTaskWorker instance.
SimpleTaskWorker<T> - Class in com.snowflake.connectors.taskreactor.worker.simpletask: A worker executing a SimpleTask.
size() - Method in interface com.snowflake.connectors.application.configuration.ConfigurationMap: Returns the number of existing keys in the configuration
size() - Method in class com.snowflake.connectors.application.configuration.DefaultConfigurationMap: Returns the number of existing keys in the configuration
SNAPSHOT - com.snowflake.connectors.application.ingestion.definition.IngestionStrategy: Create snapshots of the ingested data.
SnowparkFunctions - Class in com.snowflake.connectors.util.sql: Class containing overloaded Snowpark's functions which shouldn't be used in Connector's code.
SnowparkFunctions() - Constructor for class com.snowflake.connectors.util.sql.SnowparkFunctions
SourceValidator - Interface in com.snowflake.connectors.application.configuration.finalization: A validator for the connection to the external service, used by FinalizeConnectorHandler.
SqlTools - Class in com.snowflake.connectors.util.sql: Set of basic SQL utilities.
SqlTools() - Constructor for class com.snowflake.connectors.util.sql.SqlTools
STARTED - com.snowflake.connectors.application.status.ConnectorStatus: Connector is configured and running.
STARTING - com.snowflake.connectors.application.status.ConnectorStatus: Connector is being resumed.
startRun(String, String, Variant) - Method in interface com.snowflake.connectors.application.observability.IngestionRunRepository: Starts a new ingestion run with the provided definition id, configuration id, and metadata.
startRun(String, String, String, Variant) - Method in class com.snowflake.connectors.application.observability.DefaultIngestionRunRepository
startRun(String, String, String, Variant) - Method in interface com.snowflake.connectors.application.observability.IngestionRunRepository: Starts a new ingestion run with the provided definition id, configuration id, process id, and metadata.
state() - Method in class com.snowflake.connectors.common.task.TaskProperties: Returns the task state.
STATUS - Static variable in class com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository.ColumnNames: Representation of the status column.
stream() - Method in class com.snowflake.connectors.common.task.TaskParameters
success() - Static method in class com.snowflake.connectors.common.response.ConnectorResponse: Creates a new connector response instance, with response code of OK, no message, and no additional payload.
success(String) - Static method in class com.snowflake.connectors.common.response.ConnectorResponse: Creates a new response instance, with response code of OK, provided message, and no additional payload.
success(String, Map<String, Variant>) - Static method in class com.snowflake.connectors.common.response.ConnectorResponse: Creates a new response instance, with response code of OK, provided message, and additional payload.
suspend() - Method in class com.snowflake.connectors.common.task.DefaultTaskRef
suspend() - Method in interface com.snowflake.connectors.common.task.TaskRef: Suspends running referenced task.
suspendDispatcherTask() - Method in class com.snowflake.connectors.taskreactor.dispatcher.DispatcherTaskManager: Suspends dispatcher task
suspendIfExists() - Method in class com.snowflake.connectors.common.task.DefaultTaskRef
suspendIfExists() - Method in interface com.snowflake.connectors.common.task.TaskRef: Suspends running referenced task if it exists.
suspendTaskAfterNumFailures() - Method in class com.snowflake.connectors.common.task.TaskProperties: Returns the number of task failures before suspension.
suspendWorkerTaskIfExists(WorkerId) - Method in class com.snowflake.connectors.taskreactor.worker.WorkerTaskManager: Suspends a worker task if it exists.
SystemClock - Class in com.snowflake.connectors.util.time: Default implementation of SdkClock, using the system UTC clock.
SystemClock() - Constructor for class com.snowflake.connectors.util.time.SystemClock: Creates a new SystemClock.

T

TableLister - Interface in com.snowflake.connectors.common.table: Lists tables in the schema
TableProperties - Class in com.snowflake.connectors.common.table: Represents properties of the table object as returned by the "SHOW TABLES ..." expression
TableProperties(Identifier, Identifier, Identifier, Timestamp, String, String) - Constructor for class com.snowflake.connectors.common.table.TableProperties: Creates new TableProperties
TableRepository - Interface in com.snowflake.connectors.common.table: Interface for operations on the table objects.
TASK_REACTOR_SCHEMA - Static variable in class com.snowflake.connectors.taskreactor.ComponentNames
TaskCreationException - Exception in com.snowflake.connectors.common.task: Exception thrown when task creation has failed.
TaskCreationException(String) - Constructor for exception com.snowflake.connectors.common.task.TaskCreationException: Creates a new TaskCreationException.
TaskDefinition - Class in com.snowflake.connectors.common.task: Class representing a Snowflake task creation definition.
TaskDefinition(TaskProperties) - Constructor for class com.snowflake.connectors.common.task.TaskDefinition: Creates a new TaskDefinition.
TaskDefinition(TaskProperties, TaskParameters) - Constructor for class com.snowflake.connectors.common.task.TaskDefinition: Creates a new TaskDefinition.
TaskLister - Interface in com.snowflake.connectors.common.task: A simple utility for listing task properties.
TaskNotFoundException - Exception in com.snowflake.connectors.common.task: Exception thrown when a specified task was not found.
TaskNotFoundException(ObjectName) - Constructor for exception com.snowflake.connectors.common.task.TaskNotFoundException: Creates a new TaskNotFoundException.
TaskParameters - Class in com.snowflake.connectors.common.task: Class representing additional task parameters.
TaskParameters(Map<String, String>) - Constructor for class com.snowflake.connectors.common.task.TaskParameters
TaskProperties - Class in com.snowflake.connectors.common.task: Class representing main task properties.
TaskProperties.Builder - Class in com.snowflake.connectors.common.task: Builder for the TaskProperties.
TaskReactorConfig - Class in com.snowflake.connectors.taskreactor.config: Representation of configuration stored in CONFIG table
TaskReactorExistenceVerifier - Interface in com.snowflake.connectors.taskreactor: A utility for verifying whether the Task Reactor is enabled.
TaskReactorGetTroubleshootingDataService - Class in com.snowflake.connectors.taskreactor.troubleshooting: A service providing troubleshooting data about the Task Reactor.
TaskReactorInstance - Class in com.snowflake.connectors.taskreactor.registry: Task Reactor instance representation.
TaskReactorInstance(Identifier, boolean, boolean) - Constructor for class com.snowflake.connectors.taskreactor.registry.TaskReactorInstance: Creates a new TaskReactorInstance.
TaskReactorInstanceActionExecutor - Class in com.snowflake.connectors.taskreactor: Utility class for executing actions on all Task Reactor instances.
TaskReactorInstanceActionExecutor(TaskReactorExistenceVerifier, InstanceRegistryRepository) - Constructor for class com.snowflake.connectors.taskreactor.TaskReactorInstanceActionExecutor: Creates a new TaskReactorInstanceActionExecutor.
TaskReactorInstanceComponentProvider - Interface in com.snowflake.connectors.taskreactor: Class which is used to provide components that require Task Reactor instance name.
TaskReactorInstanceIsActiveException - Exception in com.snowflake.connectors.common.task: Exception thrown when performing an operation on a Task Reactor instance which requires the instance to be inactive, but it still is active.
TaskReactorInstanceIsActiveException(String) - Constructor for exception com.snowflake.connectors.common.task.TaskReactorInstanceIsActiveException: Creates a new TaskReactorInstanceIsActiveException.
TaskReactorLogger - Class in com.snowflake.connectors.taskreactor.log: Class which should be used in order to create a logger for taskreactor module The logger adds a prefix ConnectorsSDK::TaskReactor:: to all logged messages
TaskReactorTelemetry - Class in com.snowflake.connectors.taskreactor.telemetry: Telemetry utility for Task Reactor.
TaskReactorTelemetry() - Constructor for class com.snowflake.connectors.taskreactor.telemetry.TaskReactorTelemetry
TaskRef - Interface in com.snowflake.connectors.common.task: An interface that allows user to interact with Snowflake tasks.
TaskRepository - Interface in com.snowflake.connectors.common.task: A repository providing general operations on tasks.
timestamp - Variable in class com.snowflake.connectors.taskreactor.queue.QueueItem: Item insertion timestamp.
TIMESTAMP - Static variable in class com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository.ColumnNames: Representation of the timestamp column.
TimestampUtil - Class in com.snowflake.connectors.util.sql: Utility class which provides mapping methods between Timestamp and Instant.
toInstant(Timestamp) - Static method in class com.snowflake.connectors.util.sql.TimestampUtil: Method for converting given Timestamp to Instant.
toJson() - Method in class com.snowflake.connectors.common.response.ConnectorResponse: Returns the properties of this response in a JSON String.
toMap() - Method in class com.snowflake.connectors.common.response.ConnectorResponse: Returns the properties of this response in a Map.
toString() - Method in class com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition
toString() - Method in class com.snowflake.connectors.common.object.Identifier
toString() - Method in class com.snowflake.connectors.common.object.ObjectName
toString() - Method in class com.snowflake.connectors.common.object.Reference
toString() - Method in class com.snowflake.connectors.common.object.SchemaName
toString() - Method in class com.snowflake.connectors.taskreactor.registry.TaskReactorInstance
toString() - Method in class com.snowflake.connectors.taskreactor.worker.queue.WorkItem
toString() - Method in class com.snowflake.connectors.taskreactor.worker.WorkerId
toTimestamp(Instant) - Static method in class com.snowflake.connectors.util.sql.TimestampUtil: Method for converting given Instant to Timestamp.
toVariant() - Method in class com.snowflake.connectors.common.response.ConnectorResponse: Returns the properties of this response in a Variant.
toVariant(Variant) - Method in class com.snowflake.connectors.common.response.ConnectorResponse: Returns the properties of this response appended to the provided Variant.
trace(String) - Method in class com.snowflake.connectors.util.log.PrefixLogger
trace(String, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
trace(String, Object...) - Method in class com.snowflake.connectors.util.log.PrefixLogger
trace(String, Object, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
trace(String, Throwable) - Method in class com.snowflake.connectors.util.log.PrefixLogger
trace(Marker, String) - Method in class com.snowflake.connectors.util.log.PrefixLogger
trace(Marker, String, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
trace(Marker, String, Object...) - Method in class com.snowflake.connectors.util.log.PrefixLogger
trace(Marker, String, Object, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
trace(Marker, String, Throwable) - Method in class com.snowflake.connectors.util.log.PrefixLogger
TransactionManager - Interface in com.snowflake.connectors.util.snowflake: Wraps given action with transaction.
TYPE - Static variable in class com.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository.ColumnName: Representation of the TYPE column.

U

UNKNOWN_ERROR_CODE - Static variable in interface com.snowflake.connectors.application.lifecycle.LifecycleService: Response code signifying an unknown, unrecoverable error has occurred
UnknownConnectorException - Exception in com.snowflake.connectors.common.exception: Exception thrown when an unknown error has occurred.
UnknownConnectorException() - Constructor for exception com.snowflake.connectors.common.exception.UnknownConnectorException: Creates a new UnknownConnectorException with a default message of An unknown error occurred.
UnknownConnectorException(Exception) - Constructor for exception com.snowflake.connectors.common.exception.UnknownConnectorException: Creates a new UnknownConnectorException, with the provided exception as message source and exception cause.
UnknownConnectorException(String) - Constructor for exception com.snowflake.connectors.common.exception.UnknownConnectorException: Creates a new UnknownConnectorException with a provided message.
UnknownSqlException - Exception in com.snowflake.connectors.util.sql: Exception thrown when an unknown SQL error has occurred.
UnknownSqlException() - Constructor for exception com.snowflake.connectors.util.sql.UnknownSqlException: Creates a new UnknownSqlException with a default message of An unknown SQL error occurred.
UnknownSqlException(String, String) - Constructor for exception com.snowflake.connectors.util.sql.UnknownSqlException: Creates a new UnknownSqlException with a provided message and called procedure information.
UP_FOR_DELETION - com.snowflake.connectors.taskreactor.worker.registry.WorkerLifecycleStatus: WorkerOrchestrator sets this status right after the user decreased the number of workers.
update(Identifier) - Method in interface com.snowflake.connectors.common.task.UpdateTaskReactorTasks: Updates all worker instances with provided warehouse
update(String, Variant) - Method in class com.snowflake.connectors.common.table.DefaultKeyValueTable: Updates the value stored under the provided key.
update(String, Variant) - Method in interface com.snowflake.connectors.common.table.KeyValueTable: Updates the value stored under the provided key.
update(String, Variant) - Method in class com.snowflake.connectors.common.table.ReadOnlyKeyValueTable
update(String, String) - Method in interface com.snowflake.connectors.taskreactor.config.ConfigRepository: Updates task reactor configuration.
update(String, T) - Method in interface com.snowflake.connectors.application.configuration.ConfigurationRepository: Updates the configuration properties in the record stored under the provided key.
update(String, T) - Method in class com.snowflake.connectors.application.configuration.DefaultConfigurationRepository
update(String, T) - Method in class com.snowflake.connectors.common.state.DefaultKeyValueStateRepository
update(String, T) - Method in interface com.snowflake.connectors.common.state.KeyValueStateRepository: Updates the provided state value, stored under the provided key, in this repository.
UPDATE_WAREHOUSE - com.snowflake.connectors.taskreactor.commands.queue.Command.CommandType
updateAll(List<KeyValue>) - Method in class com.snowflake.connectors.common.table.DefaultKeyValueTable
updateAll(List<KeyValue>) - Method in interface com.snowflake.connectors.common.table.KeyValueTable: Updates the key-value pairs.
updateAll(List<KeyValue>) - Method in class com.snowflake.connectors.common.table.ReadOnlyKeyValueTable
updateConfiguration(Variant) - Method in interface com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationService: Updates the connection configuration record with the provided properties.
updateConfiguration(Variant) - Method in interface com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationService: Updates the connector configuration record with the provided properties.
updateConnectionConfiguration(Session, Variant) - Static method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandler: Default handler method for the PUBLIC.UPDATE_CONNECTION_CONFIGURATION procedure.
updateConnectionConfiguration(Variant) - Method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandler: Executes the main logic of the handler, with logging using withExceptionLogging.
UpdateConnectionConfigurationHandler - Class in com.snowflake.connectors.application.configuration.connection: Handler for the connection configuration update process.
UpdateConnectionConfigurationHandlerBuilder - Class in com.snowflake.connectors.application.configuration.connection: Builder for the UpdateConnectionConfigurationHandler.
updateConnectorStatus(FullConnectorStatus) - Method in interface com.snowflake.connectors.application.status.ConnectorStatusRepository: Updates the connector and connector configuration statuses.
updateConnectorStatus(FullConnectorStatus) - Method in interface com.snowflake.connectors.application.status.ConnectorStatusService: Updates the connector and connector configuration statuses.
updateConnectorStatus(FullConnectorStatus) - Method in class com.snowflake.connectors.application.status.DefaultConnectorStatusService
updateIngestedRows(String, Long) - Method in interface com.snowflake.connectors.application.observability.IngestionRunRepository: Updates the number of ingested rows for the specified ingestion run.
updateIngestedRows(String, Long, IngestionRunRepository.Mode) - Method in class com.snowflake.connectors.application.observability.DefaultIngestionRunRepository
updateIngestedRows(String, Long, IngestionRunRepository.Mode) - Method in interface com.snowflake.connectors.application.observability.IngestionRunRepository: Updates the number of ingested rows for the specified ingestion run.
updateInstance(String, Identifier) - Method in interface com.snowflake.connectors.common.task.UpdateTaskReactorTasks: Updates provided worker instance with provided warehouse
updateMany(List<String>, String, Variant) - Method in class com.snowflake.connectors.common.table.DefaultKeyValueTable
updateMany(List<String>, String, Variant) - Method in interface com.snowflake.connectors.common.table.KeyValueTable: Updates the provided field of the Variant value stored under the provided keys.
updateMany(List<String>, String, Variant) - Method in class com.snowflake.connectors.common.table.ReadOnlyKeyValueTable
updateResource(Session, String, Variant) - Static method in class com.snowflake.connectors.application.ingestion.update.UpdateResourceHandler: Default handler method for the PUBLIC.UPDATE_RESOURCE procedure.
updateResource(String, Variant) - Method in class com.snowflake.connectors.application.ingestion.update.UpdateResourceHandler: Executes the main logic of the handler, with logging using withExceptionLogging.
UpdateResourceHandler - Class in com.snowflake.connectors.application.ingestion.update: Handler for the process of updating a resource.
UpdateResourceHandlerBuilder - Class in com.snowflake.connectors.application.ingestion.update: Builder for the UpdateResourceHandler.
UpdateResourceHandlerBuilder(Session) - Constructor for class com.snowflake.connectors.application.ingestion.update.UpdateResourceHandlerBuilder: Creates a new UpdateResourceHandlerBuilder.
UpdateResourceValidator - Interface in com.snowflake.connectors.application.ingestion.update: Callback which is called at the beginning of updating a resource ingestion configuration
updateStatus(ConnectorStatus) - Method in class com.snowflake.connectors.application.lifecycle.DefaultLifecycleService
updateStatus(ConnectorStatus) - Method in interface com.snowflake.connectors.application.lifecycle.LifecycleService: Updates the connector status to a provided one.
updateStatus(String, String) - Method in class com.snowflake.connectors.application.ingestion.process.DefaultIngestionProcessRepository: Updates the status of an ingestion process with the specified id.
updateStatus(String, String) - Method in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository: Updates the status of an ingestion process with the specified id.
updateStatus(String, String, String, String) - Method in class com.snowflake.connectors.application.ingestion.process.DefaultIngestionProcessRepository: Updates the status of an ingestion process with the specified resource ingestion definition id, ingestion configuration, and process type.
updateStatus(String, String, String, String) - Method in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository: Updates the status of an ingestion process with the specified resource ingestion definition id, ingestion configuration, and process type.
updateStatusesFor(WorkerStatus, List<WorkerId>) - Method in interface com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository: Updates the status of workers with the specified ids.
updateStatusFor(WorkerId, WorkerStatus) - Method in interface com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository: Updates the status of a worker with the specified id.
UpdateTaskReactorTasks - Interface in com.snowflake.connectors.common.task: An interface providing update operations on tasks.
updateWarehouse(Session, String) - Static method in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandler: Default handler method for the PUBLIC.UPDATE_WAREHOUSE procedure.
updateWarehouse(Session, String, String) - Static method in class com.snowflake.connectors.taskreactor.api.UpdateWarehouseInstanceHandler: Default handler method for the TASK_REACTOR.UPDATE_WAREHOUSE procedure.
updateWarehouse(String) - Method in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandler: Executes the main logic of the handler, with logging using withExceptionLogging.
updateWarehouse(String, String) - Method in class com.snowflake.connectors.taskreactor.api.UpdateWarehouseInstanceHandler: Executes the main logic of the handler, with logging using withExceptionLogging.
UpdateWarehouseCallback - Interface in com.snowflake.connectors.application.configuration.warehouse: Callback called during the UpdateWarehouseHandler execution, may be used to provide custom warehouse update logic.
UpdateWarehouseExecutor - Class in com.snowflake.connectors.taskreactor.commands.processor.executors: Executor of the UPDATE_WAREHOUSE command.
UpdateWarehouseHandler - Class in com.snowflake.connectors.application.configuration.warehouse: Handler for the warehouse update process.
UpdateWarehouseHandlerBuilder - Class in com.snowflake.connectors.application.configuration.warehouse: Builder for the UpdateWarehouseHandler.
UpdateWarehouseHandlerBuilder(Session) - Constructor for class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerBuilder: Creates a new UpdateWarehouseHandlerBuilder.
UpdateWarehouseInputValidator - Interface in com.snowflake.connectors.application.configuration.warehouse: A validator for the input of UpdateWarehouseHandler, may be used to provide custom warehouse validation.
UpdateWarehouseInstanceHandler - Class in com.snowflake.connectors.taskreactor.api: Handler for the Task Reactor instance warehouse update.
UpdateWarehouseInstanceHandlerBuilder - Class in com.snowflake.connectors.taskreactor.api: Builder for the UpdateWarehouseInstanceHandler.
UpdateWarehouseSdkCallback - Interface in com.snowflake.connectors.application.configuration.warehouse: Callback called during the UpdateWarehouseHandler execution, used to provide additional logic for sdk-controlled components.
updateWorkersStatus(WorkerLifecycleStatus, WorkerLifecycleStatus, Collection<WorkerId>) - Method in interface com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistry: Changes workers status to new one on condition that they are currently in given status.
utcNow() - Method in interface com.snowflake.connectors.util.time.SdkClock: Returns the current UTC instant.
utcNow() - Method in class com.snowflake.connectors.util.time.SystemClock

V

validate() - Method in interface com.snowflake.connectors.application.configuration.connection.ConnectionValidator: Validates the connection configured during the handler execution.
validate() - Method in interface com.snowflake.connectors.application.lifecycle.pause.PauseConnectorStateValidator: Validates the state of the connector.
validate() - Method in interface com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorStateValidator: Validates the state of the connector.
validate(VariantResource) - Method in interface com.snowflake.connectors.application.ingestion.create.CreateResourceValidator: Callback which is called at the beginning of creating a resource but after simple validation (whether a resource with given id already exists and whether the resource has a valid structure).
validate(Identifier) - Method in interface com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseInputValidator: Validates the provided warehouse.
validate(Variant) - Method in interface com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationInputValidator: Validates the provided connection configuration.
validate(Variant) - Method in interface com.snowflake.connectors.application.configuration.connection.DraftConnectionValidator: Validates the connection configured during the handler execution.
validate(Variant) - Method in interface com.snowflake.connectors.application.configuration.connector.ConfigureConnectorInputValidator: Validates the provided connector configuration.
validate(Variant) - Method in interface com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorInputValidator: Validates the provided configuration.
validate(Variant) - Method in interface com.snowflake.connectors.application.configuration.finalization.SourceValidator: Validates the access to specific external sources.
validate(String) - Method in interface com.snowflake.connectors.application.ingestion.enable.EnableResourceValidator: Callback which is called at the beginning of enabling a resource but after simple validation (whether a given resource exists and whether the resource is not already enabled).
validate(String, List<IngestionConfiguration<Variant, Variant>>) - Method in interface com.snowflake.connectors.application.ingestion.update.UpdateResourceValidator: Callback that is called at the beginning of updating a resource ingestion configuration process intended to initial input validation.
validateConfigurationStatusIsIn(ConnectorStatus.ConnectorConfigurationStatus...) - Method in class com.snowflake.connectors.application.status.FullConnectorStatus: Validates whether this connector configuration status is present among the provided statuses.
validateConfigurationStatusIsNotIn(ConnectorStatus.ConnectorConfigurationStatus...) - Method in class com.snowflake.connectors.application.status.FullConnectorStatus: Validates whether this connector configuration status is not present among the provided statuses.
validateConnectorStatusIn(ConnectorStatus...) - Method in class com.snowflake.connectors.application.status.FullConnectorStatus: Validates whether this connector status is in provided ones.
validateDuplicates(Collection<T>, Function<T, K>) - Static method in class com.snowflake.connectors.util.sql.MergeStatementValidator: Validates if collection contains only unique keys.
validateFields(Variant) - Method in interface com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationService: Validates if all the provided connector configuration properties are allowed by the ConnectorConfigurationKey values.
validatePrivileges(String...) - Method in interface com.snowflake.connectors.util.snowflake.PrivilegeTools: Validates whether the application instance has been granted the specified account privileges.
validateRecordLimit(Collection<T>) - Static method in class com.snowflake.connectors.util.sql.MergeStatementValidator: Validates if collection size is exceeding statement limit of 16384.
validateRequiredPrivileges() - Method in class com.snowflake.connectors.application.lifecycle.DefaultLifecycleService
validateRequiredPrivileges() - Method in interface com.snowflake.connectors.application.lifecycle.LifecycleService: Validates whether the application instance has been granted all privileges necessary to run the lifecycle processes.
validateStatus(ConnectorStatus...) - Method in class com.snowflake.connectors.application.lifecycle.DefaultLifecycleService
validateStatus(ConnectorStatus...) - Method in interface com.snowflake.connectors.application.lifecycle.LifecycleService: Validates if the current connector status contains provided ones.
value() - Method in class com.snowflake.connectors.common.table.KeyValue: Returns the value of this key-value pair.
value() - Method in class com.snowflake.connectors.taskreactor.worker.WorkerId: Returns the value of this worker id.
valueOf(String) - Static method in enum com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationKey: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.snowflake.connectors.application.ingestion.definition.IngestionStrategy: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.snowflake.connectors.application.ingestion.definition.ScheduleType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.snowflake.connectors.application.observability.IngestionRun.IngestionStatus: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.snowflake.connectors.application.observability.IngestionRunRepository.Mode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.snowflake.connectors.application.status.ConnectorStatus.ConnectorConfigurationStatus: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.snowflake.connectors.application.status.ConnectorStatus: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.snowflake.connectors.common.object.Identifier.AutoQuoting: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.snowflake.connectors.taskreactor.commands.queue.Command.CommandType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.snowflake.connectors.taskreactor.worker.registry.WorkerLifecycleStatus: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.snowflake.connectors.taskreactor.worker.status.WorkerStatus: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.snowflake.connectors.taskreactor.WorkSelectorType: Returns the enum constant of this type with the specified name.
values() - Static method in enum com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationKey: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.snowflake.connectors.application.ingestion.definition.IngestionStrategy: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.snowflake.connectors.application.ingestion.definition.ScheduleType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.snowflake.connectors.application.observability.IngestionRun.IngestionStatus: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.snowflake.connectors.application.observability.IngestionRunRepository.Mode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.snowflake.connectors.application.status.ConnectorStatus.ConnectorConfigurationStatus: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.snowflake.connectors.application.status.ConnectorStatus: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.snowflake.connectors.common.object.Identifier.AutoQuoting: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.snowflake.connectors.taskreactor.commands.queue.Command.CommandType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.snowflake.connectors.taskreactor.worker.registry.WorkerLifecycleStatus: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.snowflake.connectors.taskreactor.worker.status.WorkerStatus: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.snowflake.connectors.taskreactor.WorkSelectorType: Returns an array containing the constants of this enum type, in the order they are declared.
varcharArgument(String) - Static method in class com.snowflake.connectors.util.sql.SqlTools: Deprecated, for removal: This API element is subject to removal in a future version.
variantArgument(Variant) - Static method in class com.snowflake.connectors.util.sql.SqlTools: Deprecated, for removal: This API element is subject to removal in a future version.
VariantDeserializer - Class in com.snowflake.connectors.util.variant: Jackson JSON deserializer for Variant.
VariantDeserializer() - Constructor for class com.snowflake.connectors.util.variant.VariantDeserializer
VariantMapper - Class in com.snowflake.connectors.util.variant: Utility class for Snowpark Variant mapping.
VariantMapperException - Exception in com.snowflake.connectors.util.variant: Exception thrown when an error during Variant mapping is encountered.
VariantMapperException(String, Throwable) - Constructor for exception com.snowflake.connectors.util.variant.VariantMapperException: Creates a new VariantMapperException.
VariantResource - Class in com.snowflake.connectors.application.ingestion.definition: An implementation of ResourceIngestionDefinition using Variant for all dependencies.
VariantResource() - Constructor for class com.snowflake.connectors.application.ingestion.definition.VariantResource: Creates an empty VariantResource.
VariantResource(String, String, boolean, Variant, Variant, List<IngestionConfiguration<Variant, Variant>>) - Constructor for class com.snowflake.connectors.application.ingestion.definition.VariantResource: Creates a new VariantResource, with no parent definition.
VIEW - com.snowflake.connectors.taskreactor.WorkSelectorType: Work selector provided using a view.

W

warehouse() - Method in class com.snowflake.connectors.common.task.TaskProperties: Returns the task warehouse.
warehouse() - Method in class com.snowflake.connectors.taskreactor.config.TaskReactorConfig: Returns the warehouse name.
WAREHOUSE - com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationKey: Main warehouse used by the connector.
WarehouseAlreadyUsedException - Exception in com.snowflake.connectors.application.configuration.warehouse: Exception thrown when the specified warehouse is already used by the connector.
WarehouseAlreadyUsedException(Identifier) - Constructor for exception com.snowflake.connectors.application.configuration.warehouse.WarehouseAlreadyUsedException: Creates a new WarehouseAlreadyUsedException.
warehouseIdentifier() - Method in class com.snowflake.connectors.common.task.TaskProperties: Returns the task warehouse identifier.
warehouseReference() - Method in class com.snowflake.connectors.common.task.TaskProperties: Returns the task warehouse reference.
warn(String) - Method in class com.snowflake.connectors.util.log.PrefixLogger
warn(String, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
warn(String, Object...) - Method in class com.snowflake.connectors.util.log.PrefixLogger
warn(String, Object, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
warn(String, Throwable) - Method in class com.snowflake.connectors.util.log.PrefixLogger
warn(Marker, String) - Method in class com.snowflake.connectors.util.log.PrefixLogger
warn(Marker, String, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
warn(Marker, String, Object...) - Method in class com.snowflake.connectors.util.log.PrefixLogger
warn(Marker, String, Object, Object) - Method in class com.snowflake.connectors.util.log.PrefixLogger
warn(Marker, String, Throwable) - Method in class com.snowflake.connectors.util.log.PrefixLogger
withActive(boolean) - Method in class com.snowflake.connectors.taskreactor.registry.TaskReactorInstance: Returns a copy of this instance, with the active parameter set to the specified value.
withAdditionalPayload(String, Variant) - Method in class com.snowflake.connectors.common.response.ConnectorResponse: Adds a new key-value pair to additional payload
withAllowOverlappingExecution(boolean) - Method in class com.snowflake.connectors.common.task.TaskProperties.Builder: Sets the task overlapping execution allowance used to build task properties.
withCallback(ConnectionConfigurationCallback) - Method in class com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationHandlerBuilder: Sets the callback used to build the handler instance.
withCallback(ConnectionConfigurationCallback) - Method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandlerBuilder: Sets the callback used to build the handler instance.
withCallback(ConfigureConnectorCallback) - Method in class com.snowflake.connectors.application.configuration.connector.ConfigureConnectorHandlerBuilder: Sets the callback used to build the handler instance.
withCallback(FinalizeConnectorCallback) - Method in class com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorHandlerBuilder: Sets the callback used to build the handler instance.
withCallback(UpdateWarehouseCallback) - Method in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerBuilder: Sets the callback used to build the handler instance.
withCallback(PauseConnectorCallback) - Method in class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandlerBuilder: Sets the callback used to build the handler instance.
withCallback(ResumeConnectorCallback) - Method in class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandlerBuilder: Sets the callback used to build the handler instance.
withCallback(OnIngestionScheduledCallback) - Method in class com.snowflake.connectors.application.scheduler.RunSchedulerIterationHandlerBuilder: Sets the callback used to build the handler instance.
withCondition(String) - Method in class com.snowflake.connectors.common.task.TaskProperties.Builder: Sets the task condition used to build task properties.
withConnectionValidator(ConnectionValidator) - Method in class com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationHandlerBuilder: Sets the connection validator used to build the handler instance.
withConnectionValidator(ConnectionValidator) - Method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandlerBuilder: Sets the connection validator used to build the handler instance.
withConnectorExceptionLogger(ExceptionLogger<ConnectorException>) - Method in class com.snowflake.connectors.common.exception.helper.ConnectorErrorHelperBuilder: Sets the exception logger used for logging connector exceptions.
withCreateResourceValidator(CreateResourceValidator) - Method in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerBuilder: Sets the CreateResourceValidator used to build the handler instance.
withDraftCallback(ConnectionConfigurationCallback) - Method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandlerBuilder: Sets the draft callback used to build the handler instance.
withDraftConnectionValidator(DraftConnectionValidator) - Method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandlerBuilder: Sets the draft connection validator used to build the handler instance.
withEnableResourceValidator(EnableResourceValidator) - Method in class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandlerBuilder: Sets the EnableResourceValidator used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationHandlerBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandlerBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.configuration.connector.ConfigureConnectorHandlerBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorHandlerBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.ingestion.disable.DisableResourceHandlerBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandlerBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.ingestion.update.UpdateResourceHandlerBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandlerBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandlerBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.scheduler.CreateSchedulerHandlerBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.scheduler.CreateSchedulerHandlerTestBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.scheduler.RunSchedulerIterationHandlerBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.taskreactor.api.PauseInstanceHandlerBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.taskreactor.api.ResumeInstanceHandlerBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.taskreactor.api.UpdateWarehouseInstanceHandlerBuilder: Sets the error helper used to build the handler instance.
withExceptionLogging(Supplier<T>) - Method in interface com.snowflake.connectors.common.exception.helper.ConnectorErrorHelper: Wraps the provided action in a try/catch block, and if any exception is caught - logs it and maps it to a ConnectorException instance.
withExceptionLoggingAndWrapping(Supplier<ConnectorResponse>) - Method in interface com.snowflake.connectors.common.exception.helper.ConnectorErrorHelper: Wraps the provided action in a try/catch block, and if any exception is caught - logs it and returns it as an instance of ConnectorResponse, without rethrowing the exception.
withExceptionWrapping(Supplier<ConnectorResponse>) - Method in interface com.snowflake.connectors.common.exception.helper.ConnectorErrorHelper: Wraps the provided action in a try/catch block, and if any exception is caught - returns it as an instance of ConnectorResponse, without rethrowing the exception.
withFinishedAt(Instant) - Method in class com.snowflake.connectors.application.ingestion.process.IngestionProcess: Returns a copy of this process with the specified finished at.
withInputValidator(ConnectionConfigurationInputValidator) - Method in class com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationHandlerBuilder: Sets the input validator used to build the handler instance.
withInputValidator(ConnectionConfigurationInputValidator) - Method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandlerBuilder: Sets the input validator used to build the handler instance.
withInputValidator(ConfigureConnectorInputValidator) - Method in class com.snowflake.connectors.application.configuration.connector.ConfigureConnectorHandlerBuilder: Sets the input validator used to build the handler instance.
withInputValidator(FinalizeConnectorInputValidator) - Method in class com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorHandlerBuilder: Sets the input validator used to build the handler instance.
withInputValidator(UpdateWarehouseInputValidator) - Method in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerBuilder: Sets the input validator used to build the handler instance.
withMetadata(Variant) - Method in class com.snowflake.connectors.application.ingestion.process.IngestionProcess: Returns a copy of this process with the specified metadata set.
withPostCreateResourceCallback(PostCreateResourceCallback) - Method in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerBuilder: Sets the PostCreateResourceCallback used to build the handler instance.
withPostDisableResourceCallback(PostDisableResourceCallback) - Method in class com.snowflake.connectors.application.ingestion.disable.DisableResourceHandlerBuilder: Sets the PostDisableResourceCallback used to build the handler instance.
withPostEnableResourceCallback(PostEnableResourceCallback) - Method in class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandlerBuilder: Sets the PostEnableResourceCallback used to build the handler instance.
withPostUpdateResourceCallback(PostUpdateResourceCallback) - Method in class com.snowflake.connectors.application.ingestion.update.UpdateResourceHandlerBuilder: Sets the PostUpdateResourceCallback used to build the handler instance.
withPreCreateResourceCallback(PreCreateResourceCallback) - Method in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerBuilder: Sets the PreCreateResourceCallback used to build the handler instance.
withPreDisableResourceCallback(PreDisableResourceCallback) - Method in class com.snowflake.connectors.application.ingestion.disable.DisableResourceHandlerBuilder: Sets the PreDisableResourceCallback used to build the handler instance.
withPreEnableResourceCallback(PreEnableResourceCallback) - Method in class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandlerBuilder: Sets the PreEnableResourceCallback used to build the handler instance.
withPreUpdateResourceCallback(PreUpdateResourceCallback) - Method in class com.snowflake.connectors.application.ingestion.update.UpdateResourceHandlerBuilder: Sets the PreUpdateResourceCallback used to build the handler instance.
withRollbackHandling(Supplier<ConnectorResponse>) - Method in class com.snowflake.connectors.application.lifecycle.DefaultLifecycleService
withRollbackHandling(Supplier<ConnectorResponse>) - Method in interface com.snowflake.connectors.application.lifecycle.LifecycleService: Executes the specified action with handling of rollback and unexpected errors.
withSchedule(String) - Method in class com.snowflake.connectors.common.task.TaskProperties.Builder: Sets the task schedule used to build task properties.
withSchedulerCreator(SchedulerCreator) - Method in class com.snowflake.connectors.application.scheduler.CreateSchedulerHandlerTestBuilder: Sets the scheduler creator used to build the handler instance.
withSourceValidator(SourceValidator) - Method in class com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorHandlerBuilder: Sets the source validator used to build the handler instance.
withState(String) - Method in class com.snowflake.connectors.common.task.TaskProperties.Builder: Sets the task state used to build task properties.
withStateValidator(PauseConnectorStateValidator) - Method in class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandlerBuilder: Sets the state validator used to build the handler instance.
withStateValidator(ResumeConnectorStateValidator) - Method in class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandlerBuilder: Sets the state validator used to build the handler instance.
withStatus(String) - Method in class com.snowflake.connectors.application.ingestion.process.IngestionProcess: Returns a copy of this process with the specified status set.
withSuspendTaskAfterNumFailures(int) - Method in class com.snowflake.connectors.common.task.TaskProperties.Builder: Sets the number of task failures before suspension used to build task properties.
withTransaction(Runnable) - Method in interface com.snowflake.connectors.util.snowflake.TransactionManager: Wraps given action with transaction.
withTransaction(Runnable, Function<Throwable, RuntimeException>) - Method in interface com.snowflake.connectors.util.snowflake.TransactionManager: Wraps given action with transaction.
withUnknownExceptionMapper(ExceptionMapper<Exception>) - Method in class com.snowflake.connectors.common.exception.helper.ConnectorErrorHelperBuilder: Sets the exception mapper used for mapping unknown (other than ConnectorException) exceptions.
withUpdateResourceValidator(UpdateResourceValidator) - Method in class com.snowflake.connectors.application.ingestion.update.UpdateResourceHandlerBuilder: Sets the UpdateResourceValidator used to build the handler instance.
withUpdateTaskReactorTasks(UpdateTaskReactorTasks) - Method in class com.snowflake.connectors.taskreactor.api.UpdateWarehouseInstanceHandlerBuilder: Sets the input validator used to build the handler instance.
withWarehouse(Identifier) - Method in class com.snowflake.connectors.common.task.TaskProperties.Builder: Sets the warehouse identifier used to build task properties.
withWarehouse(Reference) - Method in class com.snowflake.connectors.common.task.TaskProperties.Builder: Sets the warehouse reference used to build task properties.
withWarehouse(String) - Method in class com.snowflake.connectors.common.task.TaskProperties.Builder: Sets the warehouse used to build task properties.
withWarehouse(String, Identifier.AutoQuoting) - Method in class com.snowflake.connectors.common.task.TaskProperties.Builder: Sets the warehouse used to build task properties.
WORK_ASSIGNED - com.snowflake.connectors.taskreactor.worker.status.WorkerStatus: Worker gets this status assigned once the Dispatcher assigns work to it.
Worker<T> - Class in com.snowflake.connectors.taskreactor.worker: A set of methods performed by the Worker implementation.
Worker(WorkerId, Identifier, WorkerStatusRepository, ObjectName, WorkerQueue, TaskRepository) - Constructor for class com.snowflake.connectors.taskreactor.worker.Worker
WORKER_COMBINED_VIEW - Static variable in class com.snowflake.connectors.taskreactor.ComponentNames
WORKER_ID - Static variable in class com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository.ColumnNames: Representation of the worker_id column.
WORKER_REGISTRY_TABLE - Static variable in class com.snowflake.connectors.taskreactor.ComponentNames
WORKER_STATUS_TABLE - Static variable in class com.snowflake.connectors.taskreactor.ComponentNames
WorkerCombinedView - Interface in com.snowflake.connectors.taskreactor.worker: Utility for creating a combined view of worker queues.
workerDeleted(WorkerId) - Method in class com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistryService: Sets the status of the specified worker to DELETED.
WorkerException - Exception in com.snowflake.connectors.taskreactor.worker: Exception thrown when a worker fails.
WorkerId - Class in com.snowflake.connectors.taskreactor.worker: Representation of worker id.
WorkerId(int) - Constructor for class com.snowflake.connectors.taskreactor.worker.WorkerId: Creates a new WorkerId.
WorkerJobCancelledException - Exception in com.snowflake.connectors.taskreactor.worker: Exception thrown when new running worker was scheduled for cancellation.
WorkerJobCancelledException() - Constructor for exception com.snowflake.connectors.taskreactor.worker.WorkerJobCancelledException: Creates a new WorkerJobCancelledException.
WorkerLifecycleStatus - Enum in com.snowflake.connectors.taskreactor.worker.registry: Lifecycle status for each worker stored in a WORKER_REGISTRY table.
WorkerManager - Class in com.snowflake.connectors.taskreactor.worker: A set of utilities for worker management.
WorkerOrchestrator - Class in com.snowflake.connectors.taskreactor.worker.registry: A Task Reactor worker orchestrator.
WorkerOrchestratorValidationException - Exception in com.snowflake.connectors.taskreactor.worker.registry: Exception thrown when an invalid number of workers is specified.
WorkerOrchestratorValidationException(String) - Constructor for exception com.snowflake.connectors.taskreactor.worker.registry.WorkerOrchestratorValidationException: Creates a new WorkerOrchestratorValidationException.
workerPayload - Variable in class com.snowflake.connectors.taskreactor.queue.QueueItem: Additional payload for the worker
workerProcedure() - Method in class com.snowflake.connectors.taskreactor.config.TaskReactorConfig: Returns the worker procedure name.
workerProvisioned(WorkerId) - Method in class com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistryService: Sets the status of the specified worker to ACTIVE.
WorkerQueue - Interface in com.snowflake.connectors.taskreactor.worker.queue: Implementation of Task Reactor Worker Queue
WorkerQueueManager - Interface in com.snowflake.connectors.taskreactor.worker.queue: Manager responsible for creating queues for given workers
workerQueueStream(WorkerId) - Static method in class com.snowflake.connectors.taskreactor.ComponentNames
workerQueueTable(WorkerId) - Static method in class com.snowflake.connectors.taskreactor.ComponentNames
WorkerRegistry - Interface in com.snowflake.connectors.taskreactor.worker.registry: Registry repository of task reactor workers.
WorkerRegistryService - Class in com.snowflake.connectors.taskreactor.worker.registry: Registry of task reactor workers.
WorkerRegistryService(WorkerStatusRepository, WorkerRegistry) - Constructor for class com.snowflake.connectors.taskreactor.worker.registry.WorkerRegistryService: Creates a new WorkerRegistryService.
WorkerStatus - Enum in com.snowflake.connectors.taskreactor.worker.status: Status describing WorkerLifecycleStatus.ACTIVE workers.
WorkerStatusRepository - Interface in com.snowflake.connectors.taskreactor.worker.status
WorkerStatusRepository.ColumnNames - Class in com.snowflake.connectors.taskreactor.worker.status: Column names of the worker_status table.
workerTask(WorkerId) - Static method in class com.snowflake.connectors.taskreactor.ComponentNames
WorkerTaskManager - Class in com.snowflake.connectors.taskreactor.worker
WorkItem - Class in com.snowflake.connectors.taskreactor.worker.queue: Class describing an item that was inserted to the input queue of the task reactor.
WorkItem(String, String, Variant) - Constructor for class com.snowflake.connectors.taskreactor.worker.queue.WorkItem: Creates a new WorkItem.
WorkItemQueue - Interface in com.snowflake.connectors.taskreactor.queue: Interface of Task Reactor input Queue for basic management of the work items
WorkItemQueueException - Exception in com.snowflake.connectors.taskreactor.queue: Exception thrown when statements executed on WorkItemQueue failed .
WorkItemQueueException(SQLException) - Constructor for exception com.snowflake.connectors.taskreactor.queue.WorkItemQueueException: Creates a new WorkItemQueueException.
workSelector() - Method in class com.snowflake.connectors.taskreactor.config.TaskReactorConfig: Returns the work selector object name.
WorkSelector - Interface in com.snowflake.connectors.taskreactor.queue.selector: Class representing selection mechanism from WorkItemQueue.
workSelectorType() - Method in class com.snowflake.connectors.taskreactor.config.TaskReactorConfig: Returns the work selector type.
WorkSelectorType - Enum in com.snowflake.connectors.taskreactor: Work selector type.

A B C D E F G H I K L M N O P Q R S T U V W
All Classes All Packages