В чем разница между StreamExecutionEnvironment и StreamTableEnvironment во Flink

Question

Ну, я новичок ie на Apache Flink и читаю некоторые исходные коды на Inte rnet.

Иногда видел StreamExecutionEnvironment, но видел и StreamTableEnvironment .

Я прочитал официальный do c, но до сих пор не могу понять их разницу.

Более того, я пытаюсь закодировать задание Flink Stream, которое получает данные из Кафки. Какую среду мне следует использовать в этом случае?

Answer 1

A StreamExecutionEnvironment используется с DataStream API. Вам понадобится StreamTableEnvironment, если вы собираетесь использовать таблицу более высокого уровня или SQL API.

Раздел документации по созданию TableEnvironment описывает это более подробно.

Что вы должны использовать, зависит от того, хотите ли вы работать с потоками данных более низкого уровня, или реляционный API более высокого уровня. Оба могут использоваться для реализации задания потоковой передачи, которое читает из Kafka.

Документация включает пару пошаговых руководств по коду, представляющих оба API, которые должны помочь вам выяснить, какой API лучше подходит для вашего варианта использования. См. пошаговое руководство DataStream и пошаговое руководство по таблице .

Чтобы изучить DataStream API, потратьте день на самостоятельное обучение . Также есть обучение для Flink SQL. Оба бесплатны.