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 2015/11/05 20:04:29 UTC
[23/54] [abbrv] [partial] storm git commit: remove files added by
mistake
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/apidocs/stylesheet.css
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/apidocs/stylesheet.css b/_site/target/checkout/examples/storm-starter/target/apidocs/stylesheet.css
deleted file mode 100644
index 6ea9e51..0000000
--- a/_site/target/checkout/examples/storm-starter/target/apidocs/stylesheet.css
+++ /dev/null
@@ -1,29 +0,0 @@
-/* Javadoc style sheet */
-
-/* Define colors, fonts and other style attributes here to override the defaults */
-
-/* Page background color */
-body { background-color: #FFFFFF; color:#000000 }
-
-/* Headings */
-h1 { font-size: 145% }
-
-/* Table colors */
-.TableHeadingColor { background: #CCCCFF; color:#000000 } /* Dark mauve */
-.TableSubHeadingColor { background: #EEEEFF; color:#000000 } /* Light mauve */
-.TableRowColor { background: #FFFFFF; color:#000000 } /* White */
-
-/* Font used in left-hand frame lists */
-.FrameTitleFont { font-size: 100%; font-family: Helvetica, Arial, sans-serif; color:#000000 }
-.FrameHeadingFont { font-size: 90%; font-family: Helvetica, Arial, sans-serif; color:#000000 }
-.FrameItemFont { font-size: 90%; font-family: Helvetica, Arial, sans-serif; color:#000000 }
-
-/* Navigation bar fonts and colors */
-.NavBarCell1 { background-color:#EEEEFF; color:#000000} /* Light mauve */
-.NavBarCell1Rev { background-color:#00008B; color:#FFFFFF} /* Dark Blue */
-.NavBarFont1 { font-family: Arial, Helvetica, sans-serif; color:#000000;color:#000000;}
-.NavBarFont1Rev { font-family: Arial, Helvetica, sans-serif; color:#FFFFFF;color:#FFFFFF;}
-
-.NavBarCell2 { font-family: Arial, Helvetica, sans-serif; background-color:#FFFFFF; color:#000000}
-.NavBarCell3 { font-family: Arial, Helvetica, sans-serif; background-color:#FFFFFF; color:#000000}
-
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/META-INF/DEPENDENCIES
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/META-INF/DEPENDENCIES b/_site/target/checkout/examples/storm-starter/target/classes/META-INF/DEPENDENCIES
deleted file mode 100644
index 56eb7e4..0000000
--- a/_site/target/checkout/examples/storm-starter/target/classes/META-INF/DEPENDENCIES
+++ /dev/null
@@ -1,23 +0,0 @@
-// ------------------------------------------------------------------
-// Transitive dependencies of this project determined from the
-// maven pom organized by organization.
-// ------------------------------------------------------------------
-
-storm-starter
-
-
-From: 'an unknown organization'
- - Guava: Google Core Libraries for Java (http://code.google.com/p/guava-libraries/guava) com.google.guava:guava:bundle:16.0.1
- License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt)
- - twitter4j-core (http://twitter4j.org/) org.twitter4j:twitter4j-core:jar:3.0.3
- License: Apache License 2.0 (http://www.apache.org/licenses/LICENSE-2.0)
- - twitter4j-stream (http://twitter4j.org/) org.twitter4j:twitter4j-stream:jar:3.0.3
- License: Apache License 2.0 (http://www.apache.org/licenses/LICENSE-2.0)
-
-From: 'The Apache Software Foundation' (http://www.apache.org/)
- - Commons Collections (http://commons.apache.org/collections/) commons-collections:commons-collections:jar:3.2.1
- License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt)
-
-
-
-
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/META-INF/LICENSE
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/META-INF/LICENSE b/_site/target/checkout/examples/storm-starter/target/classes/META-INF/LICENSE
deleted file mode 100644
index d645695..0000000
--- a/_site/target/checkout/examples/storm-starter/target/classes/META-INF/LICENSE
+++ /dev/null
@@ -1,202 +0,0 @@
-
- Apache License
- Version 2.0, January 2004
- http://www.apache.org/licenses/
-
- TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
-
- 1. Definitions.
-
- "License" shall mean the terms and conditions for use, reproduction,
- and distribution as defined by Sections 1 through 9 of this document.
-
- "Licensor" shall mean the copyright owner or entity authorized by
- the copyright owner that is granting the License.
-
- "Legal Entity" shall mean the union of the acting entity and all
- other entities that control, are controlled by, or are under common
- control with that entity. For the purposes of this definition,
- "control" means (i) the power, direct or indirect, to cause the
- direction or management of such entity, whether by contract or
- otherwise, or (ii) ownership of fifty percent (50%) or more of the
- outstanding shares, or (iii) beneficial ownership of such entity.
-
- "You" (or "Your") shall mean an individual or Legal Entity
- exercising permissions granted by this License.
-
- "Source" form shall mean the preferred form for making modifications,
- including but not limited to software source code, documentation
- source, and configuration files.
-
- "Object" form shall mean any form resulting from mechanical
- transformation or translation of a Source form, including but
- not limited to compiled object code, generated documentation,
- and conversions to other media types.
-
- "Work" shall mean the work of authorship, whether in Source or
- Object form, made available under the License, as indicated by a
- copyright notice that is included in or attached to the work
- (an example is provided in the Appendix below).
-
- "Derivative Works" shall mean any work, whether in Source or Object
- form, that is based on (or derived from) the Work and for which the
- editorial revisions, annotations, elaborations, or other modifications
- represent, as a whole, an original work of authorship. For the purposes
- of this License, Derivative Works shall not include works that remain
- separable from, or merely link (or bind by name) to the interfaces of,
- the Work and Derivative Works thereof.
-
- "Contribution" shall mean any work of authorship, including
- the original version of the Work and any modifications or additions
- to that Work or Derivative Works thereof, that is intentionally
- submitted to Licensor for inclusion in the Work by the copyright owner
- or by an individual or Legal Entity authorized to submit on behalf of
- the copyright owner. For the purposes of this definition, "submitted"
- means any form of electronic, verbal, or written communication sent
- to the Licensor or its representatives, including but not limited to
- communication on electronic mailing lists, source code control systems,
- and issue tracking systems that are managed by, or on behalf of, the
- Licensor for the purpose of discussing and improving the Work, but
- excluding communication that is conspicuously marked or otherwise
- designated in writing by the copyright owner as "Not a Contribution."
-
- "Contributor" shall mean Licensor and any individual or Legal Entity
- on behalf of whom a Contribution has been received by Licensor and
- subsequently incorporated within the Work.
-
- 2. Grant of Copyright License. Subject to the terms and conditions of
- this License, each Contributor hereby grants to You a perpetual,
- worldwide, non-exclusive, no-charge, royalty-free, irrevocable
- copyright license to reproduce, prepare Derivative Works of,
- publicly display, publicly perform, sublicense, and distribute the
- Work and such Derivative Works in Source or Object form.
-
- 3. Grant of Patent License. Subject to the terms and conditions of
- this License, each Contributor hereby grants to You a perpetual,
- worldwide, non-exclusive, no-charge, royalty-free, irrevocable
- (except as stated in this section) patent license to make, have made,
- use, offer to sell, sell, import, and otherwise transfer the Work,
- where such license applies only to those patent claims licensable
- by such Contributor that are necessarily infringed by their
- Contribution(s) alone or by combination of their Contribution(s)
- with the Work to which such Contribution(s) was submitted. If You
- institute patent litigation against any entity (including a
- cross-claim or counterclaim in a lawsuit) alleging that the Work
- or a Contribution incorporated within the Work constitutes direct
- or contributory patent infringement, then any patent licenses
- granted to You under this License for that Work shall terminate
- as of the date such litigation is filed.
-
- 4. Redistribution. You may reproduce and distribute copies of the
- Work or Derivative Works thereof in any medium, with or without
- modifications, and in Source or Object form, provided that You
- meet the following conditions:
-
- (a) You must give any other recipients of the Work or
- Derivative Works a copy of this License; and
-
- (b) You must cause any modified files to carry prominent notices
- stating that You changed the files; and
-
- (c) You must retain, in the Source form of any Derivative Works
- that You distribute, all copyright, patent, trademark, and
- attribution notices from the Source form of the Work,
- excluding those notices that do not pertain to any part of
- the Derivative Works; and
-
- (d) If the Work includes a "NOTICE" text file as part of its
- distribution, then any Derivative Works that You distribute must
- include a readable copy of the attribution notices contained
- within such NOTICE file, excluding those notices that do not
- pertain to any part of the Derivative Works, in at least one
- of the following places: within a NOTICE text file distributed
- as part of the Derivative Works; within the Source form or
- documentation, if provided along with the Derivative Works; or,
- within a display generated by the Derivative Works, if and
- wherever such third-party notices normally appear. The contents
- of the NOTICE file are for informational purposes only and
- do not modify the License. You may add Your own attribution
- notices within Derivative Works that You distribute, alongside
- or as an addendum to the NOTICE text from the Work, provided
- that such additional attribution notices cannot be construed
- as modifying the License.
-
- You may add Your own copyright statement to Your modifications and
- may provide additional or different license terms and conditions
- for use, reproduction, or distribution of Your modifications, or
- for any such Derivative Works as a whole, provided Your use,
- reproduction, and distribution of the Work otherwise complies with
- the conditions stated in this License.
-
- 5. Submission of Contributions. Unless You explicitly state otherwise,
- any Contribution intentionally submitted for inclusion in the Work
- by You to the Licensor shall be under the terms and conditions of
- this License, without any additional terms or conditions.
- Notwithstanding the above, nothing herein shall supersede or modify
- the terms of any separate license agreement you may have executed
- with Licensor regarding such Contributions.
-
- 6. Trademarks. This License does not grant permission to use the trade
- names, trademarks, service marks, or product names of the Licensor,
- except as required for reasonable and customary use in describing the
- origin of the Work and reproducing the content of the NOTICE file.
-
- 7. Disclaimer of Warranty. Unless required by applicable law or
- agreed to in writing, Licensor provides the Work (and each
- Contributor provides its Contributions) on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- implied, including, without limitation, any warranties or conditions
- of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
- PARTICULAR PURPOSE. You are solely responsible for determining the
- appropriateness of using or redistributing the Work and assume any
- risks associated with Your exercise of permissions under this License.
-
- 8. Limitation of Liability. In no event and under no legal theory,
- whether in tort (including negligence), contract, or otherwise,
- unless required by applicable law (such as deliberate and grossly
- negligent acts) or agreed to in writing, shall any Contributor be
- liable to You for damages, including any direct, indirect, special,
- incidental, or consequential damages of any character arising as a
- result of this License or out of the use or inability to use the
- Work (including but not limited to damages for loss of goodwill,
- work stoppage, computer failure or malfunction, or any and all
- other commercial damages or losses), even if such Contributor
- has been advised of the possibility of such damages.
-
- 9. Accepting Warranty or Additional Liability. While redistributing
- the Work or Derivative Works thereof, You may choose to offer,
- and charge a fee for, acceptance of support, warranty, indemnity,
- or other liability obligations and/or rights consistent with this
- License. However, in accepting such obligations, You may act only
- on Your own behalf and on Your sole responsibility, not on behalf
- of any other Contributor, and only if You agree to indemnify,
- defend, and hold each Contributor harmless for any liability
- incurred by, or claims asserted against, such Contributor by reason
- of your accepting any such warranty or additional liability.
-
- END OF TERMS AND CONDITIONS
-
- APPENDIX: How to apply the Apache License to your work.
-
- To apply the Apache License to your work, attach the following
- boilerplate notice, with the fields enclosed by brackets "[]"
- replaced with your own identifying information. (Don't include
- the brackets!) The text should be enclosed in the appropriate
- comment syntax for the file format. We also recommend that a
- file or class name and description of purpose be included on the
- same "printed page" as the copyright notice for easier
- identification within third-party archives.
-
- Copyright [yyyy] [name of copyright owner]
-
- Licensed under the Apache License, Version 2.0 (the "License");
- you may not use this file except in compliance with the License.
- You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/META-INF/NOTICE
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/META-INF/NOTICE b/_site/target/checkout/examples/storm-starter/target/classes/META-INF/NOTICE
deleted file mode 100644
index 1eb697c..0000000
--- a/_site/target/checkout/examples/storm-starter/target/classes/META-INF/NOTICE
+++ /dev/null
@@ -1,8 +0,0 @@
-
-storm-starter
-Copyright 2015 The Apache Software Foundation
-
-This product includes software developed at
-The Apache Software Foundation (http://www.apache.org/).
-
-
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval15$reify__16.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval15$reify__16.class b/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval15$reify__16.class
deleted file mode 100644
index c4167ec..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval15$reify__16.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval15.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval15.class b/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval15.class
deleted file mode 100644
index bbff473..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval15.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval2$fn__3.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval2$fn__3.class b/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval2$fn__3.class
deleted file mode 100644
index a3ce834..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval2$fn__3.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval2$fn__8.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval2$fn__8.class b/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval2$fn__8.class
deleted file mode 100644
index 7b2b5f5..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval2$fn__8.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval2.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval2.class b/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval2.class
deleted file mode 100644
index 34ff10e..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/clojure/tools/logging$eval2.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/resources/asyncSplitsentence.js
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/resources/asyncSplitsentence.js b/_site/target/checkout/examples/storm-starter/target/classes/resources/asyncSplitsentence.js
deleted file mode 100644
index 66fc75e..0000000
--- a/_site/target/checkout/examples/storm-starter/target/classes/resources/asyncSplitsentence.js
+++ /dev/null
@@ -1,50 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * Example for async bolt. Receives sentence and breaks it into words.
- *
- */
-
-
-var storm = require('./storm');
-var BasicBolt = storm.BasicBolt;
-
-function SplitSentenceBolt() {
- BasicBolt.call(this);
-};
-
-SplitSentenceBolt.prototype = Object.create(BasicBolt.prototype);
-SplitSentenceBolt.prototype.constructor = SplitSentenceBolt;
-
-SplitSentenceBolt.prototype.process = function(tup, done) {
- var self = this;
-
- // Here setTimeout is not really needed, we use it to demonstrate asynchronous code in the process method:
- setTimeout(function() {
- var words = tup.values[0].split(" ");
- words.forEach(function(word) {
- self.emit({tuple: [word], anchorTupleId: tup.id}, function(taskIds) {
- self.log(word + ' sent to task ids - ' + taskIds);
- });
- });
- done();
- }, 5000)
-}
-
-new SplitSentenceBolt().run();
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/resources/randomsentence.js
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/resources/randomsentence.js b/_site/target/checkout/examples/storm-starter/target/classes/resources/randomsentence.js
deleted file mode 100644
index 36fc5f5..0000000
--- a/_site/target/checkout/examples/storm-starter/target/classes/resources/randomsentence.js
+++ /dev/null
@@ -1,93 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * Example for storm spout. Emits random sentences.
- * The original class in java - storm.starter.spout.RandomSentenceSpout.
- *
- */
-
-var storm = require('./storm');
-var Spout = storm.Spout;
-
-
-var SENTENCES = [
- "the cow jumped over the moon",
- "an apple a day keeps the doctor away",
- "four score and seven years ago",
- "snow white and the seven dwarfs",
- "i am at two with nature"]
-
-function RandomSentenceSpout(sentences) {
- Spout.call(this);
- this.runningTupleId = 0;
- this.sentences = sentences;
- this.pending = {};
-};
-
-RandomSentenceSpout.prototype = Object.create(Spout.prototype);
-RandomSentenceSpout.prototype.constructor = RandomSentenceSpout;
-
-RandomSentenceSpout.prototype.getRandomSentence = function() {
- return this.sentences[getRandomInt(0, this.sentences.length - 1)];
-}
-
-RandomSentenceSpout.prototype.nextTuple = function(done) {
- var self = this;
- var sentence = this.getRandomSentence();
- var tup = [sentence];
- var id = this.createNextTupleId();
- this.pending[id] = tup;
- //This timeout can be removed if TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS is configured to 100
- setTimeout(function() {
- self.emit({tuple: tup, id: id}, function(taskIds) {
- self.log(tup + ' sent to task ids - ' + taskIds);
- });
- done();
- },100);
-}
-
-RandomSentenceSpout.prototype.createNextTupleId = function() {
- var id = this.runningTupleId;
- this.runningTupleId++;
- return id;
-}
-
-RandomSentenceSpout.prototype.ack = function(id, done) {
- this.log('Received ack for - ' + id);
- delete this.pending[id];
- done();
-}
-
-RandomSentenceSpout.prototype.fail = function(id, done) {
- var self = this;
- this.log('Received fail for - ' + id + '. Retrying.');
- this.emit({tuple: this.pending[id], id:id}, function(taskIds) {
- self.log(self.pending[id] + ' sent to task ids - ' + taskIds);
- });
- done();
-}
-
-/**
- * Returns a random integer between min (inclusive) and max (inclusive)
- */
-function getRandomInt(min, max) {
- return Math.floor(Math.random() * (max - min + 1)) + min;
-}
-
-new RandomSentenceSpout(SENTENCES).run();
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/resources/splitsentence.js
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/resources/splitsentence.js b/_site/target/checkout/examples/storm-starter/target/classes/resources/splitsentence.js
deleted file mode 100644
index e3a8636..0000000
--- a/_site/target/checkout/examples/storm-starter/target/classes/resources/splitsentence.js
+++ /dev/null
@@ -1,44 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * Bolt example - receives sentence and breaks it into words.
- */
-
-var storm = require('./storm');
-var BasicBolt = storm.BasicBolt;
-
-function SplitSentenceBolt() {
- BasicBolt.call(this);
-};
-
-SplitSentenceBolt.prototype = Object.create(BasicBolt.prototype);
-SplitSentenceBolt.prototype.constructor = SplitSentenceBolt;
-
-SplitSentenceBolt.prototype.process = function(tup, done) {
- var self = this;
- var words = tup.values[0].split(" ");
- words.forEach(function(word) {
- self.emit({tuple: [word], anchorTupleId: tup.id}, function(taskIds) {
- self.log(word + ' sent to task ids - ' + taskIds);
- });
- });
- done();
-}
-
-new SplitSentenceBolt().run();
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/resources/splitsentence.py
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/resources/splitsentence.py b/_site/target/checkout/examples/storm-starter/target/classes/resources/splitsentence.py
deleted file mode 100644
index 300105f..0000000
--- a/_site/target/checkout/examples/storm-starter/target/classes/resources/splitsentence.py
+++ /dev/null
@@ -1,24 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-import storm
-
-class SplitSentenceBolt(storm.BasicBolt):
- def process(self, tup):
- words = tup.values[0].split(" ")
- for word in words:
- storm.emit([word])
-
-SplitSentenceBolt().run()
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/resources/splitsentence.rb
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/resources/splitsentence.rb b/_site/target/checkout/examples/storm-starter/target/classes/resources/splitsentence.rb
deleted file mode 100644
index 6d1d246..0000000
--- a/_site/target/checkout/examples/storm-starter/target/classes/resources/splitsentence.rb
+++ /dev/null
@@ -1,26 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-require "./storm"
-
-class SplitSentenceBolt < Storm::Bolt
- def process(tup)
- tup.values[0].split(" ").each do |word|
- emit([word])
- end
- end
-end
-
-SplitSentenceBolt.new.run
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/resources/storm.js
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/resources/storm.js b/_site/target/checkout/examples/storm-starter/target/classes/resources/storm.js
deleted file mode 100644
index 355c2d2..0000000
--- a/_site/target/checkout/examples/storm-starter/target/classes/resources/storm.js
+++ /dev/null
@@ -1,373 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * Base classes in node-js for storm Bolt and Spout.
- * Implements the storm multilang protocol for nodejs.
- */
-
-
-var fs = require('fs');
-
-function Storm() {
- this.messagePart = "";
- this.taskIdsCallbacks = [];
- this.isFirstMessage = true;
- this.separator = '\nend\n';
-}
-
-Storm.prototype.sendMsgToParent = function(msg) {
- var str = JSON.stringify(msg);
- process.stdout.write(str + this.separator);
-}
-
-Storm.prototype.sync = function() {
- this.sendMsgToParent({"command":"sync"});
-}
-
-Storm.prototype.sendPid = function(heartbeatdir) {
- var pid = process.pid;
- fs.closeSync(fs.openSync(heartbeatdir + "/" + pid, "w"));
- this.sendMsgToParent({"pid": pid})
-}
-
-Storm.prototype.log = function(msg) {
- this.sendMsgToParent({"command": "log", "msg": msg});
-}
-
-Storm.prototype.initSetupInfo = function(setupInfo) {
- var self = this;
- var callback = function() {
- self.sendPid(setupInfo['pidDir']);
- }
- this.initialize(setupInfo['conf'], setupInfo['context'], callback);
-}
-
-Storm.prototype.startReadingInput = function() {
- var self = this;
- process.stdin.on('readable', function() {
- var chunk = process.stdin.read();
- var messages = self.handleNewChunk(chunk);
- messages.forEach(function(message) {
- self.handleNewMessage(message);
- })
-
- });
-}
-
-/**
- * receives a new string chunk and returns a list of new messages with the separator removed
- * stores state in this.messagePart
- * @param chunk
- */
-Storm.prototype.handleNewChunk = function(chunk) {
- //invariant: this.messagePart has no separator otherwise we would have parsed it already
- var messages = [];
- if (chunk && chunk.length !== 0) {
- //"{}".split("\nend\n") ==> ['{}']
- //"\nend\n".split("\nend\n") ==> ['' , '']
- //"{}\nend\n".split("\nend\n") ==> ['{}', '']
- //"\nend\n{}".split("\nend\n") ==> ['' , '{}']
- // "{}\nend\n{}".split("\nend\n") ==> ['{}', '{}' ]
- this.messagePart = this.messagePart + chunk;
- var newMessageParts = this.messagePart.split(this.separator);
- while (newMessageParts.length > 0) {
- var potentialMessage = newMessageParts.shift();
- var anotherMessageAhead = newMessageParts.length > 0;
- if (!anotherMessageAhead) {
- this.messagePart = potentialMessage;
- }
- else if (potentialMessage.length > 0) {
- messages.push(potentialMessage);
- }
- }
- }
- return messages;
-}
-
-Storm.prototype.isTaskIds = function(msg) {
- return (msg instanceof Array);
-}
-
-Storm.prototype.handleNewMessage = function(msg) {
- var parsedMsg = JSON.parse(msg);
-
- if (this.isFirstMessage) {
- this.initSetupInfo(parsedMsg);
- this.isFirstMessage = false;
- } else if (this.isTaskIds(parsedMsg)) {
- this.handleNewTaskId(parsedMsg);
- } else {
- this.handleNewCommand(parsedMsg);
- }
-}
-
-Storm.prototype.handleNewTaskId = function(taskIds) {
- //When new list of task ids arrives, the callback that was passed with the corresponding emit should be called.
- //Storm assures that the task ids will be sent in the same order as their corresponding emits so it we can simply
- //take the first callback in the list and be sure it is the right one.
-
- var callback = this.taskIdsCallbacks.shift();
- if (callback) {
- callback(taskIds);
- } else {
- throw new Error('Something went wrong, we off the split of task id callbacks');
- }
-}
-
-
-
-/**
- *
- * @param messageDetails json with the emit details.
- *
- * For bolt, the json must contain the required fields:
- * - tuple - the value to emit
- * - anchorTupleId - the value of the anchor tuple (the input tuple that lead to this emit). Used to track the source
- * tuple and return ack when all components successfully finished to process it.
- * and may contain the optional fields:
- * - stream (if empty - emit to default stream)
- *
- * For spout, the json must contain the required fields:
- * - tuple - the value to emit
- *
- * and may contain the optional fields:
- * - id - pass id for reliable emit (and receive ack/fail later).
- * - stream - if empty - emit to default stream.
- *
- * @param onTaskIds function than will be called with list of task ids the message was emitted to (when received).
- */
-Storm.prototype.emit = function(messageDetails, onTaskIds) {
- //Every emit triggers a response - list of task ids to which the tuple was emitted. The task ids are accessible
- //through the callback (will be called when the response arrives). The callback is stored in a list until the
- //corresponding task id list arrives.
- if (messageDetails.task) {
- throw new Error('Illegal input - task. To emit to specific task use emit direct!');
- }
-
- if (!onTaskIds) {
- throw new Error('You must pass a onTaskIds callback when using emit!')
- }
-
- this.taskIdsCallbacks.push(onTaskIds);
- this.__emit(messageDetails);;
-}
-
-
-/**
- * Emit message to specific task.
- * @param messageDetails json with the emit details.
- *
- * For bolt, the json must contain the required fields:
- * - tuple - the value to emit
- * - anchorTupleId - the value of the anchor tuple (the input tuple that lead to this emit). Used to track the source
- * tuple and return ack when all components successfully finished to process it.
- * - task - indicate the task to send the tuple to.
- * and may contain the optional fields:
- * - stream (if empty - emit to default stream)
- *
- * For spout, the json must contain the required fields:
- * - tuple - the value to emit
- * - task - indicate the task to send the tuple to.
- * and may contain the optional fields:
- * - id - pass id for reliable emit (and receive ack/fail later).
- * - stream - if empty - emit to default stream.
- *
- * @param onTaskIds function than will be called with list of task ids the message was emitted to (when received).
- */
-Storm.prototype.emitDirect = function(commandDetails) {
- if (!commandDetails.task) {
- throw new Error("Emit direct must receive task id!")
- }
- this.__emit(commandDetails);
-}
-
-/**
- * Initialize storm component according to the configuration received.
- * @param conf configuration object accrding to storm protocol.
- * @param context context object according to storm protocol.
- * @param done callback. Call this method when finished initializing.
- */
-Storm.prototype.initialize = function(conf, context, done) {
- done();
-}
-
-Storm.prototype.run = function() {
- process.stdout.setEncoding('utf8');
- process.stdin.setEncoding('utf8');
- this.startReadingInput();
-}
-
-function Tuple(id, component, stream, task, values) {
- this.id = id;
- this.component = component;
- this.stream = stream;
- this.task = task;
- this.values = values;
-}
-
-/**
- * Base class for storm bolt.
- * To create a bolt implement 'process' method.
- * You may also implement initialize method to
- */
-function BasicBolt() {
- Storm.call(this);
- this.anchorTuple = null;
-};
-
-BasicBolt.prototype = Object.create(Storm.prototype);
-BasicBolt.prototype.constructor = BasicBolt;
-
-/**
- * Emit message.
- * @param commandDetails json with the required fields:
- * - tuple - the value to emit
- * - anchorTupleId - the value of the anchor tuple (the input tuple that lead to this emit). Used to track the source
- * tuple and return ack when all components successfully finished to process it.
- * and the optional fields:
- * - stream (if empty - emit to default stream)
- * - task (pass only to emit to specific task)
- */
-BasicBolt.prototype.__emit = function(commandDetails) {
- var self = this;
-
- var message = {
- command: "emit",
- tuple: commandDetails.tuple,
- stream: commandDetails.stream,
- task: commandDetails.task,
- anchors: [commandDetails.anchorTupleId]
- };
-
- this.sendMsgToParent(message);
-}
-
-BasicBolt.prototype.handleNewCommand = function(command) {
- var self = this;
- var tup = new Tuple(command["id"], command["comp"], command["stream"], command["task"], command["tuple"]);
-
- if (tup.task === -1 && tup.stream === "__heartbeat") {
- self.sync();
- return;
- }
-
- var callback = function(err) {
- if (err) {
- self.fail(tup, err);
- return;
- }
- self.ack(tup);
- }
- this.process(tup, callback);
-}
-
-/**
- * Implement this method when creating a bolt. This is the main method that provides the logic of the bolt (what
- * should it do?).
- * @param tuple the input of the bolt - what to process.
- * @param done call this method when done processing.
- */
-BasicBolt.prototype.process = function(tuple, done) {};
-
-BasicBolt.prototype.ack = function(tup) {
- this.sendMsgToParent({"command": "ack", "id": tup.id});
-}
-
-BasicBolt.prototype.fail = function(tup, err) {
- this.sendMsgToParent({"command": "fail", "id": tup.id});
-}
-
-
-/**
- * Base class for storm spout.
- * To create a spout implement the following methods: nextTuple, ack and fail (nextTuple - mandatory, ack and fail
- * can stay empty).
- * You may also implement initialize method.
- *
- */
-function Spout() {
- Storm.call(this);
-};
-
-Spout.prototype = Object.create(Storm.prototype);
-
-Spout.prototype.constructor = Spout;
-
-/**
- * This method will be called when an ack is received for preciously sent tuple. One may implement it.
- * @param id The id of the tuple.
- * @param done Call this method when finished and ready to receive more tuples.
- */
-Spout.prototype.ack = function(id, done) {};
-
-/**
- * This method will be called when an fail is received for preciously sent tuple. One may implement it (for example -
- * log the failure or send the tuple again).
- * @param id The id of the tuple.
- * @param done Call this method when finished and ready to receive more tuples.
- */
-Spout.prototype.fail = function(id, done) {};
-
-/**
- * Method the indicates its time to emit the next tuple.
- * @param done call this method when done sending the output.
- */
-Spout.prototype.nextTuple = function(done) {};
-
-Spout.prototype.handleNewCommand = function(command) {
- var self = this;
- var callback = function() {
- self.sync();
- }
-
- if (command["command"] === "next") {
- this.nextTuple(callback);
- }
-
- if (command["command"] === "ack") {
- this.ack(command["id"], callback);
- }
-
- if (command["command"] === "fail") {
- this.fail(command["id"], callback);
- }
-}
-
-/**
- * @param commandDetails json with the required fields:
- * - tuple - the value to emit.
- * and the optional fields:
- * - id - pass id for reliable emit (and receive ack/fail later).
- * - stream - if empty - emit to default stream.
- * - task - pass only to emit to specific task.
- */
-Spout.prototype.__emit = function(commandDetails) {
- var message = {
- command: "emit",
- tuple: commandDetails.tuple,
- id: commandDetails.id,
- stream: commandDetails.stream,
- task: commandDetails.task
- };
-
- this.sendMsgToParent(message);
-}
-
-module.exports.BasicBolt = BasicBolt;
-module.exports.Spout = Spout;
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/resources/storm.py
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/resources/storm.py b/_site/target/checkout/examples/storm-starter/target/classes/resources/storm.py
deleted file mode 100644
index 642c393..0000000
--- a/_site/target/checkout/examples/storm-starter/target/classes/resources/storm.py
+++ /dev/null
@@ -1,260 +0,0 @@
-# -*- coding: utf-8 -*-
-
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-import sys
-import os
-import traceback
-from collections import deque
-
-try:
- import simplejson as json
-except ImportError:
- import json
-
-json_encode = lambda x: json.dumps(x)
-json_decode = lambda x: json.loads(x)
-
-#reads lines and reconstructs newlines appropriately
-def readMsg():
- msg = ""
- while True:
- line = sys.stdin.readline()
- if not line:
- raise Exception('Read EOF from stdin')
- if line[0:-1] == "end":
- break
- msg = msg + line
- return json_decode(msg[0:-1])
-
-MODE = None
-ANCHOR_TUPLE = None
-
-#queue up commands we read while trying to read taskids
-pending_commands = deque()
-
-def readTaskIds():
- if pending_taskids:
- return pending_taskids.popleft()
- else:
- msg = readMsg()
- while type(msg) is not list:
- pending_commands.append(msg)
- msg = readMsg()
- return msg
-
-#queue up taskids we read while trying to read commands/tuples
-pending_taskids = deque()
-
-def readCommand():
- if pending_commands:
- return pending_commands.popleft()
- else:
- msg = readMsg()
- while type(msg) is list:
- pending_taskids.append(msg)
- msg = readMsg()
- return msg
-
-def readTuple():
- cmd = readCommand()
- return Tuple(cmd["id"], cmd["comp"], cmd["stream"], cmd["task"], cmd["tuple"])
-
-def sendMsgToParent(msg):
- print json_encode(msg)
- print "end"
- sys.stdout.flush()
-
-def sync():
- sendMsgToParent({'command':'sync'})
-
-def sendpid(heartbeatdir):
- pid = os.getpid()
- sendMsgToParent({'pid':pid})
- open(heartbeatdir + "/" + str(pid), "w").close()
-
-def emit(*args, **kwargs):
- __emit(*args, **kwargs)
- return readTaskIds()
-
-def emitDirect(task, *args, **kwargs):
- kwargs["directTask"] = task
- __emit(*args, **kwargs)
-
-def __emit(*args, **kwargs):
- global MODE
- if MODE == Bolt:
- emitBolt(*args, **kwargs)
- elif MODE == Spout:
- emitSpout(*args, **kwargs)
-
-def emitBolt(tup, stream=None, anchors = [], directTask=None):
- global ANCHOR_TUPLE
- if ANCHOR_TUPLE is not None:
- anchors = [ANCHOR_TUPLE]
- m = {"command": "emit"}
- if stream is not None:
- m["stream"] = stream
- m["anchors"] = map(lambda a: a.id, anchors)
- if directTask is not None:
- m["task"] = directTask
- m["tuple"] = tup
- sendMsgToParent(m)
-
-def emitSpout(tup, stream=None, id=None, directTask=None):
- m = {"command": "emit"}
- if id is not None:
- m["id"] = id
- if stream is not None:
- m["stream"] = stream
- if directTask is not None:
- m["task"] = directTask
- m["tuple"] = tup
- sendMsgToParent(m)
-
-def ack(tup):
- sendMsgToParent({"command": "ack", "id": tup.id})
-
-def fail(tup):
- sendMsgToParent({"command": "fail", "id": tup.id})
-
-def reportError(msg):
- sendMsgToParent({"command": "error", "msg": msg})
-
-def log(msg, level=2):
- sendMsgToParent({"command": "log", "msg": msg, "level":level})
-
-def logTrace(msg):
- log(msg, 0)
-
-def logDebug(msg):
- log(msg, 1)
-
-def logInfo(msg):
- log(msg, 2)
-
-def logWarn(msg):
- log(msg, 3)
-
-def logError(msg):
- log(msg, 4)
-
-def rpcMetrics(name, params):
- sendMsgToParent({"command": "metrics", "name": name, "params": params})
-
-def initComponent():
- setupInfo = readMsg()
- sendpid(setupInfo['pidDir'])
- return [setupInfo['conf'], setupInfo['context']]
-
-class Tuple(object):
- def __init__(self, id, component, stream, task, values):
- self.id = id
- self.component = component
- self.stream = stream
- self.task = task
- self.values = values
-
- def __repr__(self):
- return '<%s%s>' % (
- self.__class__.__name__,
- ''.join(' %s=%r' % (k, self.__dict__[k]) for k in sorted(self.__dict__.keys())))
-
- def is_heartbeat_tuple(self):
- return self.task == -1 and self.stream == "__heartbeat"
-
-class Bolt(object):
- def initialize(self, stormconf, context):
- pass
-
- def process(self, tuple):
- pass
-
- def run(self):
- global MODE
- MODE = Bolt
- conf, context = initComponent()
- try:
- self.initialize(conf, context)
- while True:
- tup = readTuple()
- if tup.is_heartbeat_tuple():
- sync()
- else:
- self.process(tup)
- except Exception, e:
- reportError(traceback.format_exc(e))
-
-class BasicBolt(object):
- def initialize(self, stormconf, context):
- pass
-
- def process(self, tuple):
- pass
-
- def run(self):
- global MODE
- MODE = Bolt
- global ANCHOR_TUPLE
- conf, context = initComponent()
- try:
- self.initialize(conf, context)
- while True:
- tup = readTuple()
- if tup.is_heartbeat_tuple():
- sync()
- else:
- ANCHOR_TUPLE = tup
- try:
- self.process(tup)
- ack(tup)
- except Exception, e:
- reportError(traceback.format_exc(e))
- fail(tup)
- except Exception, e:
- reportError(traceback.format_exc(e))
-
-class Spout(object):
- def initialize(self, conf, context):
- pass
-
- def ack(self, id):
- pass
-
- def fail(self, id):
- pass
-
- def nextTuple(self):
- pass
-
- def run(self):
- global MODE
- MODE = Spout
- conf, context = initComponent()
- try:
- self.initialize(conf, context)
- while True:
- msg = readCommand()
- if msg["command"] == "next":
- self.nextTuple()
- if msg["command"] == "ack":
- self.ack(msg["id"])
- if msg["command"] == "fail":
- self.fail(msg["id"])
- sync()
- except Exception, e:
- reportError(traceback.format_exc(e))
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/resources/storm.rb
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/resources/storm.rb b/_site/target/checkout/examples/storm-starter/target/classes/resources/storm.rb
deleted file mode 100644
index 816694e..0000000
--- a/_site/target/checkout/examples/storm-starter/target/classes/resources/storm.rb
+++ /dev/null
@@ -1,236 +0,0 @@
-# -*- coding: utf-8 -*-
-
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-require "rubygems"
-require "json"
-
-module Storm
- module Protocol
- class << self
- attr_accessor :mode, :pending_taskids, :pending_commands
- end
-
- self.pending_taskids = []
- self.pending_commands = []
-
- def read_message
- msg = ""
- loop do
- line = STDIN.readline.chomp
- break if line == "end"
- msg << line
- msg << "\n"
- end
- JSON.parse msg.chomp
- end
-
- def read_task_ids
- Storm::Protocol.pending_taskids.shift ||
- begin
- msg = read_message
- until msg.is_a? Array
- Storm::Protocol.pending_commands.push(msg)
- msg = read_message
- end
- msg
- end
- end
-
- def read_command
- Storm::Protocol.pending_commands.shift ||
- begin
- msg = read_message
- while msg.is_a? Array
- Storm::Protocol.pending_taskids.push(msg)
- msg = read_message
- end
- msg
- end
- end
-
- def send_msg_to_parent(msg)
- puts msg.to_json
- puts "end"
- STDOUT.flush
- end
-
- def sync
- send_msg_to_parent({'command' => 'sync'})
- end
-
- def send_pid(heartbeat_dir)
- pid = Process.pid
- send_msg_to_parent({'pid' => pid})
- File.open("#{heartbeat_dir}/#{pid}", "w").close
- end
-
- def emit_bolt(tup, args = {})
- stream = args[:stream]
- anchors = args[:anchors] || args[:anchor] || []
- anchors = [anchors] unless anchors.is_a? Enumerable
- direct = args[:direct_task]
- m = {:command => :emit, :anchors => anchors.map(&:id), :tuple => tup}
- m[:stream] = stream if stream
- m[:task] = direct if direct
- send_msg_to_parent m
- read_task_ids unless direct
- end
-
- def emit_spout(tup, args = {})
- stream = args[:stream]
- id = args[:id]
- direct = args[:direct_task]
- m = {:command => :emit, :tuple => tup}
- m[:id] = id if id
- m[:stream] = stream if stream
- m[:task] = direct if direct
- send_msg_to_parent m
- read_task_ids unless direct
- end
-
- def emit(*args)
- case Storm::Protocol.mode
- when 'spout'
- emit_spout(*args)
- when 'bolt'
- emit_bolt(*args)
- end
- end
-
- def ack(tup)
- send_msg_to_parent :command => :ack, :id => tup.id
- end
-
- def fail(tup)
- send_msg_to_parent :command => :fail, :id => tup.id
- end
-
- def reportError(msg)
- send_msg_to_parent :command => :error, :msg => msg.to_s
- end
-
- def log(msg, level=2)
- send_msg_to_parent :command => :log, :msg => msg.to_s, :level => level
- end
-
- def logTrace(msg)
- log(msg, 0)
- end
-
- def logDebug(msg)
- log(msg, 1)
- end
-
- def logInfo(msg)
- log(msg, 2)
- end
-
- def logWarn(msg)
- log(msg, 3)
- end
-
- def logError(msg)
- log(msg, 4)
- end
-
- def handshake
- setup_info = read_message
- send_pid setup_info['pidDir']
- [setup_info['conf'], setup_info['context']]
- end
- end
-
- class Tuple
- attr_accessor :id, :component, :stream, :task, :values
-
- def initialize(id, component, stream, task, values)
- @id = id
- @component = component
- @stream = stream
- @task = task
- @values = values
- end
-
- def self.from_hash(hash)
- Tuple.new(*hash.values_at("id", "comp", "stream", "task", "tuple"))
- end
-
- def is_heartbeat
- task == -1 and stream == '__heartbeat'
- end
- end
-
- class Bolt
- include Storm::Protocol
-
- def prepare(conf, context); end
-
- def process(tuple); end
-
- def run
- Storm::Protocol.mode = 'bolt'
- prepare(*handshake)
- begin
- while true
- tuple = Tuple.from_hash(read_command)
- if tuple.is_heartbeat
- sync
- else
- process tuple
- end
- end
- rescue Exception => e
- reportError 'Exception in bolt: ' + e.message + ' - ' + e.backtrace.join('\n')
- end
- end
- end
-
- class Spout
- include Storm::Protocol
-
- def open(conf, context); end
-
- def nextTuple; end
-
- def ack(id); end
-
- def fail(id); end
-
- def run
- Storm::Protocol.mode = 'spout'
- open(*handshake)
-
- begin
- while true
- msg = read_command
- case msg['command']
- when 'next'
- nextTuple
- when 'ack'
- ack(msg['id'])
- when 'fail'
- fail(msg['id'])
- end
- sync
- end
- rescue Exception => e
- reportError 'Exception in spout: ' + e.message + ' - ' + e.backtrace.join('\n')
- end
- end
- end
-end
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/BasicDRPCTopology$ExclaimBolt.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/BasicDRPCTopology$ExclaimBolt.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/BasicDRPCTopology$ExclaimBolt.class
deleted file mode 100644
index 2bc705f..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/BasicDRPCTopology$ExclaimBolt.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/BasicDRPCTopology.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/BasicDRPCTopology.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/BasicDRPCTopology.class
deleted file mode 100644
index da55e06..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/BasicDRPCTopology.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ExclamationTopology$ExclamationBolt.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ExclamationTopology$ExclamationBolt.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ExclamationTopology$ExclamationBolt.class
deleted file mode 100644
index 04d62c2..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ExclamationTopology$ExclamationBolt.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ExclamationTopology.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ExclamationTopology.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ExclamationTopology.class
deleted file mode 100644
index f2f2eec..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ExclamationTopology.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ManualDRPC$ExclamationBolt.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ManualDRPC$ExclamationBolt.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ManualDRPC$ExclamationBolt.class
deleted file mode 100644
index f45bceb..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ManualDRPC$ExclamationBolt.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ManualDRPC.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ManualDRPC.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ManualDRPC.class
deleted file mode 100644
index 039cc7f..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ManualDRPC.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/PrintSampleStream.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/PrintSampleStream.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/PrintSampleStream.class
deleted file mode 100644
index a03a715..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/PrintSampleStream.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$1.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$1.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$1.class
deleted file mode 100644
index 840aa99..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$1.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$2.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$2.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$2.class
deleted file mode 100644
index 31d1bff..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$2.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$CountAggregator.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$CountAggregator.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$CountAggregator.class
deleted file mode 100644
index ee239eb..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$CountAggregator.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$GetFollowers.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$GetFollowers.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$GetFollowers.class
deleted file mode 100644
index 440a376..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$GetFollowers.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$GetTweeters.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$GetTweeters.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$GetTweeters.class
deleted file mode 100644
index 8239483..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$GetTweeters.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$PartialUniquer.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$PartialUniquer.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$PartialUniquer.class
deleted file mode 100644
index 124455a..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology$PartialUniquer.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology.class
deleted file mode 100644
index 356eae4..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/ReachTopology.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/RollingTopWords.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/RollingTopWords.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/RollingTopWords.class
deleted file mode 100644
index 8625b89..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/RollingTopWords.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/SingleJoinExample.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/SingleJoinExample.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/SingleJoinExample.class
deleted file mode 100644
index 678e99c..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/SingleJoinExample.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$1$1.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$1$1.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$1$1.class
deleted file mode 100644
index e1743fa..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$1$1.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$1$2.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$1$2.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$1$2.class
deleted file mode 100644
index 03268be..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$1$2.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$1$3.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$1$3.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$1$3.class
deleted file mode 100644
index 2a90315..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$1$3.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$1.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$1.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$1.class
deleted file mode 100644
index 670e662..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$1.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$BatchCount.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$BatchCount.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$BatchCount.class
deleted file mode 100644
index 453f0ae..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$BatchCount.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$UpdateGlobalCount.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$UpdateGlobalCount.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$UpdateGlobalCount.class
deleted file mode 100644
index d158600..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$UpdateGlobalCount.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$Value.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$Value.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$Value.class
deleted file mode 100644
index 73f9c31..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount$Value.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount.class
deleted file mode 100644
index b870179..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalGlobalCount.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$1$1.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$1$1.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$1$1.class
deleted file mode 100644
index 377427e..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$1$1.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$1$2.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$1$2.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$1$2.class
deleted file mode 100644
index b41cff0..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$1$2.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$1$3.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$1$3.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$1$3.class
deleted file mode 100644
index c070da4..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$1$3.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$1.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$1.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$1.class
deleted file mode 100644
index 7767526..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$1.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$BucketCountUpdater.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$BucketCountUpdater.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$BucketCountUpdater.class
deleted file mode 100644
index 402ef46..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$BucketCountUpdater.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$BucketValue.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$BucketValue.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$BucketValue.class
deleted file mode 100644
index 97b5268..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$BucketValue.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$Bucketize.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$Bucketize.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$Bucketize.class
deleted file mode 100644
index de72ec0..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$Bucketize.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$CountValue.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$CountValue.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$CountValue.class
deleted file mode 100644
index 67b9aa0..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$CountValue.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$KeyedCountUpdater.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$KeyedCountUpdater.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$KeyedCountUpdater.class
deleted file mode 100644
index 8c79300..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords$KeyedCountUpdater.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords.class
deleted file mode 100644
index 703f129..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/TransactionalWords.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopology$SplitSentence.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopology$SplitSentence.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopology$SplitSentence.class
deleted file mode 100644
index f6b9531..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopology$SplitSentence.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopology$WordCount.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopology$WordCount.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopology$WordCount.class
deleted file mode 100644
index 703abbf..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopology$WordCount.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopology.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopology.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopology.class
deleted file mode 100644
index 0176f6b..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopology.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopologyNode$RandomSentence.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopologyNode$RandomSentence.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopologyNode$RandomSentence.class
deleted file mode 100644
index 335eba3..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopologyNode$RandomSentence.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopologyNode$SplitSentence.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopologyNode$SplitSentence.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopologyNode$SplitSentence.class
deleted file mode 100644
index 27a810a..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopologyNode$SplitSentence.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopologyNode$WordCount.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopologyNode$WordCount.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopologyNode$WordCount.class
deleted file mode 100644
index dbef744..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopologyNode$WordCount.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopologyNode.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopologyNode.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopologyNode.class
deleted file mode 100644
index bfa7da8..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/WordCountTopologyNode.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/AbstractRankerBolt.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/AbstractRankerBolt.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/AbstractRankerBolt.class
deleted file mode 100644
index 8bf2c2a..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/AbstractRankerBolt.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/IntermediateRankingsBolt.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/IntermediateRankingsBolt.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/IntermediateRankingsBolt.class
deleted file mode 100644
index 581671c..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/IntermediateRankingsBolt.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/PrinterBolt.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/PrinterBolt.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/PrinterBolt.class
deleted file mode 100644
index 0df482d..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/PrinterBolt.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/RollingCountBolt.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/RollingCountBolt.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/RollingCountBolt.class
deleted file mode 100644
index ff5accb..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/RollingCountBolt.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/SingleJoinBolt$1.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/SingleJoinBolt$1.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/SingleJoinBolt$1.class
deleted file mode 100644
index fa57372..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/SingleJoinBolt$1.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/SingleJoinBolt$ExpireCallback.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/SingleJoinBolt$ExpireCallback.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/SingleJoinBolt$ExpireCallback.class
deleted file mode 100644
index bc2105e..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/SingleJoinBolt$ExpireCallback.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/SingleJoinBolt.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/SingleJoinBolt.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/SingleJoinBolt.class
deleted file mode 100644
index 771ad2f..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/SingleJoinBolt.class and /dev/null differ
http://git-wip-us.apache.org/repos/asf/storm/blob/d13d1680/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/TotalRankingsBolt.class
----------------------------------------------------------------------
diff --git a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/TotalRankingsBolt.class b/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/TotalRankingsBolt.class
deleted file mode 100644
index 52fcab1..0000000
Binary files a/_site/target/checkout/examples/storm-starter/target/classes/storm/starter/bolt/TotalRankingsBolt.class and /dev/null differ