Skip to content

基于antlr4 解析器,支持spark sql, tidb sql, flink sql, Spark/flink jar 运行命令解析器

Notifications You must be signed in to change notification settings

wangyang377/dataworker-sql-parser

This branch is up to date with xunliu/dataworker-sql-parser:master.

Folders and files

NameName
Last commit message
Last commit date

Latest commit

author
binsong.li
Dec 1, 2020
8491b0a · Dec 1, 2020

History

21 Commits
Jul 31, 2020
May 5, 2020
Dec 1, 2020
Jul 12, 2018
Dec 1, 2020
Dec 1, 2020

Repository files navigation

介绍

基于antlr4 statement 解析器,支持spark sql, tidb sql, flink sql, Spark/flink jar 运行命令解析

  1. MySQL
  2. PrestoSQL
  3. PostgreSQL
  4. Spark 3.0
  5. T-SQL
  6. ClickHouse

Spark Structed Streaming sql

create stream TABLE tdl_kafka_users (
    user_name "/name" string,
    age	    int,
    email   string
) WITH (
    kafka.bootstrap.servers = 'xxx.xxx.xxx.xxx:9092',
    kafka.group.id = 'dataworker-stream',
    subscribe = 'users',
    includeHeaders = true,
    startingOffsets = 'latest',
    failOnDataLoss = true,
    format='json'
);

insert into bigdata.test_delta_dt select * from tdl_kafka_users;

-- {name:'zhangsan', age: 28, email:'zhangsan@gmail.com'}

About

基于antlr4 解析器,支持spark sql, tidb sql, flink sql, Spark/flink jar 运行命令解析器

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

  • Java 96.7%
  • ANTLR 2.2%
  • Kotlin 1.1%