Github user uybhatti commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r141356723
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcUtils.java ---
@@ -0,0 +1,2229 @@
+/*
+ * Licensed to the Apache
Github user uybhatti commented on the issue:
https://github.com/apache/flink/pull/4660
Hi @fhueske , thanks for your feedback. I have addressed your feedback.
Please take a look on changes.
Thanks, Usman
---
Github user uybhatti commented on a diff in the pull request:
https://github.com/apache/flink/pull/4660#discussion_r141336157
--- Diff: flink-libraries/flink-table/pom.xml ---
@@ -114,6 +114,12 @@ under the License.
joda-time
joda
Github user uybhatti commented on a diff in the pull request:
https://github.com/apache/flink/pull/4660#discussion_r139923268
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/runtime/batch/io/RFCCsvInputFormat.java
---
@@ -0,0 +1,449
Github user uybhatti commented on a diff in the pull request:
https://github.com/apache/flink/pull/4638#discussion_r139692943
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
---
@@ -62,10
Github user uybhatti commented on a diff in the pull request:
https://github.com/apache/flink/pull/4638#discussion_r139665963
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
---
@@ -106,8
Github user uybhatti commented on a diff in the pull request:
https://github.com/apache/flink/pull/4635#discussion_r139661930
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/StreamTableSourceTable.scala
---
@@ -28,48 +29,113 @@ import
Github user uybhatti commented on a diff in the pull request:
https://github.com/apache/flink/pull/4635#discussion_r139630218
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/StreamTableSourceTable.scala
---
@@ -28,48 +29,113 @@ import
GitHub user uybhatti opened a pull request:
https://github.com/apache/flink/pull/4670
[FLINK-2170] [connectors] Add ORC connector for TableSource
## What is the purpose of the change
Currently, we can't read data from ORC files. In this PR, we added the
support to load data
GitHub user uybhatti opened a pull request:
https://github.com/apache/flink/pull/4660
[FLINK-7050][table] Add support of RFC compliant CSV parser for Table Source
## What is the purpose of the change
Currently CsvInputFormat is not compliant with RFC 4180 standards and we
GitHub user uybhatti opened a pull request:
https://github.com/apache/flink/pull/4608
[FLINK-7227][Table API & SQL]Fix the the TableSource predicate pushâ¦
⦠down issue for OR and AND expression with more than 2 predicates
*Thank you very much for contribu
11 matches
Mail list logo
