Package com.snowflake.connectors.application.integration

Class TaskReactorOnIngestionScheduledCallback<I,M,C,D,R extends ResourceIngestionDefinition<I,M,C,D>>

java.lang.Object

com.snowflake.connectors.application.integration.TaskReactorOnIngestionScheduledCallback<I,M,C,D,R>

All Implemented Interfaces:

OnIngestionScheduledCallback

public class TaskReactorOnIngestionScheduledCallback<I,M,C,D,R extends ResourceIngestionDefinition<I,M,C,D>>
extends Object
implements OnIngestionScheduledCallback

Task reactor compatible implementation of OnIngestionScheduledCallback.

Constructor Summary

Constructors

Constructor	Description
TaskReactorOnIngestionScheduledCallback(IngestionProcessRepository ingestionProcessRepository, ResourceIngestionDefinitionRepository<R> resourceIngestionDefinitionRepository, WorkItemQueue workItemQueue)	Creates a new TaskReactorOnIngestionScheduledCallback.

Method Summary

Modifier and Type	Method	Description
static <I,M,C,D,R extends ResourceIngestionDefinition<I,M,C,D>> TaskReactorOnIngestionScheduledCallback<I,M,C,D,R>	getInstance(Session session, Identifier taskReactorName, Class<R> resourceClass)	Returns a new instance of the default callback implementation.
void	onIngestionScheduled(List<String> processIds)	Action executed when the next scheduler iteration is run.

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskReactorOnIngestionScheduledCallback

public TaskReactorOnIngestionScheduledCallback(IngestionProcessRepository ingestionProcessRepository,
                                               ResourceIngestionDefinitionRepository<R> resourceIngestionDefinitionRepository,
                                               WorkItemQueue workItemQueue)

Creates a new TaskReactorOnIngestionScheduledCallback.

Parameters:

ingestionProcessRepository - ingestion process repository

resourceIngestionDefinitionRepository - resource ingestion definition repository

workItemQueue - work item queue repository

Method Detail

onIngestionScheduled

public void onIngestionScheduled(List<String> processIds)

Description copied from interface: OnIngestionScheduledCallback

Action executed when the next scheduler iteration is run.

Specified by:

onIngestionScheduled in interface OnIngestionScheduledCallback

Parameters:

processIds - ingestion process ids

getInstance

public static <I,M,C,D,R extends ResourceIngestionDefinition<I,M,C,D>> TaskReactorOnIngestionScheduledCallback<I,M,C,D,R> getInstance(Session session,
                                                                                                                                                                                                        Identifier taskReactorName,
                                                                                                                                                                                                        Class<R> resourceClass)

Returns a new instance of the default callback implementation.

Default implementation of the creator uses:

• a default implementation of IngestionProcessRepository
• a default implementation of ResourceIngestionDefinitionRepository
• a default implementation of WorkItemQueue

Type Parameters:

I - resource id class, containing properties which identify the resource in the source system

M - resource metadata class, containing additional properties which identify the resource in the source system. The properties can be fetched automatically or calculated by the connector

C - custom ingestion configuration class, containing custom ingestion properties

D - destination configuration class, containing properties describing where the ingested data should be stored

R - ingested resource definition class

Parameters:

session - Snowpark session object

taskReactorName - task reactor instance name

resourceClass - class of the ingested resource definition

Returns:

a new callback instance