http://git-wip-us.apache.org/repos/asf/flink/blob/2a2d984f/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/StormMetaDataITCase.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/StormMetaDataITCase.java b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/StormMetaDataITCase.java index b19e106..fe09daf 100644 --- a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/StormMetaDataITCase.java +++ b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/StormMetaDataITCase.java @@ -15,24 +15,28 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.flink.storm.tests; -import org.apache.storm.topology.TopologyBuilder; -import org.apache.storm.utils.Utils; +package org.apache.flink.storm.tests; import org.apache.flink.storm.api.FlinkLocalCluster; import org.apache.flink.storm.api.FlinkTopology; import org.apache.flink.storm.tests.operators.MetaDataSpout; import org.apache.flink.storm.tests.operators.VerifyMetaDataBolt; import org.apache.flink.streaming.util.StreamingProgramTestBase; + +import org.apache.storm.topology.TopologyBuilder; +import org.apache.storm.utils.Utils; import org.junit.Assert; +/** + * Test for meta data spouts/bolts. + */ public class StormMetaDataITCase extends StreamingProgramTestBase { - private final static String topologyId = "FieldsGrouping Test"; - private final static String spoutId = "spout"; - private final static String boltId1 = "bolt1"; - private final static String boltId2 = "bolt2"; + private static final String topologyId = "FieldsGrouping Test"; + private static final String spoutId = "spout"; + private static final String boltId1 = "bolt1"; + private static final String boltId2 = "bolt2"; @Override protected void testProgram() throws Exception {
http://git-wip-us.apache.org/repos/asf/flink/blob/2a2d984f/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/StormUnionITCase.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/StormUnionITCase.java b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/StormUnionITCase.java index 452fef5..12e897a 100644 --- a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/StormUnionITCase.java +++ b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/StormUnionITCase.java @@ -15,10 +15,8 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.flink.storm.tests; -import org.apache.storm.Config; -import org.apache.storm.topology.TopologyBuilder; +package org.apache.flink.storm.tests; import org.apache.flink.storm.api.FlinkLocalCluster; import org.apache.flink.storm.api.FlinkTopology; @@ -27,6 +25,12 @@ import org.apache.flink.storm.tests.operators.MergerBolt; import org.apache.flink.storm.util.BoltFileSink; import org.apache.flink.streaming.util.StreamingProgramTestBase; +import org.apache.storm.Config; +import org.apache.storm.topology.TopologyBuilder; + +/** + * Test for the {@link MergerBolt}. + */ public class StormUnionITCase extends StreamingProgramTestBase { private static final String RESULT = "-1154715079\n" + "-1155869325\n" + "-1155484576\n" @@ -37,12 +41,12 @@ public class StormUnionITCase extends StreamingProgramTestBase { + "-624140595\n" + "-60658084\n" + "142959438\n" + "-613647601\n" + "-330177159\n" + "-54027108\n" + "1945002173\n" + "979930868"; - private final static String topologyId = "Multiple Input Streams Test"; - private final static String spoutId1 = "spout1"; - private final static String spoutId2 = "spout2"; - private final static String spoutId3 = "spout3"; - private final static String boltId = "merger"; - private final static String sinkId = "sink"; + private static final String topologyId = "Multiple Input Streams Test"; + private static final String spoutId1 = "spout1"; + private static final String spoutId2 = "spout2"; + private static final String spoutId3 = "spout3"; + private static final String boltId = "merger"; + private static final String sinkId = "sink"; private String resultPath; @Override http://git-wip-us.apache.org/repos/asf/flink/blob/2a2d984f/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/FiniteRandomSpout.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/FiniteRandomSpout.java b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/FiniteRandomSpout.java index da8d21a..923f9df 100644 --- a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/FiniteRandomSpout.java +++ b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/FiniteRandomSpout.java @@ -15,10 +15,8 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.flink.storm.tests.operators; -import java.util.Map; -import java.util.Random; +package org.apache.flink.storm.tests.operators; import org.apache.flink.storm.util.FiniteSpout; @@ -30,6 +28,13 @@ import org.apache.storm.tuple.Fields; import org.apache.storm.tuple.Values; import org.apache.storm.utils.Utils; +import java.util.Map; +import java.util.Random; + +/** + * A Spout implementation that broadcasts random numbers across a specified number of output streams, until a specified + * count is reached. + */ public class FiniteRandomSpout extends BaseRichSpout implements FiniteSpout { private static final long serialVersionUID = 6592885571932363239L; http://git-wip-us.apache.org/repos/asf/flink/blob/2a2d984f/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/MergerBolt.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/MergerBolt.java b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/MergerBolt.java index 7a6ec58..c04bce3 100644 --- a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/MergerBolt.java +++ b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/MergerBolt.java @@ -15,9 +15,8 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.flink.storm.tests.operators; -import java.util.Map; +package org.apache.flink.storm.tests.operators; import org.apache.storm.task.OutputCollector; import org.apache.storm.task.TopologyContext; @@ -26,6 +25,11 @@ import org.apache.storm.topology.base.BaseRichBolt; import org.apache.storm.tuple.Fields; import org.apache.storm.tuple.Tuple; +import java.util.Map; + +/** + * A Bolt implementation that forwards all incoming tuples to a single output stream. + */ public class MergerBolt extends BaseRichBolt { private static final long serialVersionUID = -7966475984592762720L; http://git-wip-us.apache.org/repos/asf/flink/blob/2a2d984f/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/MetaDataSpout.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/MetaDataSpout.java b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/MetaDataSpout.java index a6e19b9..4061a71 100644 --- a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/MetaDataSpout.java +++ b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/MetaDataSpout.java @@ -15,9 +15,8 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.flink.storm.tests.operators; -import java.util.Map; +package org.apache.flink.storm.tests.operators; import org.apache.storm.spout.SpoutOutputCollector; import org.apache.storm.task.TopologyContext; @@ -26,6 +25,11 @@ import org.apache.storm.topology.base.BaseRichSpout; import org.apache.storm.tuple.Fields; import org.apache.storm.tuple.Values; +import java.util.Map; + +/** + * A Spout implementation emitting meta data. + */ public class MetaDataSpout extends BaseRichSpout { private static final long serialVersionUID = 5305870218033256376L; http://git-wip-us.apache.org/repos/asf/flink/blob/2a2d984f/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/TaskIdBolt.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/TaskIdBolt.java b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/TaskIdBolt.java index fb5c8d3..1a8f218 100644 --- a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/TaskIdBolt.java +++ b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/TaskIdBolt.java @@ -15,9 +15,8 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.flink.storm.tests.operators; -import java.util.Map; +package org.apache.flink.storm.tests.operators; import org.apache.storm.task.OutputCollector; import org.apache.storm.task.TopologyContext; @@ -27,6 +26,8 @@ import org.apache.storm.tuple.Fields; import org.apache.storm.tuple.Tuple; import org.apache.storm.tuple.Values; +import java.util.Map; + /** * Bolt to prepend all incoming tuple values with the task id. */ http://git-wip-us.apache.org/repos/asf/flink/blob/2a2d984f/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/VerifyMetaDataBolt.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/VerifyMetaDataBolt.java b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/VerifyMetaDataBolt.java index f7b40fc..059882b 100644 --- a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/VerifyMetaDataBolt.java +++ b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/VerifyMetaDataBolt.java @@ -15,9 +15,8 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.flink.storm.tests.operators; -import java.util.Map; +package org.apache.flink.storm.tests.operators; import org.apache.storm.task.OutputCollector; import org.apache.storm.task.TopologyContext; @@ -28,6 +27,11 @@ import org.apache.storm.tuple.MessageId; import org.apache.storm.tuple.Tuple; import org.apache.storm.tuple.Values; +import java.util.Map; + +/** + * A Bolt implementation that verifies metadata emitted by a {@link MetaDataSpout}. + */ public class VerifyMetaDataBolt extends BaseRichBolt { private static final long serialVersionUID = 1353222852073800478L; http://git-wip-us.apache.org/repos/asf/flink/blob/2a2d984f/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountITCase.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountITCase.java b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountITCase.java index f48e2f6..d1cc5a2 100644 --- a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountITCase.java +++ b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountITCase.java @@ -21,6 +21,9 @@ package org.apache.flink.storm.wordcount; import org.apache.flink.streaming.util.StreamingProgramTestBase; import org.apache.flink.test.testdata.WordCountData; +/** + * Test for the BoltTokenizerWordCount example. + */ public class BoltTokenizerWordCountITCase extends StreamingProgramTestBase { protected String textPath; http://git-wip-us.apache.org/repos/asf/flink/blob/2a2d984f/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountPojoITCase.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountPojoITCase.java b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountPojoITCase.java index 902cacf..0eb4a6e 100644 --- a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountPojoITCase.java +++ b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountPojoITCase.java @@ -21,6 +21,9 @@ package org.apache.flink.storm.wordcount; import org.apache.flink.streaming.util.StreamingProgramTestBase; import org.apache.flink.test.testdata.WordCountData; +/** + * Test for the BoltTokenizerWordCountPojo example. + */ public class BoltTokenizerWordCountPojoITCase extends StreamingProgramTestBase { protected String textPath; http://git-wip-us.apache.org/repos/asf/flink/blob/2a2d984f/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountWithNamesITCase.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountWithNamesITCase.java b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountWithNamesITCase.java index 160efb3..8879d9e 100644 --- a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountWithNamesITCase.java +++ b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountWithNamesITCase.java @@ -21,6 +21,9 @@ package org.apache.flink.storm.wordcount; import org.apache.flink.streaming.util.StreamingProgramTestBase; import org.apache.flink.test.testdata.WordCountData; +/** + * Test for the BoltTokenizerWordCountWithNames example. + */ public class BoltTokenizerWordCountWithNamesITCase extends StreamingProgramTestBase { protected String textPath; http://git-wip-us.apache.org/repos/asf/flink/blob/2a2d984f/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/SpoutSourceWordCountITCase.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/SpoutSourceWordCountITCase.java b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/SpoutSourceWordCountITCase.java index 17f5be5..ec2ca2c 100644 --- a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/SpoutSourceWordCountITCase.java +++ b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/SpoutSourceWordCountITCase.java @@ -21,6 +21,9 @@ package org.apache.flink.storm.wordcount; import org.apache.flink.streaming.util.StreamingProgramTestBase; import org.apache.flink.test.testdata.WordCountData; +/** + * Test for the SpoutSourceWordCount example. + */ public class SpoutSourceWordCountITCase extends StreamingProgramTestBase { protected String textPath; http://git-wip-us.apache.org/repos/asf/flink/blob/2a2d984f/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/WordCountLocalITCase.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/WordCountLocalITCase.java b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/WordCountLocalITCase.java index 47ef2c4..471afa9 100644 --- a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/WordCountLocalITCase.java +++ b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/WordCountLocalITCase.java @@ -21,6 +21,9 @@ package org.apache.flink.storm.wordcount; import org.apache.flink.streaming.util.StreamingProgramTestBase; import org.apache.flink.test.testdata.WordCountData; +/** + * Test for the WordCountLocal example. + */ public class WordCountLocalITCase extends StreamingProgramTestBase { protected String textPath; http://git-wip-us.apache.org/repos/asf/flink/blob/2a2d984f/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/WordCountLocalNamedITCase.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/WordCountLocalNamedITCase.java b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/WordCountLocalNamedITCase.java index b04faa5..445ea37 100644 --- a/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/WordCountLocalNamedITCase.java +++ b/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/WordCountLocalNamedITCase.java @@ -21,7 +21,9 @@ package org.apache.flink.storm.wordcount; import org.apache.flink.streaming.util.StreamingProgramTestBase; import org.apache.flink.test.testdata.WordCountData; - +/** + * Test for the WordCountLocalByName example. + */ public class WordCountLocalNamedITCase extends StreamingProgramTestBase { protected String textPath;
