zeppelin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m...@apache.org
Subject [1/3] zeppelin git commit: [ZEPPELIN-1363] Note level dynamic form
Date Sat, 18 Nov 2017 20:53:40 GMT
Repository: zeppelin
Updated Branches:
  refs/heads/master 2a33fd379 -> 50cfabdf9


http://git-wip-us.apache.org/repos/asf/zeppelin/blob/50cfabdf/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterTest.java
----------------------------------------------------------------------
diff --git a/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterTest.java
b/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterTest.java
index c268c81..7f9978a 100644
--- a/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterTest.java
+++ b/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterTest.java
@@ -94,7 +94,7 @@ public class RemoteInterpreterTest {
     RemoteInterpreter remoteInterpreter2 = (RemoteInterpreter) interpreter2;
 
     InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl",
-        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(),
+        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(), new GUI(),
         null, null, new ArrayList<InterpreterContextRunner>(), null);
     assertEquals("hello", remoteInterpreter1.interpret("hello", context1).message().get(0).getData());
     assertEquals(Interpreter.FormType.NATIVE, interpreter1.getFormType());
@@ -137,7 +137,7 @@ public class RemoteInterpreterTest {
     RemoteInterpreter remoteInterpreter2 = (RemoteInterpreter) interpreter2;
 
     InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl",
-        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(),
+        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(), new GUI(),
         null, null, new ArrayList<InterpreterContextRunner>(), null);
     assertEquals("hello", remoteInterpreter1.interpret("hello", context1).message().get(0).getData());
     assertEquals("hello", remoteInterpreter2.interpret("hello", context1).message().get(0).getData());
@@ -183,7 +183,7 @@ public class RemoteInterpreterTest {
     RemoteInterpreter remoteInterpreter2 = (RemoteInterpreter) interpreter2;
 
     InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl",
-        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(),
+        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(), new GUI(),
         null, null, new ArrayList<InterpreterContextRunner>(), null);
     assertEquals("hello", remoteInterpreter1.interpret("hello", context1).message().get(0).getData());
     assertEquals("hello", remoteInterpreter2.interpret("hello", context1).message().get(0).getData());
@@ -224,7 +224,7 @@ public class RemoteInterpreterTest {
     interpreterSetting.setProperty("zeppelin.SleepInterpreter.precode", "fail test");
     Interpreter interpreter1 = interpreterSetting.getInterpreter("user1", "note1", "sleep");
     InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl",
-        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(),
+        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(), new GUI(),
         null, null, new ArrayList<InterpreterContextRunner>(), null);
     assertEquals(Code.ERROR, interpreter1.interpret("10", context1).code());
   }
@@ -235,7 +235,7 @@ public class RemoteInterpreterTest {
     interpreterSetting.setProperty("zeppelin.SleepInterpreter.precode", "1");
     Interpreter interpreter1 = interpreterSetting.getInterpreter("user1", "note1", "sleep");
     InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl",
-        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(),
+        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(), new GUI(),
         null, null, new ArrayList<InterpreterContextRunner>(), null);
     assertEquals(Code.SUCCESS, interpreter1.interpret("10", context1).code());
   }
@@ -250,7 +250,7 @@ public class RemoteInterpreterTest {
     RemoteInterpreter remoteInterpreter1 = (RemoteInterpreter) interpreter1;
 
     InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl",
-        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(),
+        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(), new GUI(),
         null, null, new ArrayList<InterpreterContextRunner>(), null);
     assertEquals(Code.ERROR, remoteInterpreter1.interpret("hello", context1).code());
   }
@@ -262,7 +262,7 @@ public class RemoteInterpreterTest {
 
     final Interpreter interpreter1 = interpreterSetting.getInterpreter("user1", "note1",
"sleep");
     final InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl",
-        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(),
+        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(), new GUI(),
         null, null, new ArrayList<InterpreterContextRunner>(), null);
     // run this dummy interpret method first to launch the RemoteInterpreterProcess to avoid
the
     // time overhead of launching the process.
@@ -305,7 +305,7 @@ public class RemoteInterpreterTest {
 
     final Interpreter interpreter1 = interpreterSetting.getInterpreter("user1", "note1",
"sleep");
     final InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl",
-        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(),
+        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(), new GUI(),
         null, null, new ArrayList<InterpreterContextRunner>(), null);
 
     // run this dummy interpret method first to launch the RemoteInterpreterProcess to avoid
