Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5758
---
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r179715295
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -29,38 +30,47 @@
/**
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r179686465
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -29,38 +30,47 @@
/**
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r179686471
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/TableDescriptor.scala
---
@@ -0,0 +1,75 @@
+/*
+ * Licensed
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r179182994
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/TableDescriptor.scala
---
@@ -0,0 +1,75 @@
+/*
+ * Licensed
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r179178156
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/TableDescriptor.scala
---
@@ -0,0 +1,75 @@
+/*
+ * License
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r179149794
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -29,38 +30,47 @@
/**
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r179150731
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/TableDescriptor.scala
---
@@ -0,0 +1,75 @@
+/*
+ * Licensed
GitHub user suez1224 reopened a pull request:
https://github.com/apache/flink/pull/5758
[FLINK-9059][Table API & SQL] add table type attribute; replace "sources"
with "tables" in environmâ¦
## What is the purpose of the change
Add support for unified table source and sink
Github user suez1224 closed the pull request at:
https://github.com/apache/flink/pull/5758
---
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r178334028
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -29,38 +30,47 @@
/**
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r178334057
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/TableDescriptor.scala
---
@@ -0,0 +1,75 @@
+/*
+ * License
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r178330131
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/TableDescriptor.scala
---
@@ -0,0 +1,75 @@
+/*
+ * Licensed
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r178244750
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -102,10 +112,10 @@ public static Envi
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r178244473
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -29,38 +30,47 @@
/**
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r177830071
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -102,10 +112,10 @@ public static Env
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r177828794
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -29,38 +30,47 @@
/**
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r177836030
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/TableDescriptor.scala
---
@@ -0,0 +1,75 @@
+/*
+ * License
GitHub user suez1224 opened a pull request:
https://github.com/apache/flink/pull/5758
[FLINK-9059][Table API & SQL] add table type attribute; replace "sources"
with "tables" in environmâ¦
## What is the purpose of the change
Add support for unified table source and sink de
19 matches
Mail list logo