Package com.snowflake.connectors.application.integration

Class SchedulerTaskReactorOnIngestionScheduled

java.lang.Object

com.snowflake.connectors.application.integration.SchedulerTaskReactorOnIngestionScheduled

All Implemented Interfaces:

OnIngestionScheduledCallback

public class SchedulerTaskReactorOnIngestionScheduled
extends Object
implements OnIngestionScheduledCallback

Task reactor compatible implementation of OnIngestionScheduledCallback.

Constructor Summary

Constructors

Constructor	Description
SchedulerTaskReactorOnIngestionScheduled(IngestionProcessRepository ingestionProcessRepository, ResourceIngestionDefinitionRepository<VariantResource> resourceIngestionDefinitionRepository, Session session, Identifier taskReactorName)	Creates a new SchedulerTaskReactorOnIngestionScheduled.

Method Summary

Modifier and Type	Method	Description
static SchedulerTaskReactorOnIngestionScheduled	getInstance(Session session, Identifier taskReactorName)	Returns a new instance of the default callback implementation.
void	onIngestionScheduled(String processId)	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

SchedulerTaskReactorOnIngestionScheduled

public SchedulerTaskReactorOnIngestionScheduled(IngestionProcessRepository ingestionProcessRepository,
                                                ResourceIngestionDefinitionRepository<VariantResource> resourceIngestionDefinitionRepository,
                                                Session session,
                                                Identifier taskReactorName)

Creates a new SchedulerTaskReactorOnIngestionScheduled.

Parameters:

ingestionProcessRepository - ingestion process repository

resourceIngestionDefinitionRepository - resource ingestion definition repository

session - Snowpark session object

taskReactorName - task reactor instance name

Method Detail

onIngestionScheduled

public void onIngestionScheduled(String processId)

Description copied from interface: OnIngestionScheduledCallback

Action executed when the next scheduler iteration is run.

Specified by:

onIngestionScheduled in interface OnIngestionScheduledCallback

Parameters:

processId - ingestion process id

getInstance

public static SchedulerTaskReactorOnIngestionScheduled getInstance(Session session,
                                                                   Identifier taskReactorName)

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

Parameters:

session - Snowpark session object

taskReactorName - task reactor instance name

Returns:

a new callback instance