mirror of
https://github.com/apache/zeppelin
synced 2026-05-24 09:38:26 +00:00
instead of null pass "new AuthenticationInfo()"
This commit is contained in:
parent
ba91da4121
commit
34dcc32035
10 changed files with 29 additions and 38 deletions
|
|
@ -62,7 +62,7 @@ public class ScaldingInterpreterTest {
|
|||
}
|
||||
|
||||
InterpreterGroup intpGroup = new InterpreterGroup();
|
||||
context = new InterpreterContext("note", "id", "title", "text", null,
|
||||
context = new InterpreterContext("note", "id", "title", "text", new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(), new GUI(), new AngularObjectRegistry(
|
||||
intpGroup.getId(), null), null,
|
||||
new LinkedList<InterpreterContextRunner>(), null);
|
||||
|
|
|
|||
|
|
@ -26,10 +26,7 @@ import java.util.Properties;
|
|||
|
||||
import org.apache.zeppelin.display.AngularObjectRegistry;
|
||||
import org.apache.zeppelin.display.GUI;
|
||||
import org.apache.zeppelin.interpreter.InterpreterContext;
|
||||
import org.apache.zeppelin.interpreter.InterpreterContextRunner;
|
||||
import org.apache.zeppelin.interpreter.InterpreterGroup;
|
||||
import org.apache.zeppelin.interpreter.InterpreterResult;
|
||||
import org.apache.zeppelin.interpreter.*;
|
||||
import org.apache.zeppelin.interpreter.InterpreterResult.Code;
|
||||
import org.junit.After;
|
||||
import org.junit.Before;
|
||||
|
|
@ -58,7 +55,8 @@ public class DepInterpreterTest {
|
|||
intpGroup.add(dep);
|
||||
dep.setInterpreterGroup(intpGroup);
|
||||
|
||||
context = new InterpreterContext("note", "id", "title", "text", null, new HashMap<String, Object>(), new GUI(),
|
||||
context = new InterpreterContext("note", "id", "title", "text", new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(), new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
null,
|
||||
new LinkedList<InterpreterContextRunner>(), null);
|
||||
|
|
|
|||
|
|
@ -76,7 +76,7 @@ public class SparkInterpreterTest {
|
|||
|
||||
InterpreterGroup intpGroup = new InterpreterGroup();
|
||||
context = new InterpreterContext("note", "id", "title", "text",
|
||||
null,
|
||||
new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(),
|
||||
new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
|
|
|
|||
|
|
@ -65,7 +65,8 @@ public class SparkSqlInterpreterTest {
|
|||
sql.setInterpreterGroup(intpGroup);
|
||||
sql.open();
|
||||
}
|
||||
context = new InterpreterContext("note", "id", "title", "text", null, new HashMap<String, Object>(), new GUI(),
|
||||
context = new InterpreterContext("note", "id", "title", "text", new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(), new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
null,
|
||||
new LinkedList<InterpreterContextRunner>(), new InterpreterOutput(new InterpreterOutputListener() {
|
||||
|
|
|
|||
|
|
@ -32,9 +32,9 @@ trait AbstractAngularElemTest
|
|||
|
||||
override def beforeEach() {
|
||||
val intpGroup = new InterpreterGroup()
|
||||
val context = new InterpreterContext("note", "paragraph", "title", "text", null,
|
||||
new util.HashMap[String, Object](), new GUI(), new AngularObjectRegistry(
|
||||
intpGroup.getId(), null),
|
||||
val context = new InterpreterContext("note", "paragraph", "title", "text",
|
||||
new AuthenticationInfo(), new util.HashMap[String, Object](), new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
null,
|
||||
new util.LinkedList[InterpreterContextRunner](),
|
||||
new InterpreterOutput(new InterpreterOutputListener() {
|
||||
|
|
|
|||
|
|
@ -29,10 +29,7 @@ import org.apache.zeppelin.display.AngularObject;
|
|||
import org.apache.zeppelin.display.AngularObjectRegistry;
|
||||
import org.apache.zeppelin.display.AngularObjectRegistryListener;
|
||||
import org.apache.zeppelin.display.GUI;
|
||||
import org.apache.zeppelin.interpreter.InterpreterContext;
|
||||
import org.apache.zeppelin.interpreter.InterpreterContextRunner;
|
||||
import org.apache.zeppelin.interpreter.InterpreterGroup;
|
||||
import org.apache.zeppelin.interpreter.InterpreterResult;
|
||||
import org.apache.zeppelin.interpreter.*;
|
||||
import org.apache.zeppelin.interpreter.remote.mock.MockInterpreterAngular;
|
||||
import org.apache.zeppelin.resource.LocalResourcePool;
|
||||
import org.apache.zeppelin.resource.ResourcePool;
|
||||
|
|
@ -84,7 +81,7 @@ public class RemoteAngularObjectTest implements AngularObjectRegistryListener {
|
|||
"id",
|
||||
"title",
|
||||
"text",
|
||||
null,
|
||||
new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(),
|
||||
new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
|
|
|
|||
|
|
@ -75,7 +75,7 @@ public class RemoteInterpreterOutputTestStream implements RemoteInterpreterProce
|
|||
"id",
|
||||
"title",
|
||||
"text",
|
||||
null,
|
||||
new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(),
|
||||
new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
|
|
|
|||
|
|
@ -30,10 +30,7 @@ import java.util.Properties;
|
|||
import org.apache.thrift.transport.TTransportException;
|
||||
import org.apache.zeppelin.display.AngularObjectRegistry;
|
||||
import org.apache.zeppelin.display.GUI;
|
||||
import org.apache.zeppelin.interpreter.InterpreterContext;
|
||||
import org.apache.zeppelin.interpreter.InterpreterContextRunner;
|
||||
import org.apache.zeppelin.interpreter.InterpreterGroup;
|
||||
import org.apache.zeppelin.interpreter.InterpreterResult;
|
||||
import org.apache.zeppelin.interpreter.*;
|
||||
import org.apache.zeppelin.interpreter.InterpreterResult.Code;
|
||||
import org.apache.zeppelin.interpreter.remote.mock.MockInterpreterA;
|
||||
import org.apache.zeppelin.interpreter.remote.mock.MockInterpreterB;
|
||||
|
|
@ -121,7 +118,7 @@ public class RemoteInterpreterTest {
|
|||
"id",
|
||||
"title",
|
||||
"text",
|
||||
null,
|
||||
new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(),
|
||||
new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
|
|
@ -156,7 +153,7 @@ public class RemoteInterpreterTest {
|
|||
"id",
|
||||
"title",
|
||||
"text",
|
||||
null,
|
||||
new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(),
|
||||
new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
|
|
@ -206,7 +203,7 @@ public class RemoteInterpreterTest {
|
|||
"id",
|
||||
"title",
|
||||
"text",
|
||||
null,
|
||||
new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(),
|
||||
new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
|
|
@ -220,7 +217,7 @@ public class RemoteInterpreterTest {
|
|||
"id",
|
||||
"title",
|
||||
"text",
|
||||
null,
|
||||
new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(),
|
||||
new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
|
|
@ -273,7 +270,7 @@ public class RemoteInterpreterTest {
|
|||
"jobA",
|
||||
"title",
|
||||
"text",
|
||||
null,
|
||||
new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(),
|
||||
new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
|
|
@ -309,7 +306,7 @@ public class RemoteInterpreterTest {
|
|||
"jobB",
|
||||
"title",
|
||||
"text",
|
||||
null,
|
||||
new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(),
|
||||
new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
|
|
@ -376,7 +373,7 @@ public class RemoteInterpreterTest {
|
|||
jobId,
|
||||
"title",
|
||||
"text",
|
||||
null,
|
||||
new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(),
|
||||
new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
|
|
@ -455,7 +452,7 @@ public class RemoteInterpreterTest {
|
|||
jobId,
|
||||
"title",
|
||||
"text",
|
||||
null,
|
||||
new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(),
|
||||
new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
|
|
@ -555,7 +552,7 @@ public class RemoteInterpreterTest {
|
|||
"jobA",
|
||||
"title",
|
||||
"text",
|
||||
null,
|
||||
new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(),
|
||||
new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
|
|
|
|||
|
|
@ -18,10 +18,7 @@ package org.apache.zeppelin.resource;
|
|||
|
||||
import com.google.gson.Gson;
|
||||
import org.apache.zeppelin.display.GUI;
|
||||
import org.apache.zeppelin.interpreter.InterpreterContext;
|
||||
import org.apache.zeppelin.interpreter.InterpreterContextRunner;
|
||||
import org.apache.zeppelin.interpreter.InterpreterGroup;
|
||||
import org.apache.zeppelin.interpreter.InterpreterResult;
|
||||
import org.apache.zeppelin.interpreter.*;
|
||||
import org.apache.zeppelin.interpreter.remote.RemoteInterpreter;
|
||||
import org.apache.zeppelin.interpreter.remote.RemoteInterpreterEventPoller;
|
||||
import org.apache.zeppelin.interpreter.remote.mock.MockInterpreterResourcePool;
|
||||
|
|
@ -93,7 +90,7 @@ public class DistributedResourcePoolTest {
|
|||
"id",
|
||||
"title",
|
||||
"text",
|
||||
null,
|
||||
new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(),
|
||||
new GUI(),
|
||||
null,
|
||||
|
|
|
|||
|
|
@ -30,6 +30,7 @@ import java.util.Properties;
|
|||
|
||||
import org.apache.zeppelin.display.AngularObjectRegistry;
|
||||
import org.apache.zeppelin.display.GUI;
|
||||
import org.apache.zeppelin.interpreter.AuthenticationInfo;
|
||||
import org.apache.zeppelin.interpreter.InterpreterContext;
|
||||
import org.apache.zeppelin.interpreter.InterpreterContextRunner;
|
||||
import org.apache.zeppelin.interpreter.InterpreterGroup;
|
||||
|
|
@ -103,7 +104,7 @@ public class RemoteSchedulerTest implements RemoteInterpreterProcessListener {
|
|||
"jobId",
|
||||
"title",
|
||||
"text",
|
||||
null,
|
||||
new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(),
|
||||
new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
|
|
@ -176,7 +177,7 @@ public class RemoteSchedulerTest implements RemoteInterpreterProcessListener {
|
|||
"jobId1",
|
||||
"title",
|
||||
"text",
|
||||
null,
|
||||
new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(),
|
||||
new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
|
|
@ -214,7 +215,7 @@ public class RemoteSchedulerTest implements RemoteInterpreterProcessListener {
|
|||
"jobId2",
|
||||
"title",
|
||||
"text",
|
||||
null,
|
||||
new AuthenticationInfo(),
|
||||
new HashMap<String, Object>(),
|
||||
new GUI(),
|
||||
new AngularObjectRegistry(intpGroup.getId(), null),
|
||||
|
|
|
|||
Loading…
Reference in a new issue