You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2016/06/09 19:50:33 UTC

[01/10] storm git commit: expose TextFileReader public

Repository: storm
Updated Branches:
  refs/heads/1.0.x-branch 92b6bcb56 -> 1a50bec2c
  refs/heads/1.x-branch 6aee784d7 -> 71476b48d
  refs/heads/master bd4260e46 -> 02c4f6b40


expose TextFileReader public


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/5fff9cc2
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/5fff9cc2
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/5fff9cc2

Branch: refs/heads/master
Commit: 5fff9cc2438233fbd47757ba7d08a238a6e38fa8
Parents: 671e21e
Author: darionyaphet <da...@gmail.com>
Authored: Sun Jun 5 14:40:35 2016 +0800
Committer: darionyaphet <da...@gmail.com>
Committed: Sun Jun 5 14:40:35 2016 +0800

----------------------------------------------------------------------
 .../src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/5fff9cc2/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java
----------------------------------------------------------------------
diff --git a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java
index ac72d69..6da9860 100644
--- a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java
+++ b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java
@@ -32,7 +32,7 @@ import java.util.List;
 import java.util.Map;
 
 // Todo: Track file offsets instead of line number
-class TextFileReader extends AbstractFileReader {
+public class TextFileReader extends AbstractFileReader {
   public static final String[] defaultFields = {"line"};
   public static final String CHARSET = "hdfsspout.reader.charset";
   public static final String BUFFER_SIZE = "hdfsspout.reader.buffer.bytes";

[09/10] storm git commit: expose TextFileReader public

Posted by pt...@apache.org.
expose TextFileReader public

Signed-off-by: P. Taylor Goetz <pt...@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/195d5bc2
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/195d5bc2
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/195d5bc2

Branch: refs/heads/1.0.x-branch
Commit: 195d5bc2815f6df24d3a6c5a292c8009b8b8b2ae
Parents: 92b6bcb
Author: darionyaphet <da...@gmail.com>
Authored: Sun Jun 5 14:40:35 2016 +0800
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 9 15:41:03 2016 -0400

----------------------------------------------------------------------
 .../src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/195d5bc2/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java
----------------------------------------------------------------------
diff --git a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java
index ac72d69..6da9860 100644
--- a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java
+++ b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java
@@ -32,7 +32,7 @@ import java.util.List;
 import java.util.Map;
 
 // Todo: Track file offsets instead of line number
-class TextFileReader extends AbstractFileReader {
+public class TextFileReader extends AbstractFileReader {
   public static final String[] defaultFields = {"line"};
   public static final String CHARSET = "hdfsspout.reader.charset";
   public static final String BUFFER_SIZE = "hdfsspout.reader.buffer.bytes";

[05/10] storm git commit: Merge branch 'STORM-1882' of github.com:darionyaphet/storm

Posted by pt...@apache.org.
Merge branch 'STORM-1882' of github.com:darionyaphet/storm


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/3d789fc5
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/3d789fc5
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/3d789fc5

Branch: refs/heads/master
Commit: 3d789fc5c922b4ae6e81a12670211b28690651e4
Parents: 2835e37 5fff9cc
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jun 9 15:27:49 2016 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 9 15:27:49 2016 -0400

----------------------------------------------------------------------
 .../src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------

[06/10] storm git commit: add STORM-1882 to changelog

Posted by pt...@apache.org.
add STORM-1882 to changelog


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/02c4f6b4
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/02c4f6b4
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/02c4f6b4

Branch: refs/heads/master
Commit: 02c4f6b40336d79a268fa790881fcd4ed24f5df9
Parents: 3d789fc
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jun 9 15:38:34 2016 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 9 15:38:34 2016 -0400

----------------------------------------------------------------------
 CHANGELOG.md | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/02c4f6b4/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 4556dea..12b120a 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
 ## 2.0.0
+ * STORM-1882: Expose TextFileReader public
  * STORM-1873: Implement alternative behaviour for late tuples
  * STORM-1878: Flux can now handle IStatefulBolts
  * STORM-1864: StormSubmitter should throw respective exceptions and log respective errors forregistered submitter hook invocation

[08/10] storm git commit: add STORM-1882 to changelog

Posted by pt...@apache.org.
add STORM-1882 to changelog


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/71476b48
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/71476b48
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/71476b48

Branch: refs/heads/1.x-branch
Commit: 71476b48d34fe51eee0faf265088cbefe3a5eb3f
Parents: 1d29acd
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jun 9 15:40:30 2016 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 9 15:40:30 2016 -0400

----------------------------------------------------------------------
 CHANGELOG.md | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/71476b48/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index f0ed69a..d01d3ce 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
 ## 1.1.0
+ * STORM-1882: Expose TextFileReader public
  * STORM-1873: Implement alternative behaviour for late tuples
  * STORM-1719: Introduce REST API: Topology metric stats for stream
  * STORM-1887: Fixed help message for set_log_level command

[03/10] storm git commit: Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/storm

Posted by pt...@apache.org.
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/storm


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/eff8c938
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/eff8c938
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/eff8c938

Branch: refs/heads/master
Commit: eff8c9382f78aff15cfed11516991f7e503e9373
Parents: 86ccee4 2c77a20
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Wed Jun 8 11:21:52 2016 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Wed Jun 8 11:21:52 2016 -0400

----------------------------------------------------------------------
 CHANGELOG.md                                    |  3 +
 README.markdown                                 |  1 +
 bin/storm.py                                    | 12 ++--
 .../java/org/apache/storm/flux/FluxBuilder.java |  8 +++
 external/flux/flux-examples/README.md           | 18 ++++++
 .../flux/examples/StatefulWordCounter.java      | 64 ++++++++++++++++++++
 .../resources/simple_stateful_wordcount.yaml    | 60 ++++++++++++++++++
 .../storm/hive/trident/TridentHiveTopology.java | 29 ++++++---
 .../jvm/org/apache/storm/StormSubmitter.java    | 48 +++++++++++----
 .../storm/hooks/SubmitterHookException.java     | 41 +++++++++++++
 10 files changed, 255 insertions(+), 29 deletions(-)
----------------------------------------------------------------------

[02/10] storm git commit: Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/storm

Posted by pt...@apache.org.
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/storm


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/86ccee49
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/86ccee49
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/86ccee49

Branch: refs/heads/master
Commit: 86ccee493768a3cccfa05e2ca30d962c87dd4e67
Parents: e1ce13f a9ef86d
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Mon Jun 6 14:47:38 2016 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Mon Jun 6 14:47:38 2016 -0400

----------------------------------------------------------------------
 CHANGELOG.md                                    |  4 ++
 README.markdown                                 |  1 +
 bin/storm.py                                    | 22 ++++---
 docs/Powered-By.md                              | 10 +++
 .../starter/trident/TridentKafkaWordCount.java  | 67 ++++++++++++++------
 external/storm-kafka/pom.xml                    |  5 ++
 .../src/jvm/org/apache/storm/utils/Utils.java   | 10 ++-
 7 files changed, 87 insertions(+), 32 deletions(-)
----------------------------------------------------------------------

[04/10] storm git commit: Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/storm

Posted by pt...@apache.org.
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/storm


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/2835e37a
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/2835e37a
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/2835e37a

Branch: refs/heads/master
Commit: 2835e37a665178d2b736be8fdb56c182e6a129ac
Parents: eff8c93 bd4260e
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jun 9 15:07:16 2016 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 9 15:07:16 2016 -0400

----------------------------------------------------------------------
 CHANGELOG.md                                    |  1 +
 README.markdown                                 |  2 +-
 docs/Metrics.md                                 | 97 +++++++++++++++++++-
 docs/Windowing.md                               | 24 ++++-
 pom.xml                                         |  9 ++
 .../clj/org/apache/storm/daemon/executor.clj    |  1 +
 storm-core/src/jvm/org/apache/storm/Config.java |  8 ++
 .../storm/topology/WindowedBoltExecutor.java    | 25 ++++-
 .../topology/base/BaseStatefulWindowedBolt.java |  8 ++
 .../storm/topology/base/BaseWindowedBolt.java   | 14 +++
 .../topology/WindowedBoltExecutorTest.java      | 87 +++++++++++++++++-
 11 files changed, 266 insertions(+), 10 deletions(-)
----------------------------------------------------------------------

[07/10] storm git commit: expose TextFileReader public

Posted by pt...@apache.org.
expose TextFileReader public

Signed-off-by: P. Taylor Goetz <pt...@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/1d29acda
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/1d29acda
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/1d29acda

Branch: refs/heads/1.x-branch
Commit: 1d29acdaaedba42f7ce8f73ea241e6ce9579d73a
Parents: 6aee784
Author: darionyaphet <da...@gmail.com>
Authored: Sun Jun 5 14:40:35 2016 +0800
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 9 15:39:07 2016 -0400

----------------------------------------------------------------------
 .../src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/1d29acda/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java
----------------------------------------------------------------------
diff --git a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java
index ac72d69..6da9860 100644
--- a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java
+++ b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java
@@ -32,7 +32,7 @@ import java.util.List;
 import java.util.Map;
 
 // Todo: Track file offsets instead of line number
-class TextFileReader extends AbstractFileReader {
+public class TextFileReader extends AbstractFileReader {
   public static final String[] defaultFields = {"line"};
   public static final String CHARSET = "hdfsspout.reader.charset";
   public static final String BUFFER_SIZE = "hdfsspout.reader.buffer.bytes";

[10/10] storm git commit: add STORM-1882 to changelog

Posted by pt...@apache.org.
add STORM-1882 to changelog


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/1a50bec2
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/1a50bec2
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/1a50bec2

Branch: refs/heads/1.0.x-branch
Commit: 1a50bec2c79667a1422e520abf69e6256634645f
Parents: 195d5bc
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jun 9 15:41:27 2016 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 9 15:41:27 2016 -0400

----------------------------------------------------------------------
 CHANGELOG.md | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/1a50bec2/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index c917c99..fe4a93f 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
 ## 1.0.2
+ * STORM-1882: Expose TextFileReader public
  * STORM-1864 : StormSubmitter should throw respective exceptions and log respective errors for registered submitter hook invocation
  * STORM-1887: Fixed help message for set_log_level command
  * STORM-1878: Flux can now handle IStatefulBolts