Перейти к основному содержимому

Загрузка данных

📄️ Загрузка данных с использованием транзакционного интерфейса Stream Load

Начиная с версии 1.5.0, Selena предоставляет транзакционный интерфейс Stream Load для реализации двухфазного коммита (2PC) для транзакций, которые выполняются для загрузки данных из внешних систем, таких как Apache Flink® и Apache Kafka®. Транзакционный интерфейс Stream Load помогает улучшить производительность высококонкурентных потоковых загрузок.

📄️ Непрерывная загрузка данных из Apache Flink®

Selena предоставляет собственный коннектор под названием Selena Connector for Apache Flink® (сокращенно Flink коннектор), который помогает загружать данные в таблицу Selena с помощью Flink. Основной принцип заключается в накоплении данных и последующей их загрузке за один раз в Selena через STREAM LOAD.

📄️ Изменение данных через загрузку

Таблицы с первичным ключом, предоставляемые Selena, позволяют вносить изменения в данные таблиц Selena путем выполнения заданий Stream Load, Broker Load или Routine Load. Эти изменения данных включают вставки, обновления и удаления. Однако таблицы с первичным ключом не поддерживают изменение данных с использованием Spark Load или INSERT.