Skip to content

Commit 9c817ec

Browse files
author
yanxi0227
committed
Merge branch 'v1.5.0_dev' of github.com:DTStack/flinkStreamSQL into v1.5.0_dev
2 parents b41cc0e + a75a0b7 commit 9c817ec

29 files changed

Lines changed: 2483 additions & 12 deletions

File tree

‎README.md‎

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,8 +10,8 @@
1010

1111
# 已支持
1212
* 源表：kafka 0.9，1.x版本
13-
* 维表：mysql，hbase，mongo，redis
14-
* 结果表：mysql，hbase，elasticsearch5.x，mongo，redis
13+
* 维表：mysql，hbase，mongo，redis,cassandra
14+
* 结果表：mysql，hbase，elasticsearch5.x，mongo，redis,cassandra
1515

1616
# 后续开发计划
1717
* 增加oracle维表，结果表功能
@@ -152,12 +152,14 @@ sh submit.sh -sql D:\sideSql.txt -name xctest -remoteSqlPluginPath /opt/dtstack
152152
* [mysql 结果表插件](docs/mysqlSink.md)
153153
* [mongo 结果表插件](docs/mongoSink.md)
154154
* [redis 结果表插件](docs/redisSink.md)
155+
* [cassandra 结果表插件](docs/cassandraSink.md)
155156

156157
### 2.3 维表插件
157158
* [hbase 维表插件](docs/hbaseSide.md)
158159
* [mysql 维表插件](docs/mysqlSide.md)
159160
* [mongo 维表插件](docs/mongoSide.md)
160161
* [redis 维表插件](docs/redisSide.md)
162+
* [cassandra 维表插件](docs/cassandraSide.md)
161163

162164
## 3 性能指标(新增)
163165

‎cassandra/cassandra-side/cassandra-all-side/pom.xml‎

Lines changed: 88 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,88 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<project xmlns="http://maven.apache.org/POM/4.0.0"
3+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5+
<parent>
6+
<artifactId>sql.side.cassandra</artifactId>
7+
<groupId>com.dtstack.flink</groupId>
8+
<version>1.0-SNAPSHOT</version>
9+
<relativePath>../pom.xml</relativePath>
10+
</parent>
11+
<modelVersion>4.0.0</modelVersion>
12+
13+
<artifactId>sql.side.all.cassandra</artifactId>
14+
<name>cassandra-all-side</name>
15+
16+
<packaging>jar</packaging>
17+
18+
<dependencies>
19+
<dependency>
20+
<groupId>com.dtstack.flink</groupId>
21+
<artifactId>sql.side.cassandra.core</artifactId>
22+
<version>1.0-SNAPSHOT</version>
23+
</dependency>
24+
</dependencies>
25+
26+
<build>
27+
<plugins>
28+
<plugin>
29+
<groupId>org.apache.maven.plugins</groupId>
30+
<artifactId>maven-shade-plugin</artifactId>
31+
<version>1.4</version>
32+
<executions>
33+
<execution>
34+
<phase>package</phase>
35+
<goals>
36+
<goal>shade</goal>
37+
</goals>
38+
<configuration>
39+
<artifactSet>
40+
<excludes>
41+
42+
</excludes>
43+
</artifactSet>
44+
<filters>
45+
<filter>
46+
<artifact>*:*</artifact>
47+
<excludes>
48+
<exclude>META-INF/*.SF</exclude>
49+
<exclude>META-INF/*.DSA</exclude>
50+
<exclude>META-INF/*.RSA</exclude>
51+
</excludes>
52+
</filter>
53+
</filters>
54+
</configuration>
55+
</execution>
56+
</executions>
57+
</plugin>
58+
59+
<plugin>
60+
<artifactId>maven-antrun-plugin</artifactId>
61+
<version>1.2</version>
62+
<executions>
63+
<execution>
64+
<id>copy-resources</id>
65+
<!-- here the phase you need -->
66+
<phase>package</phase>
67+
<goals>
68+
<goal>run</goal>
69+
</goals>
70+
<configuration>
71+
<tasks>
72+
<copy todir="${basedir}/../../../plugins/cassandraallside">
73+
<fileset dir="target/">
74+
<include name="${project.artifactId}-${project.version}.jar" />
75+
</fileset>
76+
</copy>
77+
78+
<move file="${basedir}/../../../plugins/cassandraallside/${project.artifactId}-${project.version}.jar"
79+
tofile="${basedir}/../../../plugins/cassandraallside/${project.name}.jar" />
80+
</tasks>
81+
</configuration>
82+
</execution>
83+
</executions>
84+
</plugin>
85+
</plugins>
86+
</build>
87+
88+
</project>

0 commit comments

Comments
 (0)