| com.snowflake.connectors.application.configuration |
Backend implementations for configuration management and wizard procedures.
|
| com.snowflake.connectors.application.configuration.connection |
Backend implementations for the connection configuration wizard step.
|
| com.snowflake.connectors.application.configuration.connector |
Backend implementations for the connector configuration wizard step.
|
| com.snowflake.connectors.application.configuration.finalization |
Backend implementations for the configuration finalization wizard step.
|
| com.snowflake.connectors.application.configuration.warehouse |
Backend implementations for the warehouse update process.
|
| com.snowflake.connectors.application.ingestion.create |
Backend implementation of ingestion resource creation.
|
| com.snowflake.connectors.application.ingestion.definition |
Resource ingestion definition management.
|
| com.snowflake.connectors.application.ingestion.disable |
Backend implementation of ingestion resource disabling.
|
| com.snowflake.connectors.application.ingestion.enable |
Backend implementation of ingestion resource enabling.
|
| com.snowflake.connectors.application.ingestion.process |
Resource ingestion process management.
|
| com.snowflake.connectors.application.ingestion.update |
Update resource ingestion configuration.
|
| com.snowflake.connectors.application.integration |
Task reactor compatible implementations of the task scheduler.
|
| com.snowflake.connectors.application.lifecycle |
Backend implementations for the connector lifecycle processes.
|
| com.snowflake.connectors.application.lifecycle.pause |
Backend implementations for the connector pausing process.
|
| com.snowflake.connectors.application.lifecycle.resume |
Backend implementations for the connector resuming process.
|
| com.snowflake.connectors.application.observability |
Ingestion observability management.
|
| com.snowflake.connectors.application.observability.exception |
Exceptions for ingestion observability management.
|
| com.snowflake.connectors.application.scheduler |
Task scheduler implementation.
|
| com.snowflake.connectors.application.status |
Connector and connector configuration status management.
|
| com.snowflake.connectors.application.status.exception |
Exceptions for connector and connector configuration status management.
|
| com.snowflake.connectors.common.exception |
Common connector exceptions.
|
| com.snowflake.connectors.common.exception.context |
|
| com.snowflake.connectors.common.exception.helper |
|
| com.snowflake.connectors.common.object |
Representation of Snowflake objects.
|
| com.snowflake.connectors.common.response |
Standard connector response.
|
| com.snowflake.connectors.common.state |
Common connector state management.
|
| com.snowflake.connectors.common.table |
Common data table representations.
|
| com.snowflake.connectors.common.task |
Snowflake task management.
|
| com.snowflake.connectors.taskreactor |
Task reactor dispatcher and utilities.
|
| com.snowflake.connectors.taskreactor.api |
Backend implementation for the Task Reactor API.
|
| com.snowflake.connectors.taskreactor.commands.processor |
Task reactor commands processor.
|
| com.snowflake.connectors.taskreactor.commands.processor.executors |
Task reactor command executors.
|
| com.snowflake.connectors.taskreactor.commands.queue |
Task reactor command queue.
|
| com.snowflake.connectors.taskreactor.config |
Task Reactor instance configuration management.
|
| com.snowflake.connectors.taskreactor.dispatcher |
Task Reactor instance dispatcher management.
|
| com.snowflake.connectors.taskreactor.lifecycle |
Task Reactor lifecycle management.
|
| com.snowflake.connectors.taskreactor.log |
|
| com.snowflake.connectors.taskreactor.queue |
Task reactor queue.
|
| com.snowflake.connectors.taskreactor.queue.cleaner |
Task reactor expired work items cleaner.
|
| com.snowflake.connectors.taskreactor.queue.selector |
Task reactor work selector.
|
| com.snowflake.connectors.taskreactor.registry |
Task reactor instance registry.
|
| com.snowflake.connectors.taskreactor.telemetry |
Task reactor telemetry.
|
| com.snowflake.connectors.taskreactor.troubleshooting |
Task reactor troubleshooting.
|
| com.snowflake.connectors.taskreactor.worker |
Task reactor worker management.
|
| com.snowflake.connectors.taskreactor.worker.ingestion |
Task reactor ingestion.
|
| com.snowflake.connectors.taskreactor.worker.queue |
Task Reactor worker queue.
|
| com.snowflake.connectors.taskreactor.worker.registry |
Task reactor worker registry.
|
| com.snowflake.connectors.taskreactor.worker.simpletask |
Task reactor simple tasks.
|
| com.snowflake.connectors.taskreactor.worker.status |
Task reactor worker status management.
|
| com.snowflake.connectors.util.log |
|
| com.snowflake.connectors.util.snowflake |
Various utilities for Snowflake-related operations.
|
| com.snowflake.connectors.util.snowflake.assertions |
Assertion utilities.
|
| com.snowflake.connectors.util.sql |
Various utilities for SQL operations.
|
| com.snowflake.connectors.util.time |
Utilities for time management.
|
| com.snowflake.connectors.util.variant |
Various utilities for Variant operations. |