flink-demo

minimum code just run

flink-ds-connector

DataStream API usage

• kafka
• es
• jdbc
• file
  • row string
  • parquet avro
  • avro
  • custom avro

flink-sql-connector

SQL usage

• print
• blackhole
• datagen
• jdbc
  • scan
  • lookup
  • batch sink
  • streaming sink
• es
  • batch sink
  • streaming sink
• hbase
  • lookup
  • scan
  • batch sink
  • streaming sink
• kafka
  • streaming sink
  • scan source
• upsert-kafka
  • streaming sink
  • scan source
• filesystem
  • streaming sink
• hudi
  • you need build hudi and local install
  • be careful the File.separator, replace with Path.SEPARATOR only for windows
  • batch sink and read
  • streaming sink and read
  • cdc
  • cdc docs

how to run sql

• cd flink-sql-parser
• mvn install -Dskip.Tests
• cd ../flink-sql-submitter
• mvn install -Dskip.Tests
• run SqlTest
  • with --sql.path your sql file path