This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a change to branch dev
in repository
https://gitbox.apache.org/repos/asf/incubator-streampark-quickstart.git
from 5ed17ad Merge pull request #29 from wolfboys/readme
add a2d0e29 add some demo for e2e
add 50ad428 add some demo for e2e
new a36dca4 Merge pull request #30 from SbloodyS/add_demo_for_e2e
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
quickstart-flink/pom.xml | 3 +
.../apacheflinksql_1.16/assembly.xml} | 44 ++++---
.../apacheflinksql_1.16/pom.xml | 78 +++++++++++++
.../src/main/java/JavaFlinkSqlJob.java | 62 ++++++++++
.../apacheflinksql_1.17/assembly.xml} | 44 ++++---
.../apacheflinksql_1.17/pom.xml | 78 +++++++++++++
.../src/main/java/JavaFlinkSqlJob.java | 62 ++++++++++
.../apacheflinksql_1.18/assembly.xml} | 44 ++++---
.../apacheflinksql_1.18/pom.xml | 78 +++++++++++++
.../src/main/java/JavaFlinkSqlJob.java | 62 ++++++++++
.../apacheflinksql_1.19/assembly.xml} | 44 ++++---
.../apacheflinksql_1.19/pom.xml | 78 +++++++++++++
.../src/main/java/JavaFlinkSqlJob.java | 62 ++++++++++
.../{ => apacheflinksql_demo}/pom.xml | 43 ++-----
.../src/main/java}/SocketWindowWordCount.java | 2 -
quickstart-flink/quickstart-apacheflink/pom.xml | 130 ++-------------------
.../src/main/resources/log4j2.properties | 25 ----
17 files changed, 667 insertions(+), 272 deletions(-)
copy quickstart-flink/{quickstart-flinksql/pom.xml =>
quickstart-apacheflink/apacheflinksql_1.16/assembly.xml} (50%)
create mode 100644
quickstart-flink/quickstart-apacheflink/apacheflinksql_1.16/pom.xml
create mode 100644
quickstart-flink/quickstart-apacheflink/apacheflinksql_1.16/src/main/java/JavaFlinkSqlJob.java
copy quickstart-flink/{quickstart-flinksql/pom.xml =>
quickstart-apacheflink/apacheflinksql_1.17/assembly.xml} (50%)
create mode 100644
quickstart-flink/quickstart-apacheflink/apacheflinksql_1.17/pom.xml
create mode 100644
quickstart-flink/quickstart-apacheflink/apacheflinksql_1.17/src/main/java/JavaFlinkSqlJob.java
copy quickstart-flink/{quickstart-flinksql/pom.xml =>
quickstart-apacheflink/apacheflinksql_1.18/assembly.xml} (50%)
create mode 100644
quickstart-flink/quickstart-apacheflink/apacheflinksql_1.18/pom.xml
create mode 100644
quickstart-flink/quickstart-apacheflink/apacheflinksql_1.18/src/main/java/JavaFlinkSqlJob.java
copy quickstart-flink/{quickstart-flinksql/pom.xml =>
quickstart-apacheflink/apacheflinksql_1.19/assembly.xml} (50%)
create mode 100644
quickstart-flink/quickstart-apacheflink/apacheflinksql_1.19/pom.xml
create mode 100644
quickstart-flink/quickstart-apacheflink/apacheflinksql_1.19/src/main/java/JavaFlinkSqlJob.java
copy quickstart-flink/quickstart-apacheflink/{ => apacheflinksql_demo}/pom.xml
(77%)
rename
quickstart-flink/quickstart-apacheflink/{src/main/java/org/apache/streampark/quickstart/flink
=> apacheflinksql_demo/src/main/java}/SocketWindowWordCount.java (98%)
delete mode 100644
quickstart-flink/quickstart-apacheflink/src/main/resources/log4j2.properties
