This is an automated email from the ASF dual-hosted git repository.
karthikz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git
The following commit(s) were added to refs/heads/master by this push:
new 056ba11 fixing test (#2894)
056ba11 is described below
commit 056ba114543a5f24c261375f2308556694c0e852
Author: Josh Fischer <j...@joshfischer.io>
AuthorDate: Tue May 8 01:09:18 2018 -0500
fixing test (#2894)
---
.../org/apache/heron/eco/parser/EcoParserTest.java | 89 +++++++++++++++++++++-
1 file changed, 88 insertions(+), 1 deletion(-)
diff --git a/eco/tests/java/org/apache/heron/eco/parser/EcoParserTest.java
b/eco/tests/java/org/apache/heron/eco/parser/EcoParserTest.java
index 9e665b7..30c41e1 100644
--- a/eco/tests/java/org/apache/heron/eco/parser/EcoParserTest.java
+++ b/eco/tests/java/org/apache/heron/eco/parser/EcoParserTest.java
@@ -16,7 +16,94 @@
* specific language governing permissions and limitations
* under the License.
*/
-\n"
+package org.apache.heron.eco.parser;
+import java.io.ByteArrayInputStream;
+import java.io.FileInputStream;
+import java.io.InputStream;
+import java.util.List;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.powermock.api.mockito.PowerMockito;
+
+import org.apache.heron.eco.definition.BeanDefinition;
+import org.apache.heron.eco.definition.BeanReference;
+import org.apache.heron.eco.definition.BoltDefinition;
+import org.apache.heron.eco.definition.EcoTopologyDefinition;
+import org.apache.heron.eco.definition.GroupingDefinition;
+import org.apache.heron.eco.definition.PropertyDefinition;
+import org.apache.heron.eco.definition.StreamDefinition;
+
+import static junit.framework.TestCase.assertNotNull;
+import static org.hamcrest.CoreMatchers.equalTo;
+import static org.hamcrest.CoreMatchers.is;
+import static org.junit.Assert.*;
+
+
+/**
+ * Unit tests for {@link EcoParser}
+ */
+public class EcoParserTest {
+
+ private static final String BOLT_1 = "bolt-1";
+ private static final String BOLT_2 = "bolt-2";
+ private static final String YAML_NO_CONFIG_STR = "# topology definition\n"
+ + "# name to be used when submitting\n"
+ + "name: \"yaml-topology\"\n"
+ + "\n"
+ + "# topology configuration\n"
+ + "# this will be passed to the submitter as a map of config options\n"
+ + "#\n"
+ + "# spout definitions\n"
+ + "spouts:\n"
+ + " - id: \"spout-1\"\n"
+ + " className: \"org.apache.heron.sample.TestWordSpout\"\n"
+ + " parallelism: 1\n"
+ + "\n"
+ + "# bolt definitions\n"
+ + "bolts:\n"
+ + " - id: \"bolt-1\"\n"
+ + " className: \"org.apache.heron.sample.TestWordCounter\"\n"
+ + " parallelism: 2\n"
+ + "\n"
+ + " - id: \"bolt-2\"\n"
+ + " className: \"org.apache.heron.sample.LogInfoBolt\"\n"
+ + " parallelism: 1\n"
+ + "\n"
+ + "#stream definitions\n"
+ + "# stream definitions define connections between spouts and bolts.\n"
+ + "# note that such connections can be cyclical\n"
+ + "streams:\n"
+ + " - name: \"spout-1 --> bolt-1\" # name isn't used (placeholder for
logging, UI, etc.)\n"
+ + " id: \"connection-1\"\n"
+ + " from: \"spout-1\"\n"
+ + " to: \"bolt-1\"\n"
+ + " grouping:\n"
+ + " type: FIELDS\n"
+ + " args: [\"word\"]\n"
+ + "\n"
+ + " - name: \"bolt-1 --> bolt2\"\n"
+ + " id: \"connection-2\"\n"
+ + " from: \"bolt-1\"\n"
+ + " to: \"bolt-2\"\n"
+ + " grouping:\n"
+ + " type: SHUFFLE";
+ private static final String YAML_STR = "# Licensed to the Apache Software
Foundation"
+ + " (ASF) under one\n"
+ + "# or more contributor license agreements. See the NOTICE file\n"
+ + "# distributed with this work for additional information\n"
+ + "# regarding copyright ownership. The ASF licenses this file\n"
+ + "# to you under the Apache License, Version 2.0 (the\n"
+ + "# \"License\"); you may not use this file except in compliance\n"
+ + "# with the License. You may obtain a copy of the License at\n"
+ + "#\n"
+ + "# http://www.apache.org/licenses/LICENSE-2.0\n";
+ + "#\n"
+ + "# Unless required by applicable law or agreed to in writing,
software\n"
+ + "# distributed under the License is distributed on an \"AS IS\"
BASIS,\n"
+ + "# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
implied.\n"
+ + "# See the License for the specific language governing permissions
and\n"
+ + "# limitations under the License.\n"
+ "\n"
+ "---\n"
+ "\n"
--
To stop receiving notification emails like this one, please contact
karth...@apache.org.
