Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5441
---
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r168914688
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/ResultStore.java
---
@@ -0,0 +1,124 @@
+/*
+ *
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r168447407
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/PropertyStrings.java
---
@@ -0,0 +1,63 @@
+/*
+ *
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r168440952
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Deployment.java
---
@@ -0,0 +1,95 @@
+/*
+ * Licensed
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r168429967
--- Diff: flink-libraries/flink-sql-client/pom.xml ---
@@ -0,0 +1,149 @@
+
+
+http://maven.apache.org/POM/4.0.0;
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167903512
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/TypedResult.java
---
@@ -0,0 +1,69 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167889717
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliChangelogResultView.java
---
@@ -0,0 +1,284 @@
+/*
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167917093
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167916900
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r16794
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167951055
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/DynamicResult.java
---
@@ -0,0 +1,253 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167953460
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/DynamicResult.java
---
@@ -0,0 +1,253 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167871796
--- Diff: flink-libraries/flink-sql-client/pom.xml ---
@@ -0,0 +1,149 @@
+
+
+http://maven.apache.org/POM/4.0.0;
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167939768
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167914210
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -0,0 +1,121 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167922399
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/ResultStore.java
---
@@ -0,0 +1,124 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167896355
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/CollectTableSink.java
---
@@ -0,0 +1,116 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167949288
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/DynamicResult.java
---
@@ -0,0 +1,253 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167944240
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/ResultStore.java
---
@@ -0,0 +1,124 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167921047
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/PropertyStrings.java
---
@@ -0,0 +1,63 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167871058
--- Diff: flink-libraries/flink-sql-client/pom.xml ---
@@ -0,0 +1,149 @@
+
+
+http://maven.apache.org/POM/4.0.0;
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167953650
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/DynamicResult.java
---
@@ -0,0 +1,253 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167921296
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/PropertyStrings.java
---
@@ -0,0 +1,63 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167912319
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167912662
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167952297
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/DynamicResult.java
---
@@ -0,0 +1,253 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167898913
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167936060
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -0,0 +1,121 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167881723
--- Diff: flink-libraries/flink-sql-client/pom.xml ---
@@ -0,0 +1,149 @@
+
+
+http://maven.apache.org/POM/4.0.0;
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167921412
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/PropertyStrings.java
---
@@ -0,0 +1,63 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167947410
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/DynamicResult.java
---
@@ -0,0 +1,253 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167938697
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167902843
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/TypedResult.java
---
@@ -0,0 +1,69 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167880842
--- Diff: flink-libraries/flink-sql-client/pom.xml ---
@@ -0,0 +1,149 @@
+
+
+http://maven.apache.org/POM/4.0.0;
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167880856
--- Diff: flink-libraries/flink-sql-client/pom.xml ---
@@ -0,0 +1,149 @@
+
+
+http://maven.apache.org/POM/4.0.0;
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167869733
--- Diff: flink-libraries/flink-sql-client/bin/sql-client.sh ---
@@ -0,0 +1,83 @@
+#!/usr/bin/env bash
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167892881
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/CollectTableSink.java
---
@@ -0,0 +1,116 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167882975
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/SqlClient.java
---
@@ -0,0 +1,181 @@
+/*
+ * Licensed to the
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167909635
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167872946
--- Diff: flink-libraries/flink-sql-client/pom.xml ---
@@ -0,0 +1,149 @@
+
+
+http://maven.apache.org/POM/4.0.0;
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167870419
--- Diff: flink-libraries/flink-sql-client/conf/sql-client-defaults.yaml ---
@@ -0,0 +1,47 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167871291
--- Diff: flink-libraries/flink-sql-client/pom.xml ---
@@ -0,0 +1,149 @@
+
+
+http://maven.apache.org/POM/4.0.0;
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167869958
--- Diff: flink-libraries/flink-sql-client/conf/sql-client-defaults.yaml ---
@@ -0,0 +1,47 @@
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/5441
[FLINK-8607] [table] Add a basic embedded SQL CLI client
## What is the purpose of the change
This PR implements the first part of the implementation plan described in
FLIP-24.
44 matches
Mail list logo
