Ecosyste.ms: Repos
An open API service providing repository metadata for many open source software ecosystems.
GitHub / DTStack / flinkStreamSQL
基于开源的flink，对其实时sql进行扩展；主要实现了流与维表的join，支持原生flink SQL所有的语法
JSON API: https://repos.ecosyste.ms/api/v1/hosts/GitHub/repositories/DTStack%2FflinkStreamSQL
Stars: 1,995
Forks: 928
Open Issues: 87
License: apache-2.0
Language: Java
Repo Size: 6.75 MB
Dependencies:
274
Created: over 5 years ago
Updated: 3 months ago
Last pushed: 3 months ago
Last synced: 3 months ago
Topics: bigdata, flink, sql, stream
Files
Loading...
Readme
Loading...
Dependencies
aws/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- com.dtstack.flink:sql.side.cassandra.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.cassandra.core 1.0-SNAPSHOT
- io.vertx:vertx-core 3.5.2
- io.vertx:vertx-jdbc-client 3.5.2
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
cassandra/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- com.datastax.cassandra:cassandra-driver-core 3.6.0
- com.dtstack.flink:sql.side.clickhouse.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.clickhouse.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT test
- com.dtstack.flink:sql.sink.rdb 1.0-SNAPSHOT
clickhouse/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- ru.yandex.clickhouse:clickhouse-jdbc 0.1.55
console/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
core/pom.xml
maven
- com.fasterxml.jackson.core:jackson-databind 2.11.3
- com.google.guava:guava 19.0
- commons-codec:commons-codec 1.10
- joda-time:joda-time 2.5
- org.apache.flink:flink-cep-scala_2.11 ${flink.version}
- org.apache.flink:flink-shaded-hadoop2 2.7.5-1.8.1
- org.apache.flink:flink-statebackend-rocksdb_2.11 ${flink.version}
- org.apache.flink:flink-streaming-java_2.11 ${flink.version}
- org.apache.flink:flink-streaming-scala_2.11 ${flink.version}
- org.apache.flink:flink-table-api-java-bridge_2.11 ${flink.version}
- org.apache.flink:flink-table-common ${flink.version}
- org.apache.flink:flink-table-planner-blink_2.11 ${flink.version}
- org.apache.flink:flink-table-runtime-blink_2.11 ${flink.version}
- junit:junit 4.12 test
- com.dtstack.flink:sql.side.db2.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.db2.core 1.0-SNAPSHOT
db2/db2-side/pom.xml
maven
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT test
db2/db2-sink/pom.xml
maven
- com.dtstack.flink:sql.sink.rdb 1.0-SNAPSHOT
db2/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- com.ibm.db2.jcc:db2jcc db2jcc4
- log4j:log4j 1.2.17
- junit:junit 4.8.2 test
dirtyData/mysql/pom.xml
maven
- mysql:mysql-connector-java 5.1.46
dirtyData/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- junit:junit 3.8.1 test
- org.apache.flink:flink-connector-elasticsearch-base_2.11 ${flink.version}
- org.apache.flink:flink-connector-elasticsearch5_2.11 ${flink.version}
- org.apache.logging.log4j:log4j-to-slf4j 2.7
- org.elasticsearch.client:transport ${elasticsearch.version}
- org.elasticsearch.client:x-pack-transport ${elasticsearch.version}
- org.slf4j:slf4j-log4j12 1.6.1
elasticsearch5/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- org.apache.flink:flink-table-planner_2.11 ${flink.version} provided
- com.google.protobuf:protobuf-java 3.15.0
- io.transwarp.elasticsearch:elasticsearch-client 5.4.1
- io.transwarp.sasl:guardian-sasl-transwarp 6.2.1
- org.apache.logging.log4j:log4j-to-slf4j 2.7
- org.slf4j:slf4j-log4j12 1.6.1
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- com.dtstack.flink:sql.side.elasticsearch6.core 1.0-SNAPSHOT
- org.elasticsearch.client:elasticsearch-rest-high-level-client ${elasticsearch.version}
- junit:junit 4.12 test
- com.dtstack.flink:sql.side.elasticsearch6.core 1.0-SNAPSHOT
- org.elasticsearch.client:elasticsearch-rest-high-level-client ${elasticsearch.version}
- org.elasticsearch.client:elasticsearch-rest-high-level-client ${elasticsearch.version}
- junit:junit 4.12 test
- org.apache.flink:flink-streaming-java_2.11 ${flink.version} provided
- log4j:log4j 1.2.17
- org.apache.flink:flink-connector-elasticsearch-base_2.11 ${flink.version}
- org.apache.flink:flink-connector-elasticsearch6_2.11 ${flink.version}
- org.elasticsearch.client:elasticsearch-rest-high-level-client ${elasticsearch.version}
- org.slf4j:slf4j-api 1.7.15
- org.slf4j:slf4j-log4j12 1.6.1
elasticsearch6/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- com.dtstack.flink:sql.side.elasticsearch7.core 1.0-SNAPSHOT
- org.elasticsearch.client:elasticsearch-rest-high-level-client ${elasticsearch.version}
- junit:junit 4.12 test
- com.dtstack.flink:sql.side.elasticsearch7.core 1.0-SNAPSHOT
- org.elasticsearch.client:elasticsearch-rest-high-level-client ${elasticsearch.version}
- org.elasticsearch.client:elasticsearch-rest-high-level-client ${elasticsearch.version}
- junit:junit 4.12 test
- org.apache.flink:flink-streaming-java_2.11 ${flink.version} provided
- com.google.code.gson:gson 2.8.5
- log4j:log4j 1.2.17
- org.apache.flink:flink-connector-elasticsearch-base_2.11 ${flink.version}
- org.apache.flink:flink-connector-elasticsearch7_2.11 ${flink.version}
- org.elasticsearch.client:elasticsearch-rest-high-level-client ${elasticsearch.version}
- org.slf4j:slf4j-api 1.7.15
- org.slf4j:slf4j-log4j12 1.6.1
elasticsearch7/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- junit:junit 3.8.1 test
file/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- org.apache.flink:flink-avro ${flink.version}
- org.apache.flink:flink-csv ${flink.version}
- org.apache.flink:flink-json ${flink.version}
- com.dtstack.flink:sql.side.hbase.core 1.0-SNAPSHOT
- org.apache.hbase:hbase-client 1.3.1
- com.dtstack.flink:sql.side.hbase.core 1.0-SNAPSHOT
- org.hbase:asynchbase 1.8.2
hbase/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- org.apache.hbase:hbase-client 1.3.1
http/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- org.apache.httpcomponents:httpclient 4.5.13
- com.dtstack.flink:sql.side.impala.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.impala.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT test
- com.dtstack.flink:sql.sink.rdb 1.0-SNAPSHOT
impala/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- com.cloudera.impala.jdbc:ImpalaJDBC41 2.6.12
- org.apache.hadoop:hadoop-common 2.7.3
kafka/kafka-sink/pom.xml
maven
- com.dtstack.flink:sql.sink.kafka-base 1.0-SNAPSHOT
- com.dtstack.flink:sql.source.kafka-base 1.0-SNAPSHOT
kafka/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- org.apache.flink:flink-connector-kafka_2.11 ${flink.version}
kafka-base/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- org.apache.flink:flink-connector-kafka-0.9_2.11 ${flink.version} provided
- org.apache.flink:flink-avro ${flink.version}
- org.apache.flink:flink-csv ${flink.version}
- org.apache.flink:flink-json ${flink.version}
- com.dtstack.flink:sql.sink.kafka-base 1.0-SNAPSHOT
- com.dtstack.flink:sql.source.kafka-base 1.0-SNAPSHOT
kafka09/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- org.apache.flink:flink-connector-kafka-0.9_2.11 ${flink.version}
- com.dtstack.flink:sql.sink.kafka-base 1.0-SNAPSHOT
- com.dtstack.flink:sql.source.kafka-base 1.0-SNAPSHOT
kafka10/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- org.apache.flink:flink-connector-kafka-0.10_2.11 ${flink.version}
- com.dtstack.flink:sql.sink.kafka-base 1.0-SNAPSHOT
- com.dtstack.flink:sql.source.kafka-base 1.0-SNAPSHOT
kafka11/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- org.apache.flink:flink-connector-kafka-0.11_2.11 ${flink.version}
- com.dtstack.flink:sql.side.kingbase.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.kingbase.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT test
- com.dtstack.flink:sql.sink.rdb 1.0-SNAPSHOT
kingbase/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- com.kingbase8:kingbase8 8.2.0
- com.dtstack.flink:sql.side.kudu.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.kudu.core 1.0-SNAPSHOT
- io.vertx:vertx-core 3.5.2
- io.vertx:vertx-jdbc-client 3.5.2
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
kudu/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- org.apache.kudu:kudu-client 1.10.1
launcher/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT
- log4j:log4j 1.2.17
- org.apache.flink:flink-yarn_2.11 ${flink.version}
- org.slf4j:slf4j-log4j12 1.6.1
localTest/pom.xml
maven
- ch.qos.logback:logback-classic 1.2.0 compile
- com.alibaba:fastjson 1.2.76 compile
- com.alibaba:fastjson 1.2.70 compile
- org.slf4j:slf4j-api 1.6.3 compile
- com.dtstack.flink:console-sink 1.0-SNAPSHOT
- com.dtstack.flink:dirtyConsumer.console 1.0-SNAPSHOT
- com.dtstack.flink:dirtyConsumer.mysql 1.0-SNAPSHOT
- com.dtstack.flink:sql.console 1.0-SNAPSHOT
- com.dtstack.flink:sql.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.hbase 1.0-SNAPSHOT
- com.dtstack.flink:sql.http 1.0-SNAPSHOT
- com.dtstack.flink:sql.impala 1.0-SNAPSHOT
- com.dtstack.flink:sql.kudu 1.0-SNAPSHOT
- com.dtstack.flink:sql.mongo 1.0-SNAPSHOT
- com.dtstack.flink:sql.mysql 1.0-SNAPSHOT
- com.dtstack.flink:sql.oracle 1.0-SNAPSHOT
- com.dtstack.flink:sql.postgresql 1.0-SNAPSHOT
- com.dtstack.flink:sql.redis 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.all.hbase 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.all.impala 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.all.kudu 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.all.mongo 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.all.mysql 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.all.oracle 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.all.postgresql 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.all.redis 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.async.hbase 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.async.impala 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.async.kudu 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.async.mongo 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.async.mysql 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.async.oracle 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.async.postgresql 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.async.redis 1.0-SNAPSHOT
- com.dtstack.flink:sql.sink.hbase 1.0-SNAPSHOT
- com.dtstack.flink:sql.sink.http 1.0-SNAPSHOT
- com.dtstack.flink:sql.sink.impala 1.0-SNAPSHOT
- com.dtstack.flink:sql.sink.kudu 1.0-SNAPSHOT
- com.dtstack.flink:sql.sink.mongo 1.0-SNAPSHOT
- com.dtstack.flink:sql.sink.mysql 1.0-SNAPSHOT
- com.dtstack.flink:sql.sink.oracle 1.0-SNAPSHOT
- com.dtstack.flink:sql.sink.postgresql 1.0-SNAPSHOT
- com.dtstack.flink:sql.sink.redis 1.0-SNAPSHOT
- com.dtstack.flink:sql.source.file 1.0-SNAPSHOT
- com.dtstack.flink:sql.source.kafka-base 1.0-SNAPSHOT
- com.dtstack.flink:sql.source.kafka11 1.0-SNAPSHOT
- junit:junit 4.12 test
- com.dtstack.flink:sql.side.mongo.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.mongo.core 1.0-SNAPSHOT
- io.vertx:vertx-core 3.5.2
- io.vertx:vertx-jdbc-client 3.5.2
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
mongo/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- org.mongodb:mongo-java-driver 3.8.2
- org.mongodb:mongodb-driver-async 3.8.2
- com.dtstack.flink:sql.side.mysql.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.mysql.core 1.0-SNAPSHOT
mysql/mysql-side/pom.xml
maven
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT test
mysql/mysql-sink/pom.xml
maven
- com.dtstack.flink:sql.sink.rdb 1.0-SNAPSHOT
mysql/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- mysql:mysql-connector-java 5.1.46
- com.dtstack.flink:sql.side.oceanbase.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.oceanbase.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT test
- com.dtstack.flink:sql.sink.rdb 1.0-SNAPSHOT
oceanbase/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- mysql:mysql-connector-java 5.1.40
- com.dtstack.flink:sql.side.oracle.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.oracle.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT test
- com.dtstack.flink:sql.sink.rdb 1.0-SNAPSHOT
oracle/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- com.github.noraui:ojdbc8 12.2.0.1
- com.dtstack.flink:sql.side.polardb.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.polardb.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT test
- com.dtstack.flink:sql.sink.rdb 1.0-SNAPSHOT
polardb/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- mysql:mysql-connector-java 8.0.16
pom.xml
maven
- com.alibaba:fastjson 1.2.76
- junit:junit 4.12 test
- org.jacoco:org.jacoco.agent 0.7.8 test
- org.mockito:mockito-core 2.21.0 test
- org.powermock:powermock-api-mockito2 2.0.4 test
- org.powermock:powermock-module-junit4 2.0.4 test
postgresql/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- org.postgresql:postgresql 42.2.2
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT test
- com.dtstack.flink:sql.side.postgresql.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.postgresql.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.sink.rdb 1.0-SNAPSHOT
rdb/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- com.dtstack.flink:sql.core 1.0-SNAPSHOT test
rdb/rdb-side/pom.xml
maven
- com.dtstack.flink:sql.core.rdb 1.0-SNAPSHOT
- io.vertx:vertx-core 3.9.4
- io.vertx:vertx-jdbc-client 3.9.4
rdb/rdb-sink/pom.xml
maven
- com.dtstack.flink:sql.core.rdb 1.0-SNAPSHOT
redis5/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- redis.clients:jedis 2.9.0
- com.dtstack.flink:sql.side.redis.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.redis.core 1.0-SNAPSHOT
- io.lettuce:lettuce-core 5.0.5.RELEASE
- io.netty:netty-all 4.1.24.Final
serversocket/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
solr/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- org.apache.solr:solr-solrj 7.4.0
sqlserver/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- com.microsoft.sqlserver:mssql-jdbc 9.2.1.jre8
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT test
- com.dtstack.flink:sql.side.sqlserver.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.sqlserver.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.sink.rdb 1.0-SNAPSHOT
tidb/pom.xml
maven
- com.dtstack.flink:sql.core 1.0-SNAPSHOT provided
- mysql:mysql-connector-java 5.1.46
tidb/tidb-side/pom.xml
maven
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.rdb 1.0-SNAPSHOT test
- com.dtstack.flink:sql.side.tidb.core 1.0-SNAPSHOT
- com.dtstack.flink:sql.side.tidb.core 1.0-SNAPSHOT
tidb/tidb-sink/pom.xml
maven
- com.dtstack.flink:sql.sink.rdb 1.0-SNAPSHOT
file/file-source/pom.xml
maven
hbase/hbase-side/pom.xml
maven
hbase/hbase-sink/pom.xml
maven
http/http-sink/pom.xml
maven
kudu/kudu-side/pom.xml
maven
kudu/kudu-sink/pom.xml
maven
mongo/mongo-side/pom.xml
maven
mongo/mongo-sink/pom.xml
maven
rdb/rdb-core/pom.xml
maven