Package com.snowflake.connectors.application.ingestion.definition

Class ResourceIngestionDefinitionRepositoryFactory

java.lang.Object

com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinitionRepositoryFactory

public class ResourceIngestionDefinitionRepositoryFactory
extends Object

Factory for instances of ResourceIngestionDefinitionRepository.

Constructor Summary

Constructors

Constructor	Description
ResourceIngestionDefinitionRepositoryFactory()

Method Summary

Modifier and Type	Method	Description
static <R extends ResourceIngestionDefinition<?,?,?,?>> ResourceIngestionDefinitionRepository<R>	create(Session session, Class<R> resourceClass)	Creates a new instance of the default ResourceIngestionDefinitionRepository implementation, created for the given ResourceIngestionDefinition implementation.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ResourceIngestionDefinitionRepositoryFactory

public ResourceIngestionDefinitionRepositoryFactory()

Method Detail

create

public static <R extends ResourceIngestionDefinition<?,?,?,?>> ResourceIngestionDefinitionRepository<R> create(Session session,
                                                                                                                                 Class<R> resourceClass)

Creates a new instance of the default ResourceIngestionDefinitionRepository implementation, created for the given ResourceIngestionDefinition implementation.

Default implementation of the repository uses:

• default reflection-based resource ingestion definition mapper
• default resource ingestion definition validator
• STATE.RESOURCE_INGESTION_DEFINITION table for data storage

Type Parameters:

R - type of the resource, for which the repository will be created

Parameters:

session - Snowpark session object

resourceClass - implementation of the ResourceIngestionDefinition class

Returns:

new instance of the repository

Throws:

ResourceIngestionDefinitionInstantiationException - when instance of DefaultResourceIngestionDefinitionRepository cannot be created