#apache-flink
Вопрос:
У меня есть точка сохранения мгновения. Я хотел бы подготовить отчет об этом, используя API, предпочтительно на Java. Думая о точке сохранения как о базе данных, я хотел бы перечислить таблицы, схемы таблиц, размер каждой таблицы в терминах строк и байтов и получить статистику по размерам строк в байтах (min, max, average, std. dev. и т. Д.). Описанный здесь API предполагает, что схема бд известна (продолжая аналогию с бд). Есть ли API для этого?
Ответ №1:
Насколько я знаю, Flink не является таким API. обычно точка сохранения не должна быть репортером. Я рекомендую использовать для этого пользовательские метрики. см.: https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/ops/metrics/.(Я действительно хочу добавить комментарий, но у меня недостаточно репутации, надеюсь, это вас не побеспокоит)
Комментарии:
1. Спасибо за ответ. Показатели не совсем соответствуют моему варианту использования, когда у меня есть существующая точка сохранения и я хочу ее изучить. Однако я приму ваш ответ как «нет» на мой вопрос.