the
@@ -378,7 +378,7 @@ public class RemoteInterpreterTest {
     interpreter.getInterpreterGroup().setAngularObjectRegistry(registry);
 
     final InterpreterContext context = new InterpreterContext("noteId", "paragraphId", "repl",
-        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(),
+        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(), new GUI(),
         null, null, new ArrayList<InterpreterContextRunner>(), null);
 
     InterpreterResult result = interpreter.interpret("dummy", context);
@@ -405,7 +405,7 @@ public class RemoteInterpreterTest {
 
     final Interpreter interpreter1 = interpreterSetting.getInterpreter("user1", "note1",
"get");
     final InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl",
-        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(),
+        "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(),
new GUI(), new GUI(),
         null, null, new ArrayList<InterpreterContextRunner>(), null);
 
     assertEquals("VALUE_1", interpreter1.interpret("getEnv ENV_1", context1).message().get(0).getData());
@@ -431,7 +431,7 @@ public class RemoteInterpreterTest {
     Map<String, Input> expected = new LinkedHashMap<>(gui.getForms());
     Interpreter interpreter = interpreterSetting.getDefaultInterpreter("user1", "note1");
     InterpreterContext context = new InterpreterContext("noteId", "paragraphId", "repl",
null,
-        null, AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), gui,
+        null, AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), gui, new
GUI(),
         null, null, new ArrayList<InterpreterContextRunner>(), null);
 
     interpreter.interpret("text", context);

http://git-wip-us.apache.org/repos/asf/zeppelin/blob/50cfabdf/zeppelin-zengine/src/test/java/org/apache/zeppelin/resource/DistributedResourcePoolTest.java
----------------------------------------------------------------------
diff --git a/zeppelin-zengine/src/test/java/org/apache/zeppelin/resource/DistributedResourcePoolTest.java
b/zeppelin-zengine/src/test/java/org/apache/zeppelin/resource/DistributedResourcePoolTest.java
index c7ccd46..6f7c197 100644
--- a/zeppelin-zengine/src/test/java/org/apache/zeppelin/resource/DistributedResourcePoolTest.java
+++ b/zeppelin-zengine/src/test/java/org/apache/zeppelin/resource/DistributedResourcePoolTest.java
@@ -61,6 +61,7 @@ public class DistributedResourcePoolTest extends AbstractInterpreterTest
{
         new AuthenticationInfo(),
         new HashMap<String, Object>(),
         new GUI(),
+        new GUI(),
         null,
         null,
         new LinkedList<InterpreterContextRunner>(),

http://git-wip-us.apache.org/repos/asf/zeppelin/blob/50cfabdf/zeppelin-zengine/src/test/java/org/apache/zeppelin/scheduler/RemoteSchedulerTest.java
----------------------------------------------------------------------
diff --git a/zeppelin-zengine/src/test/java/org/apache/zeppelin/scheduler/RemoteSchedulerTest.java
b/zeppelin-zengine/src/test/java/org/apache/zeppelin/scheduler/RemoteSchedulerTest.java
index e43a39d..1253789 100644
--- a/zeppelin-zengine/src/test/java/org/apache/zeppelin/scheduler/RemoteSchedulerTest.java
+++ b/zeppelin-zengine/src/test/java/org/apache/zeppelin/scheduler/RemoteSchedulerTest.java
@@ -121,6 +121,7 @@ public class RemoteSchedulerTest implements RemoteInterpreterProcessListener
{
             new AuthenticationInfo(),
             new HashMap<String, Object>(),
             new GUI(),
+            new GUI(),
             null,
             new LocalResourcePool("pool1"),
             new LinkedList<InterpreterContextRunner>(), null));
@@ -182,6 +183,7 @@ public class RemoteSchedulerTest implements RemoteInterpreterProcessListener
{
           new AuthenticationInfo(),
           new HashMap<String, Object>(),
           new GUI(),
+          new GUI(),
           null,
           new LocalResourcePool("pool1"),
           new LinkedList<InterpreterContextRunner>(), null);
@@ -236,6 +238,7 @@ public class RemoteSchedulerTest implements RemoteInterpreterProcessListener
{
           new AuthenticationInfo(),
           new HashMap<String, Object>(),
           new GUI(),
+          new GUI(),
           null,
           new LocalResourcePool("pool1"),
           new LinkedList<InterpreterContextRunner>(), null);


Mime
View raw message