tree: f03a63f010c1c47b2c11c5e08773746eeb547f2b [path history] [tgz]
  1. sort-api/
  2. sort-common/
  3. sort-connectors/
  4. sort-core/
  5. sort-dist/
  6. sort-end-to-end-tests/
  7. sort-formats/
  8. pom.xml
  9. quick_start.md
  10. README.md
inlong-sort/README.md

Description

Overview

InLong-Sort is used to extract data from different source systems, then transforms the data and finally loads the data into diffrent storage systems. InLong-Sort is simply a Flink Application, and relys on InLong-Manager to manage meta data(such as the source informations and storage informations).

Features

Supported Extract Node

  • Pulsar
  • MySQL
  • Kafka
  • MongoDB
  • PostgreSQL
  • HDFS

Supported Transform

  • String Split
  • String Regular Replace
  • String Regular Replace First Matched Value
  • Data Filter
  • Data Distinct
  • Regular Join

Supported Load Node

  • Hive
  • Kafka
  • HBase
  • ClickHouse
  • Iceberg
  • PostgreSQL
  • HDFS
  • TDSQL Postgres

Future Plans

More kinds of Extract Node

Oracle, SqlServer, and etc.

More kinds of Transform

Time window aggregation, Content extraction, Type conversion, Time format conversion, and etc.

More kinds of Load Node

Elasticsearch, and etc.