mirror of
https://github.com/apache/zeppelin
synced 2026-05-24 09:38:26 +00:00
Refatoring - removing old annotations
This commit is contained in:
parent
e363ed45e5
commit
5c1e3e4791
3 changed files with 4 additions and 8 deletions
|
|
@ -37,7 +37,6 @@ import org.slf4j.LoggerFactory;
|
|||
* and saving/loading jobs from disk.
|
||||
* Changing/adding/deleting non transitive field name need consideration of that.
|
||||
*
|
||||
* @author Leemoonsoo
|
||||
*/
|
||||
public abstract class Job {
|
||||
/**
|
||||
|
|
|
|||
|
|
@ -15,6 +15,7 @@
|
|||
* limitations under the License.
|
||||
*/
|
||||
package org.apache.zeppelin.socket;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.net.URISyntaxException;
|
||||
import java.net.UnknownHostException;
|
||||
|
|
@ -46,15 +47,14 @@ import org.slf4j.Logger;
|
|||
import org.slf4j.LoggerFactory;
|
||||
import com.google.common.base.Strings;
|
||||
import com.google.gson.Gson;
|
||||
|
||||
/**
|
||||
* Zeppelin websocket service.
|
||||
*
|
||||
* @author anthonycorbacho
|
||||
*/
|
||||
public class NotebookServer extends WebSocketServlet implements
|
||||
NotebookSocketListener, JobListenerFactory, AngularObjectRegistryListener {
|
||||
private static final Logger LOG = LoggerFactory
|
||||
.getLogger(NotebookServer.class);
|
||||
private static final Logger LOG = LoggerFactory.getLogger(NotebookServer.class);
|
||||
Gson gson = new Gson();
|
||||
final Map<String, List<NotebookSocket>> noteSocketMap = new HashMap<>();
|
||||
final List<NotebookSocket> connectedSockets = new LinkedList<>();
|
||||
|
|
@ -62,9 +62,9 @@ public class NotebookServer extends WebSocketServlet implements
|
|||
private Notebook notebook() {
|
||||
return ZeppelinServer.notebook;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean checkOrigin(HttpServletRequest request, String origin) {
|
||||
|
||||
try {
|
||||
return SecurityUtils.isValidOrigin(origin, ZeppelinConfiguration.create());
|
||||
} catch (UnknownHostException e) {
|
||||
|
|
@ -72,7 +72,6 @@ public class NotebookServer extends WebSocketServlet implements
|
|||
} catch (URISyntaxException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -23,7 +23,6 @@ import org.apache.zeppelin.display.Input;
|
|||
import org.apache.zeppelin.interpreter.*;
|
||||
import org.apache.zeppelin.interpreter.Interpreter.FormType;
|
||||
import org.apache.zeppelin.interpreter.InterpreterResult.Code;
|
||||
import org.apache.zeppelin.interpreter.InterpreterResult.Type;
|
||||
import org.apache.zeppelin.scheduler.Job;
|
||||
import org.apache.zeppelin.scheduler.JobListener;
|
||||
import org.slf4j.Logger;
|
||||
|
|
@ -35,7 +34,6 @@ import java.util.*;
|
|||
/**
|
||||
* Paragraph is a representation of an execution unit.
|
||||
*
|
||||
* @author Leemoonsoo
|
||||
*/
|
||||
public class Paragraph extends Job implements Serializable, Cloneable {
|
||||
private static final transient long serialVersionUID = -6328572073497992016L;
|
||||
|
|
|
|||
Loading…
Reference in a new issue