Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4670
---
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 haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140697199
--- Diff: flink-connectors/flink-orc/pom.xml ---
@@ -0,0 +1,152 @@
+
+
+http://maven.apache.org/POM/4.0.0;
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140699375
--- Diff: flink-connectors/flink-orc/pom.xml ---
@@ -0,0 +1,152 @@
+
+
+http://maven.apache.org/POM/4.0.0;
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140698526
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/RowOrcInputFormat.java
---
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140697150
--- Diff: flink-connectors/flink-orc/pom.xml ---
@@ -0,0 +1,152 @@
+
+
+http://maven.apache.org/POM/4.0.0;
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140699402
--- Diff: flink-connectors/flink-orc/pom.xml ---
@@ -0,0 +1,152 @@
+
+
+http://maven.apache.org/POM/4.0.0;
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140699453
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcTableSource.java
---
@@ -0,0 +1,128 @@
+/*
+ * Licensed to the Apache
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140698436
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/RowOrcInputFormat.java
---
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140697285
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcTableSource.java
---
@@ -0,0 +1,128 @@
+/*
+ * Licensed to the Apache
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140699592
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/RowOrcInputFormat.java
---
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140699826
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/RowOrcInputFormat.java
---
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140700434
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcUtils.java ---
@@ -0,0 +1,2229 @@
+/*
+ * Licensed to the Apache Software
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140699131
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcUtils.java ---
@@ -0,0 +1,2229 @@
+/*
+ * Licensed to the Apache Software
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140700095
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/RowOrcInputFormat.java
---
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140697648
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/RowOrcInputFormat.java
---
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140698914
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcUtils.java ---
@@ -0,0 +1,2229 @@
+/*
+ * Licensed to the Apache Software
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140700317
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcUtils.java ---
@@ -0,0 +1,2229 @@
+/*
+ * Licensed to the Apache Software
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140697889
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/RowOrcInputFormat.java
---
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140698040
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/RowOrcInputFormat.java
---
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140699511
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcTableSource.java
---
@@ -0,0 +1,128 @@
+/*
+ * Licensed to the Apache
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140697494
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcTableSource.java
---
@@ -0,0 +1,128 @@
+/*
+ * Licensed to the Apache
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140698379
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/RowOrcInputFormat.java
---
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140699738
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/RowOrcInputFormat.java
---
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140699577
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/RowOrcInputFormat.java
---
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140697367
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcTableSource.java
---
@@ -0,0 +1,128 @@
+/*
+ * Licensed to the Apache
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140699558
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcTableSource.java
---
@@ -0,0 +1,128 @@
+/*
+ * Licensed to the Apache
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4670#discussion_r140699619
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/RowOrcInputFormat.java
---
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache
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
29 matches
Mail list logo
