引入排程器参考

数据库对象和过程

以下过程是通过文件 scheduler/scheduler.sql 创建的。

PUBLIC.CREATE_SCHEDULER()

此过程充当 SQL 和 Java 之间的入口点。它将根据 APP_STATE 表中可用的计划创建一个任务运行。执行此任务时，此任务将执行以下 PUBLIC.RUN_SCHEDULER_ITERATION() 过程。

PUBLIC.RUN_SCHEDULER_ITERATION()

此过程是 Java 实施实际计划任务的入口点。每当执行排程器任务时都会调用它。

它需要 com.snowflake:telemetry 包才能向事件表发出指标。

PUBLIC.ON_INGESTION_SCHEDULED (process_id VARCHAR)

此过程定义了排程器执行的单个进程的引入流程。默认实施不起作用。我们建议使用 OnIngestionScheduledCallback 界面在 Java 中实施此过程。

自定义处理程序

引入排程器程序功能由两个不同的处理程序组成，它们充当从 SQL 到 Java 的入口点：

  • CreateSchedulerHandler

  • RunSchedulerIterationHandler

我们建议只对后者进行自定义。

生成器方法

可以使用 RunSchedulerIterationHandlerBuilder 对 RunSchedulerIterationHandler 进行自定义。此辅助对象允许对基础界面进行自定义实施：

  • ConnectorErrorHelper

  • OnIngestionScheduledCallback

如果没有提供，则将使用默认实施。

class CustomOnIngestionScheduledCallback implements OnIngestionScheduledCallback {
    @Override
    public void onIngestionScheduled(String processId) {
        // CUSTOM LOGIC
    }
}

class CustomHandler {

    // Path to this method needs to be specified in the PUBLIC.RUN_SCHEDULER_ITERATION procedure using SQL
    public static Variant runIteration(Session session) {
        return RunSchedulerIterationHandler.builder(session)
            .withOnIngestionScheduledCallback(new CustomOnIngestionScheduledCallback())
            .build()
            .runIteration()
            .toVariant();
    }
}