Github user aniketadnaik commented on the issue:
https://github.com/apache/carbondata/pull/1352
All review comments have been addressed in the latest commit. Please review
and merge.
mvn -T 4C -Pspark-2.1 -Dspark.version=2.1.0 clean verify - Successful
mvn clean verify
Github user aniketadnaik commented on the issue:
https://github.com/apache/carbondata/pull/1352
All review comments have been addressed in previous commit. Please review
and merge.
mvn -T 4C -Pspark-2.1 -Dspark.version=2.1.0 clean verify - Successful
mvn clean verify
Github user aniketadnaik commented on the issue:
https://github.com/apache/carbondata/pull/1352
Please review and merge this PR (Branch: StreamIngest-1174) to
"streaming_ingest" branch.
---
Github user aniketadnaik commented on the issue:
https://github.com/apache/carbondata/pull/1352
* Please merge this PR (Branch: **StreamIngest-1174**) to
"**streaming_ingest**" branch.
* Following is the build and test report
$>mvn -Pspark-2.1 -Dspark.versio
Github user aniketadnaik commented on the issue:
https://github.com/apache/carbondata/pull/1352
Please rebase "streaming_ingest" branch from latest "master" to take care
of presto test failures.
---
Github user aniketadnaik commented on the issue:
https://github.com/apache/carbondata/pull/1352
Please hold off review. Rebase has caused some issue. I'll need to fix it.
---
Github user aniketadnaik commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1352#discussion_r139085031
--- Diff:
core/src/main/java/org/apache/carbondata/core/streaming/CarbonStreamingCommitInfo.java
---
@@ -0,0 +1,108 @@
+/*
+ * Licensed
Github user aniketadnaik commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1352#discussion_r138813656
--- Diff:
examples/spark2/src/main/scala/org/apache/carbondata/examples/streaming/CarbonStreamingIngestFileSourceExample.scala
---
@@ -0,0 +1,132
Github user aniketadnaik commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1352#discussion_r138813473
--- Diff:
examples/spark2/src/main/scala/org/apache/carbondata/examples/utils/StreamingCleanupUtil.scala
---
@@ -0,0 +1,45
Github user aniketadnaik commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1352#discussion_r138813548
--- Diff:
examples/spark2/src/main/scala/org/apache/carbondata/examples/streaming/CarbonStreamingIngestFileSourceExample.scala
---
@@ -0,0 +1,132
Github user aniketadnaik commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1352#discussion_r138813373
--- Diff:
examples/spark2/src/main/scala/org/apache/carbondata/examples/streaming/CarbonStreamingIngestFileSourceExample.scala
---
@@ -0,0 +1,132
Github user aniketadnaik commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1352#discussion_r138813289
--- Diff:
examples/spark2/src/main/scala/org/apache/carbondata/examples/streaming/CarbonStreamingIngestFileSourceExample.scala
---
@@ -0,0 +1,132
Github user aniketadnaik commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1352#discussion_r138813057
--- Diff:
integration/spark2/src/test/scala/org/apache/spark/carbondata/streaming/CarbonSourceSchemaValidationTest.scala
---
@@ -0,0 +1,43
Github user aniketadnaik commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1352#discussion_r138813012
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/CarbonSource.scala ---
@@ -205,19 +220,188 @@ class CarbonSource extends
Github user aniketadnaik commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1352#discussion_r138812980
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/CarbonSource.scala ---
@@ -205,19 +220,188 @@ class CarbonSource extends
GitHub user aniketadnaik opened a pull request:
https://github.com/apache/carbondata/pull/1352
[CARBONDATA-1174] Streaming Ingestion - schema validation and streaming
examples
- Description:
This change is mainly targeted for "streaming_ingest" development branch.
Github user aniketadnaik commented on the issue:
https://github.com/apache/carbondata/pull/1064
This PR is merged to "streaming_ingest" branch. Thanks!
---
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 pr
Github user aniketadnaik closed the pull request at:
https://github.com/apache/carbondata/pull/1064
---
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 the
Github user aniketadnaik commented on the issue:
https://github.com/apache/carbondata/pull/1064
Can someone please merge this PR to "streaming_ingest" branch?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as wel
Github user aniketadnaik commented on the issue:
https://github.com/apache/carbondata/pull/1064
@jackylk, @chenliang613 - All review comments are addressed.
---
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
Github user aniketadnaik commented on the issue:
https://github.com/apache/carbondata/pull/1064
Can someone review the changes ?
---
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
Github user aniketadnaik commented on the issue:
https://github.com/apache/carbondata/pull/1064
@jackylk - Thanks for rebase on streaming_ingest branch . I have rebased
and tested my branch streamIngest-1173 in aniketadnaik/carbondataStreamIngest
repo.
---
If your project is set up
GitHub user aniketadnaik opened a pull request:
https://github.com/apache/carbondata/pull/1064
[CARBONDATA-<1173>] Stream ingestion - write path framework
Description:
This is a over all streaming write path framework implementation. It is
mainly target
23 matches
Mail list logo