trino-435：prune worker catalogs

本文主要是介绍trino-435：prune worker catalogs，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一、前言

上一章节我们dynamic catalog restful API开发，其中catalog删除API仅仅在coordinator节点操作就可以了，那么woker几点的catalog是怎么与worker几点保持一致的呢？这一章节就重点介绍prune worker catalogs是如何做到的。

二、coordinator节点CatalogPruneTask类

在该类中存在如下的定时调度任务方法：

@PostConstructpublic void start(){if (enabled && !started.getAndSet(true)) {executor.scheduleWithFixedDelay(() -> {try {pruneWorkerCatalogs();}catch (Throwable e) {// ignore to avoid getting unscheduledlog.warn(e, "Error pruning catalogs");}}, updateInterval.toMillis(), updateInterval.toMillis(), MILLISECONDS);}}

下面的方法将coordinator节点中active catalogs发送给worker节点去触发prune，修剪worker节点的catalog调用的接口为：/v1/task/pruneCatalogs&#

这篇关于trino-435：prune worker catalogs的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---