Package com.snowflake.connectors.application.integration

Class SchedulerTaskReactorOnIngestionFinishedCallback

java.lang.Object

com.snowflake.connectors.application.integration.SchedulerTaskReactorOnIngestionFinishedCallback

All Implemented Interfaces:

OnIngestionFinishedCallback

public class SchedulerTaskReactorOnIngestionFinishedCallback
extends Object
implements OnIngestionFinishedCallback

Task reactor compatible implementation of OnIngestionFinishedCallback.

Constructor Summary

Constructors

Constructor	Description
SchedulerTaskReactorOnIngestionFinishedCallback(OnIngestionFinishedCallback schedulerCallback)	Creates a new SchedulerTaskReactorOnIngestionFinishedCallback.

Method Summary

Modifier and Type	Method	Description
static SchedulerTaskReactorOnIngestionFinishedCallback	getInstance(Session session)	Returns a new instance of the default callback implementation.
void	onIngestionFinished(String ingestionProcessId, Variant metadata)	Method which is called when Task Reactor finishes an ingestion

Methods inherited from class java.lang.Object

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

Constructor Detail

SchedulerTaskReactorOnIngestionFinishedCallback

public SchedulerTaskReactorOnIngestionFinishedCallback(OnIngestionFinishedCallback schedulerCallback)

Creates a new SchedulerTaskReactorOnIngestionFinishedCallback.

Parameters:

schedulerCallback - scheduler callback for ingestion finish

Method Detail

onIngestionFinished

public void onIngestionFinished(String ingestionProcessId,
                                Variant metadata)

Description copied from interface: OnIngestionFinishedCallback

Method which is called when Task Reactor finishes an ingestion

Specified by:

onIngestionFinished in interface OnIngestionFinishedCallback

Parameters:

ingestionProcessId - id of a work item specified when the work item was inserted to the queue

metadata - payload with additional information that can be shared between work items of the same type

getInstance

public static SchedulerTaskReactorOnIngestionFinishedCallback getInstance(Session session)

Returns a new instance of the default callback implementation.

Default implementation of the callback uses a default implementation of OnIngestionFinishedCallback.

Parameters:

session - Snowpark session object

Returns:

a new callback instance