Apache Zeppelin 是一个让交互式数据分析变得可行的基于网页的开源框架.zip

/** * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ /** * Autogenerated by Thrift Compiler (0.13.0) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated */ package org.apache.zeppelin.interpreter.thrift; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) @javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.13.0)", date = "2021-03-09") public class RemoteInterpreterService { public interface Iface { public void createInterpreter(java.lang.String intpGroupId, java.lang.String sessionId, java.lang.String className, java.util.Map<java.lang.String,java.lang.String> properties, java.lang.String userName) throws InterpreterRPCException, org.apache.thrift.TException; public void init(java.util.Map<java.lang.String,java.lang.String> properties) throws InterpreterRPCException, org.apache.thrift.TException; public void open(java.lang.String sessionId, java.lang.String className) throws InterpreterRPCException, org.apache.thrift.TException; public void close(java.lang.String sessionId, java.lang.String className) throws InterpreterRPCException, org.apache.thrift.TException; public void reconnect(java.lang.String host, int port) throws InterpreterRPCException, org.apache.thrift.TException; public RemoteInterpreterResult interpret(java.lang.String sessionId, java.lang.String className, java.lang.String st, RemoteInterpreterContext interpreterContext) throws InterpreterRPCException, org.apache.thrift.TException; public void cancel(java.lang.String sessionId, java.lang.String className, RemoteInterpreterContext interpreterContext) throws InterpreterRPCException, org.apache.thrift.TException; public int getProgress(java.lang.String sessionId, java.lang.String className, RemoteInterpreterContext interpreterContext) throws InterpreterRPCException, org.apache.thrift.TException; public java.lang.String getFormType(java.lang.String sessionId, java.lang.String className) throws InterpreterRPCException, org.apache.thrift.TException; public java.util.List<InterpreterCompletion> completion(java.lang.String sessionId, java.lang.String className, java.lang.String buf, int cursor, RemoteInterpreterContext interpreterContext) throws InterpreterRPCException, org.apache.thrift.TException; public void shutdown() throws org.apache.thrift.TException; public java.lang.String getStatus(java.lang.String sessionId, java.lang.String jobId) throws InterpreterRPCException, org.apache.thrift.TException; public java.util.List<java.lang.String> resourcePoolGetAll() throws InterpreterRPCException, org.apache.thrift.TException; public java.nio.ByteBuffer resourceGet(java.lang.String sessionId, java.lang.String paragraphId, java.lang.String resourceName) throws InterpreterRPCException, org.apache.thrift.TException; public boolean resourceRemove(java.lang.String sessionId, java.lang.String paragraphId, java.lang.String resourceName) throws InterpreterRPCException, org.apache.thrift.TException; public java.nio.ByteBuffer resourceInvokeMethod(java.lang.String sessionId, java.lang.String paragraphId, java.lang.String resourceName, java.lang.String invokeMessage) throws InterpreterRPCException, org.apache.thrift.TException; public void angularObjectUpdate(java.lang.String name, java.lang.String sessionId, java.lang.String paragraphId, java.lang.String object) throws InterpreterRPCException, org.apache.thrift.TException; public void angularObjectAdd(java.lang.String name, java.lang.String sessionId, java.lang.String paragraphId, java.lang.String object) throws InterpreterRPCException, org.apache.thrift.TException; public void angularObjectRemove(java.lang.String name, java.lang.String sessionId, java.lang.String paragraphId) throws InterpreterRPCException, org.apache.thrift.TException; public void angularRegistryPush(java.lang.String registry) throws InterpreterRPCException, org.apache.thrift.TException; public RemoteApplicationResult loadApplication(java.lang.String applicationInstanceId, java.lang.String packageInfo, java.lang.String sessionId, java.lang.String paragraphId) throws InterpreterRPCException, org.apache.thrift.TException; public RemoteApplicationResult unloadApplication(java.lang.String applicationInstanceId) throws InterpreterRPCException, org.apache.thrift.TException; public RemoteApplicationResult runApplication(java.lang.String applicationInstanceId) throws InterpreterRPCException, org.apache.thrift.TException; } public interface AsyncIface { public void createInterpreter(java.lang.String intpGroupId, java.lang.String sessionId, java.lang.String className, java.util.Map<java.lang.String,java.lang.String> properties, java.lang.String userName, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException; public void init(java.util.Map<java.lang.String,java.lang.String> properties, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException; public void open(java.lang.String sessionId, java.lang.String className, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException; public void close(java.lang.String sessionId, java.lang.String className, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException; public void reconnect(java.lang.String host, int port, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException; public void interpret(java.lang.String sessionId, java.lang.String className, java.lang.String st, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback<RemoteInterpreterResult> resultHandler) throws org.apache.thrift.TException; public void cancel(java.lang.String sessionId, java.lang.String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException; public void getProgress(java.lang.String sessionId, java.lang.String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer> resultHandler) throws org.apache.thrift.TException; public void getFormType(java.lang.String sessionId, java.lang.String className, org.apache.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.thrift.TException; public void completion(java.lang.String sessionId, java.lang.String className, java.lang.String buf, int cursor, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback<java.util.List<InterpreterCompletion>> resultHandler) throws org.apache.thrift.TException; public void shutdown(org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException; public void getStatus(java.lang.String sessionId, java.lang.String jobId, org.apache.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.thrift.TException; public void resourcePoolGetAll(org.apache.thrift.async.AsyncMethodCall