GitHub user devtagare reopened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/282
APEXMALHAR-2066 JdbcPolling,idempotent,partitionable
JdbcPolling,idempotent,partitionable #282
You can merge this pull request into a Git repository by running:
$ git pull
Github user devtagare closed the pull request at:
https://github.com/apache/incubator-apex-malhar/pull/282
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if
GitHub user devtagare opened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/282
APEXMALHAR-2066 JdbcPolling,idempotent,partitionable
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/devtagare/incubator-apex
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/233#discussion_r60866562
--- Diff:
library/src/test/java/com/datatorrent/lib/io/fs/HDFSOutputOperatorTest.java ---
@@ -0,0 +1,113 @@
+/**
+ * Licensed to
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/233#discussion_r60866383
--- Diff:
library/src/main/java/com/datatorrent/lib/io/fs/HDFSOutputOperator.java ---
@@ -0,0 +1,393 @@
+/**
+ * Licensed to the
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/233#discussion_r60866308
--- Diff:
library/src/main/java/com/datatorrent/lib/io/fs/HDFSOutputOperator.java ---
@@ -0,0 +1,393 @@
+/**
+ * Licensed to the
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r58004569
--- Diff:
contrib/src/test/java/com/datatorrent/contrib/avro/AvroToPojoTest.java ---
@@ -0,0 +1,294 @@
+/**
+ * Licensed to the
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57970394
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroRecordHelper.java ---
@@ -0,0 +1,120 @@
+/**
+ * Licensed to the
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57965227
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroToPojo.java ---
@@ -0,0 +1,415 @@
+/**
+ * Licensed to the Apache
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57936247
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,164 @@
+/**
+ * Licensed to
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57936223
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroToPojo.java ---
@@ -0,0 +1,415 @@
+/**
+ * Licensed to the Apache
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57934967
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroToPojo.java ---
@@ -0,0 +1,415 @@
+/**
+ * Licensed to the Apache
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57934935
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,164 @@
+/**
+ * Licensed to
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57934571
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroToPojo.java ---
@@ -0,0 +1,415 @@
+/**
+ * Licensed to the Apache
Github user devtagare closed the pull request at:
https://github.com/apache/incubator-apex-malhar/pull/211
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if
GitHub user devtagare reopened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/211
APEXMALHAR-2011-2012 Avro to Pojo & Pojo to Avro converter
Please review changes for Avro to Pojo conversion & back.
Thanks,
Dev
You can merge this pull requ
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57766719
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licensed to
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57766614
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licensed to
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57766680
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licensed to
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57763599
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licensed to
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57763061
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licensed to
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57762934
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licensed to
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/219#discussion_r57661266
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/parquet/ParquetFilePOJOReader.java
---
@@ -0,0 +1,305 @@
+/**
+ * Licensed
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/219#discussion_r57661315
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/parquet/AbstractParquetFileReader.java
---
@@ -0,0 +1,113
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/219#discussion_r57661028
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/parquet/ParquetFilePOJOReader.java
---
@@ -0,0 +1,305 @@
+/**
+ * Licensed
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/219#discussion_r57660735
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/parquet/ParquetFilePOJOReader.java
---
@@ -0,0 +1,305 @@
+/**
+ * Licensed
GitHub user devtagare reopened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/211
APEXMALHAR-2011-2012 Avro to Pojo & Pojo to Avro converter
Please review changes for Avro to Pojo conversion & back.
Thanks,
Dev
You can merge this pull requ
Github user devtagare closed the pull request at:
https://github.com/apache/incubator-apex-malhar/pull/211
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if
GitHub user devtagare reopened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/211
APEXMALHAR-2011-2012 Avro to Pojo & Pojo to Avro converter
Please review changes for Avro to Pojo conversion & back.
Thanks,
Dev
You can merge this pull requ
Github user devtagare closed the pull request at:
https://github.com/apache/incubator-apex-malhar/pull/211
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r56626092
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroRecordHelper.java ---
@@ -114,6 +107,7 @@ private static Object
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r56298492
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroToPojo.java ---
@@ -0,0 +1,428 @@
+/**
+ * Licensed to the Apache
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r56294963
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/PojoToAvro.java ---
@@ -0,0 +1,296 @@
+/**
+ * Licensed to the Apache
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r56294938
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroToPojo.java ---
@@ -0,0 +1,428 @@
+/**
+ * Licensed to the Apache
GitHub user devtagare opened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/211
APEXMALHAR-2011-2012 Avro to Pojo & Pojo to Avro converter
Please review changes for Avro to Pojo conversion & back.
Thanks,
Dev
You can merge this pull reques
GitHub user devtagare opened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/156
MLHR-1881 topic & zookeeper based offset manager for kafka0.8.2
Initial commit for preview & comments.
Clean-up, externalization & tests to follow soon.
You can mer
36 matches
Mail list logo
