+ * Blocking RPC to interpreter pice of code + *+ */ + @java.lang.Override + public void interprete(org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest request, + io.grpc.stub.StreamObserver
+ * Terminates this RPC Server python process + *+ */ + @java.lang.Override + public void shutdown(org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.Void request, + io.grpc.stub.StreamObserver
+ * Blocking RPC to interpreter pice of code + *+ */ + @java.lang.Override + public void interprete(org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest request, + io.grpc.stub.StreamObserver
+ * Terminates this RPC Server python process + *+ */ + @java.lang.Override + public void shutdown(org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.Void request, + io.grpc.stub.StreamObserver
+ * Blocking RPC to interpreter pice of code + *+ */ + @java.lang.Override + public org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.InterpetedResult interprete(org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest request) { + return blockingUnaryCall( + getChannel(), METHOD_INTERPRETE, getCallOptions(), request); + } + + /** + */ + @java.lang.Override + public org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeSuggestions autoComplete(org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeCompletionRequest request) { + return blockingUnaryCall( + getChannel(), METHOD_AUTO_COMPLETE, getCallOptions(), request); + } + + /** + */ + @java.lang.Override + public org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.ProgressIndicator progress(org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.Void request) { + return blockingUnaryCall( + getChannel(), METHOD_PROGRESS, getCallOptions(), request); + } + + /** + *
+ * Terminates this RPC Server python process + *+ */ + @java.lang.Override + public org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.Void shutdown(org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.Void request) { + return blockingUnaryCall( + getChannel(), METHOD_SHUTDOWN, getCallOptions(), request); + } + } + + /** + */ + public static class PythonInterpreterFutureStub extends io.grpc.stub.AbstractStub
+ * Blocking RPC to interpreter pice of code + *+ */ + @java.lang.Override + public com.google.common.util.concurrent.ListenableFuture
+ * Terminates this RPC Server python process + *+ */ + @java.lang.Override + public com.google.common.util.concurrent.ListenableFuture
optional string code = 1;
+ */
+ java.lang.String getCode();
+ /**
+ * optional string code = 1;
+ */
+ com.google.protobuf.ByteString
+ getCodeBytes();
+
+ /**
+ * optional string noteId = 2;
+ */
+ java.lang.String getNoteId();
+ /**
+ * optional string noteId = 2;
+ */
+ com.google.protobuf.ByteString
+ getNoteIdBytes();
+ }
+ /**
+ * Protobuf type {@code CodeInterpreteRequest}
+ */
+ public static final class CodeInterpreteRequest extends
+ com.google.protobuf.GeneratedMessage implements
+ // @@protoc_insertion_point(message_implements:CodeInterpreteRequest)
+ CodeInterpreteRequestOrBuilder {
+ // Use CodeInterpreteRequest.newBuilder() to construct.
+ private CodeInterpreteRequest(com.google.protobuf.GeneratedMessage.Builder builder) {
+ super(builder);
+ }
+ private CodeInterpreteRequest() {
+ code_ = "";
+ noteId_ = "";
+ }
+
+ @java.lang.Override
+ public final com.google.protobuf.UnknownFieldSet
+ getUnknownFields() {
+ return com.google.protobuf.UnknownFieldSet.getDefaultInstance();
+ }
+ private CodeInterpreteRequest(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry) {
+ this();
+ int mutable_bitField0_ = 0;
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ default: {
+ if (!input.skipField(tag)) {
+ done = true;
+ }
+ break;
+ }
+ case 10: {
+ String s = input.readStringRequireUtf8();
+
+ code_ = s;
+ break;
+ }
+ case 18: {
+ String s = input.readStringRequireUtf8();
+
+ noteId_ = s;
+ break;
+ }
+ }
+ }
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ throw new RuntimeException(e.setUnfinishedMessage(this));
+ } catch (java.io.IOException e) {
+ throw new RuntimeException(
+ new com.google.protobuf.InvalidProtocolBufferException(
+ e.getMessage()).setUnfinishedMessage(this));
+ } finally {
+ makeExtensionsImmutable();
+ }
+ }
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.internal_static_CodeInterpreteRequest_descriptor;
+ }
+
+ protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.internal_static_CodeInterpreteRequest_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest.class, org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest.Builder.class);
+ }
+
+ public static final int CODE_FIELD_NUMBER = 1;
+ private volatile java.lang.Object code_;
+ /**
+ * optional string code = 1;
+ */
+ public java.lang.String getCode() {
+ java.lang.Object ref = code_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ code_ = s;
+ return s;
+ }
+ }
+ /**
+ * optional string code = 1;
+ */
+ public com.google.protobuf.ByteString
+ getCodeBytes() {
+ java.lang.Object ref = code_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ code_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int NOTEID_FIELD_NUMBER = 2;
+ private volatile java.lang.Object noteId_;
+ /**
+ * optional string noteId = 2;
+ */
+ public java.lang.String getNoteId() {
+ java.lang.Object ref = noteId_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ noteId_ = s;
+ return s;
+ }
+ }
+ /**
+ * optional string noteId = 2;
+ */
+ public com.google.protobuf.ByteString
+ getNoteIdBytes() {
+ java.lang.Object ref = noteId_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ noteId_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ private byte memoizedIsInitialized = -1;
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized == 1) return true;
+ if (isInitialized == 0) return false;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ if (!getCodeBytes().isEmpty()) {
+ com.google.protobuf.GeneratedMessage.writeString(output, 1, code_);
+ }
+ if (!getNoteIdBytes().isEmpty()) {
+ com.google.protobuf.GeneratedMessage.writeString(output, 2, noteId_);
+ }
+ }
+
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (!getCodeBytes().isEmpty()) {
+ size += com.google.protobuf.GeneratedMessage.computeStringSize(1, code_);
+ }
+ if (!getNoteIdBytes().isEmpty()) {
+ size += com.google.protobuf.GeneratedMessage.computeStringSize(2, noteId_);
+ }
+ memoizedSize = size;
+ return size;
+ }
+
+ private static final long serialVersionUID = 0L;
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input, extensionRegistry);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+ public static Builder newBuilder(org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
+ }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ * Protobuf type {@code CodeInterpreteRequest}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessage.Builderoptional string code = 1;
+ */
+ public java.lang.String getCode() {
+ java.lang.Object ref = code_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ code_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * optional string code = 1;
+ */
+ public com.google.protobuf.ByteString
+ getCodeBytes() {
+ java.lang.Object ref = code_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ code_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * optional string code = 1;
+ */
+ public Builder setCode(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ code_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * optional string code = 1;
+ */
+ public Builder clearCode() {
+
+ code_ = getDefaultInstance().getCode();
+ onChanged();
+ return this;
+ }
+ /**
+ * optional string code = 1;
+ */
+ public Builder setCodeBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ code_ = value;
+ onChanged();
+ return this;
+ }
+
+ private java.lang.Object noteId_ = "";
+ /**
+ * optional string noteId = 2;
+ */
+ public java.lang.String getNoteId() {
+ java.lang.Object ref = noteId_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ noteId_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * optional string noteId = 2;
+ */
+ public com.google.protobuf.ByteString
+ getNoteIdBytes() {
+ java.lang.Object ref = noteId_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ noteId_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * optional string noteId = 2;
+ */
+ public Builder setNoteId(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ noteId_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * optional string noteId = 2;
+ */
+ public Builder clearNoteId() {
+
+ noteId_ = getDefaultInstance().getNoteId();
+ onChanged();
+ return this;
+ }
+ /**
+ * optional string noteId = 2;
+ */
+ public Builder setNoteIdBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ noteId_ = value;
+ onChanged();
+ return this;
+ }
+ public final Builder setUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return this;
+ }
+
+ public final Builder mergeUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return this;
+ }
+
+
+ // @@protoc_insertion_point(builder_scope:CodeInterpreteRequest)
+ }
+
+ // @@protoc_insertion_point(class_scope:CodeInterpreteRequest)
+ private static final org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest DEFAULT_INSTANCE;
+ static {
+ DEFAULT_INSTANCE = new org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest();
+ }
+
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeInterpreteRequest getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.Parseroptional string output = 1;
+ */
+ java.lang.String getOutput();
+ /**
+ * optional string output = 1;
+ */
+ com.google.protobuf.ByteString
+ getOutputBytes();
+
+ /**
+ * optional string status = 2;
+ *
+ * + *TODO(bzz) replace \w enum + *+ */ + java.lang.String getStatus(); + /** + *
optional string status = 2;
+ *
+ * + *TODO(bzz) replace \w enum + *+ */ + com.google.protobuf.ByteString + getStatusBytes(); + } + /** + * Protobuf type {@code InterpetedResult} + */ + public static final class InterpetedResult extends + com.google.protobuf.GeneratedMessage implements + // @@protoc_insertion_point(message_implements:InterpetedResult) + InterpetedResultOrBuilder { + // Use InterpetedResult.newBuilder() to construct. + private InterpetedResult(com.google.protobuf.GeneratedMessage.Builder builder) { + super(builder); + } + private InterpetedResult() { + output_ = ""; + status_ = ""; + } + + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return com.google.protobuf.UnknownFieldSet.getDefaultInstance(); + } + private InterpetedResult( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) { + this(); + int mutable_bitField0_ = 0; + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + default: { + if (!input.skipField(tag)) { + done = true; + } + break; + } + case 10: { + String s = input.readStringRequireUtf8(); + + output_ = s; + break; + } + case 18: { + String s = input.readStringRequireUtf8(); + + status_ = s; + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw new RuntimeException(e.setUnfinishedMessage(this)); + } catch (java.io.IOException e) { + throw new RuntimeException( + new com.google.protobuf.InvalidProtocolBufferException( + e.getMessage()).setUnfinishedMessage(this)); + } finally { + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.internal_static_InterpetedResult_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.internal_static_InterpetedResult_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.InterpetedResult.class, org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.InterpetedResult.Builder.class); + } + + public static final int OUTPUT_FIELD_NUMBER = 1; + private volatile java.lang.Object output_; + /** + *
optional string output = 1;
+ */
+ public java.lang.String getOutput() {
+ java.lang.Object ref = output_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ output_ = s;
+ return s;
+ }
+ }
+ /**
+ * optional string output = 1;
+ */
+ public com.google.protobuf.ByteString
+ getOutputBytes() {
+ java.lang.Object ref = output_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ output_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int STATUS_FIELD_NUMBER = 2;
+ private volatile java.lang.Object status_;
+ /**
+ * optional string status = 2;
+ *
+ * + *TODO(bzz) replace \w enum + *+ */ + public java.lang.String getStatus() { + java.lang.Object ref = status_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + status_ = s; + return s; + } + } + /** + *
optional string status = 2;
+ *
+ * + *TODO(bzz) replace \w enum + *+ */ + public com.google.protobuf.ByteString + getStatusBytes() { + java.lang.Object ref = status_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + status_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; + } + + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + if (!getOutputBytes().isEmpty()) { + com.google.protobuf.GeneratedMessage.writeString(output, 1, output_); + } + if (!getStatusBytes().isEmpty()) { + com.google.protobuf.GeneratedMessage.writeString(output, 2, status_); + } + } + + public int getSerializedSize() { + int size = memoizedSize; + if (size != -1) return size; + + size = 0; + if (!getOutputBytes().isEmpty()) { + size += com.google.protobuf.GeneratedMessage.computeStringSize(1, output_); + } + if (!getStatusBytes().isEmpty()) { + size += com.google.protobuf.GeneratedMessage.computeStringSize(2, status_); + } + memoizedSize = size; + return size; + } + + private static final long serialVersionUID = 0L; + public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.InterpetedResult parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.InterpetedResult parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.InterpetedResult parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.InterpetedResult parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.InterpetedResult parseFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.InterpetedResult parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.InterpetedResult parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input); + } + public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.InterpetedResult parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input, extensionRegistry); + } + public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.InterpetedResult parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.InterpetedResult parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder() { + return DEFAULT_INSTANCE.toBuilder(); + } + public static Builder newBuilder(org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.InterpetedResult prototype) { + return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); + } + public Builder toBuilder() { + return this == DEFAULT_INSTANCE + ? new Builder() : new Builder().mergeFrom(this); + } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessage.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * Protobuf type {@code InterpetedResult} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessage.Builder
optional string output = 1;
+ */
+ public java.lang.String getOutput() {
+ java.lang.Object ref = output_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ output_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * optional string output = 1;
+ */
+ public com.google.protobuf.ByteString
+ getOutputBytes() {
+ java.lang.Object ref = output_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ output_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * optional string output = 1;
+ */
+ public Builder setOutput(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ output_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * optional string output = 1;
+ */
+ public Builder clearOutput() {
+
+ output_ = getDefaultInstance().getOutput();
+ onChanged();
+ return this;
+ }
+ /**
+ * optional string output = 1;
+ */
+ public Builder setOutputBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ output_ = value;
+ onChanged();
+ return this;
+ }
+
+ private java.lang.Object status_ = "";
+ /**
+ * optional string status = 2;
+ *
+ * + *TODO(bzz) replace \w enum + *+ */ + public java.lang.String getStatus() { + java.lang.Object ref = status_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + status_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + *
optional string status = 2;
+ *
+ * + *TODO(bzz) replace \w enum + *+ */ + public com.google.protobuf.ByteString + getStatusBytes() { + java.lang.Object ref = status_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + status_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + *
optional string status = 2;
+ *
+ * + *TODO(bzz) replace \w enum + *+ */ + public Builder setStatus( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + + status_ = value; + onChanged(); + return this; + } + /** + *
optional string status = 2;
+ *
+ * + *TODO(bzz) replace \w enum + *+ */ + public Builder clearStatus() { + + status_ = getDefaultInstance().getStatus(); + onChanged(); + return this; + } + /** + *
optional string status = 2;
+ *
+ * + *TODO(bzz) replace \w enum + *+ */ + public Builder setStatusBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + checkByteStringIsUtf8(value); + + status_ = value; + onChanged(); + return this; + } + public final Builder setUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return this; + } + + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return this; + } + + + // @@protoc_insertion_point(builder_scope:InterpetedResult) + } + + // @@protoc_insertion_point(class_scope:InterpetedResult) + private static final org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.InterpetedResult DEFAULT_INSTANCE; + static { + DEFAULT_INSTANCE = new org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.InterpetedResult(); + } + + public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.InterpetedResult getDefaultInstance() { + return DEFAULT_INSTANCE; + } + + private static final com.google.protobuf.Parser
optional string context = 1;
+ */
+ java.lang.String getContext();
+ /**
+ * optional string context = 1;
+ */
+ com.google.protobuf.ByteString
+ getContextBytes();
+ }
+ /**
+ * Protobuf type {@code CodeCompletionRequest}
+ */
+ public static final class CodeCompletionRequest extends
+ com.google.protobuf.GeneratedMessage implements
+ // @@protoc_insertion_point(message_implements:CodeCompletionRequest)
+ CodeCompletionRequestOrBuilder {
+ // Use CodeCompletionRequest.newBuilder() to construct.
+ private CodeCompletionRequest(com.google.protobuf.GeneratedMessage.Builder builder) {
+ super(builder);
+ }
+ private CodeCompletionRequest() {
+ context_ = "";
+ }
+
+ @java.lang.Override
+ public final com.google.protobuf.UnknownFieldSet
+ getUnknownFields() {
+ return com.google.protobuf.UnknownFieldSet.getDefaultInstance();
+ }
+ private CodeCompletionRequest(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry) {
+ this();
+ int mutable_bitField0_ = 0;
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ default: {
+ if (!input.skipField(tag)) {
+ done = true;
+ }
+ break;
+ }
+ case 10: {
+ String s = input.readStringRequireUtf8();
+
+ context_ = s;
+ break;
+ }
+ }
+ }
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ throw new RuntimeException(e.setUnfinishedMessage(this));
+ } catch (java.io.IOException e) {
+ throw new RuntimeException(
+ new com.google.protobuf.InvalidProtocolBufferException(
+ e.getMessage()).setUnfinishedMessage(this));
+ } finally {
+ makeExtensionsImmutable();
+ }
+ }
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.internal_static_CodeCompletionRequest_descriptor;
+ }
+
+ protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.internal_static_CodeCompletionRequest_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeCompletionRequest.class, org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeCompletionRequest.Builder.class);
+ }
+
+ public static final int CONTEXT_FIELD_NUMBER = 1;
+ private volatile java.lang.Object context_;
+ /**
+ * optional string context = 1;
+ */
+ public java.lang.String getContext() {
+ java.lang.Object ref = context_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ context_ = s;
+ return s;
+ }
+ }
+ /**
+ * optional string context = 1;
+ */
+ public com.google.protobuf.ByteString
+ getContextBytes() {
+ java.lang.Object ref = context_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ context_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ private byte memoizedIsInitialized = -1;
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized == 1) return true;
+ if (isInitialized == 0) return false;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ if (!getContextBytes().isEmpty()) {
+ com.google.protobuf.GeneratedMessage.writeString(output, 1, context_);
+ }
+ }
+
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (!getContextBytes().isEmpty()) {
+ size += com.google.protobuf.GeneratedMessage.computeStringSize(1, context_);
+ }
+ memoizedSize = size;
+ return size;
+ }
+
+ private static final long serialVersionUID = 0L;
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeCompletionRequest parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeCompletionRequest parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeCompletionRequest parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeCompletionRequest parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeCompletionRequest parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeCompletionRequest parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeCompletionRequest parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeCompletionRequest parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input, extensionRegistry);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeCompletionRequest parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeCompletionRequest parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+ public static Builder newBuilder(org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeCompletionRequest prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
+ }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ * Protobuf type {@code CodeCompletionRequest}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessage.Builderoptional string context = 1;
+ */
+ public java.lang.String getContext() {
+ java.lang.Object ref = context_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ context_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * optional string context = 1;
+ */
+ public com.google.protobuf.ByteString
+ getContextBytes() {
+ java.lang.Object ref = context_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ context_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * optional string context = 1;
+ */
+ public Builder setContext(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ context_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * optional string context = 1;
+ */
+ public Builder clearContext() {
+
+ context_ = getDefaultInstance().getContext();
+ onChanged();
+ return this;
+ }
+ /**
+ * optional string context = 1;
+ */
+ public Builder setContextBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ context_ = value;
+ onChanged();
+ return this;
+ }
+ public final Builder setUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return this;
+ }
+
+ public final Builder mergeUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return this;
+ }
+
+
+ // @@protoc_insertion_point(builder_scope:CodeCompletionRequest)
+ }
+
+ // @@protoc_insertion_point(class_scope:CodeCompletionRequest)
+ private static final org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeCompletionRequest DEFAULT_INSTANCE;
+ static {
+ DEFAULT_INSTANCE = new org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeCompletionRequest();
+ }
+
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeCompletionRequest getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.Parserrepeated string suggestions = 1;
+ */
+ com.google.protobuf.ProtocolStringList
+ getSuggestionsList();
+ /**
+ * repeated string suggestions = 1;
+ */
+ int getSuggestionsCount();
+ /**
+ * repeated string suggestions = 1;
+ */
+ java.lang.String getSuggestions(int index);
+ /**
+ * repeated string suggestions = 1;
+ */
+ com.google.protobuf.ByteString
+ getSuggestionsBytes(int index);
+ }
+ /**
+ * Protobuf type {@code CodeSuggestions}
+ */
+ public static final class CodeSuggestions extends
+ com.google.protobuf.GeneratedMessage implements
+ // @@protoc_insertion_point(message_implements:CodeSuggestions)
+ CodeSuggestionsOrBuilder {
+ // Use CodeSuggestions.newBuilder() to construct.
+ private CodeSuggestions(com.google.protobuf.GeneratedMessage.Builder builder) {
+ super(builder);
+ }
+ private CodeSuggestions() {
+ suggestions_ = com.google.protobuf.LazyStringArrayList.EMPTY;
+ }
+
+ @java.lang.Override
+ public final com.google.protobuf.UnknownFieldSet
+ getUnknownFields() {
+ return com.google.protobuf.UnknownFieldSet.getDefaultInstance();
+ }
+ private CodeSuggestions(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry) {
+ this();
+ int mutable_bitField0_ = 0;
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ default: {
+ if (!input.skipField(tag)) {
+ done = true;
+ }
+ break;
+ }
+ case 10: {
+ String s = input.readStringRequireUtf8();
+ if (!((mutable_bitField0_ & 0x00000001) == 0x00000001)) {
+ suggestions_ = new com.google.protobuf.LazyStringArrayList();
+ mutable_bitField0_ |= 0x00000001;
+ }
+ suggestions_.add(s);
+ break;
+ }
+ }
+ }
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ throw new RuntimeException(e.setUnfinishedMessage(this));
+ } catch (java.io.IOException e) {
+ throw new RuntimeException(
+ new com.google.protobuf.InvalidProtocolBufferException(
+ e.getMessage()).setUnfinishedMessage(this));
+ } finally {
+ if (((mutable_bitField0_ & 0x00000001) == 0x00000001)) {
+ suggestions_ = suggestions_.getUnmodifiableView();
+ }
+ makeExtensionsImmutable();
+ }
+ }
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.internal_static_CodeSuggestions_descriptor;
+ }
+
+ protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.internal_static_CodeSuggestions_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeSuggestions.class, org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeSuggestions.Builder.class);
+ }
+
+ public static final int SUGGESTIONS_FIELD_NUMBER = 1;
+ private com.google.protobuf.LazyStringList suggestions_;
+ /**
+ * repeated string suggestions = 1;
+ */
+ public com.google.protobuf.ProtocolStringList
+ getSuggestionsList() {
+ return suggestions_;
+ }
+ /**
+ * repeated string suggestions = 1;
+ */
+ public int getSuggestionsCount() {
+ return suggestions_.size();
+ }
+ /**
+ * repeated string suggestions = 1;
+ */
+ public java.lang.String getSuggestions(int index) {
+ return suggestions_.get(index);
+ }
+ /**
+ * repeated string suggestions = 1;
+ */
+ public com.google.protobuf.ByteString
+ getSuggestionsBytes(int index) {
+ return suggestions_.getByteString(index);
+ }
+
+ private byte memoizedIsInitialized = -1;
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized == 1) return true;
+ if (isInitialized == 0) return false;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ for (int i = 0; i < suggestions_.size(); i++) {
+ com.google.protobuf.GeneratedMessage.writeString(output, 1, suggestions_.getRaw(i));
+ }
+ }
+
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ {
+ int dataSize = 0;
+ for (int i = 0; i < suggestions_.size(); i++) {
+ dataSize += computeStringSizeNoTag(suggestions_.getRaw(i));
+ }
+ size += dataSize;
+ size += 1 * getSuggestionsList().size();
+ }
+ memoizedSize = size;
+ return size;
+ }
+
+ private static final long serialVersionUID = 0L;
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeSuggestions parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeSuggestions parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeSuggestions parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeSuggestions parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeSuggestions parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeSuggestions parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeSuggestions parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeSuggestions parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input, extensionRegistry);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeSuggestions parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeSuggestions parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+ public static Builder newBuilder(org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeSuggestions prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
+ }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ * Protobuf type {@code CodeSuggestions}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessage.Builderrepeated string suggestions = 1;
+ */
+ public com.google.protobuf.ProtocolStringList
+ getSuggestionsList() {
+ return suggestions_.getUnmodifiableView();
+ }
+ /**
+ * repeated string suggestions = 1;
+ */
+ public int getSuggestionsCount() {
+ return suggestions_.size();
+ }
+ /**
+ * repeated string suggestions = 1;
+ */
+ public java.lang.String getSuggestions(int index) {
+ return suggestions_.get(index);
+ }
+ /**
+ * repeated string suggestions = 1;
+ */
+ public com.google.protobuf.ByteString
+ getSuggestionsBytes(int index) {
+ return suggestions_.getByteString(index);
+ }
+ /**
+ * repeated string suggestions = 1;
+ */
+ public Builder setSuggestions(
+ int index, java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ ensureSuggestionsIsMutable();
+ suggestions_.set(index, value);
+ onChanged();
+ return this;
+ }
+ /**
+ * repeated string suggestions = 1;
+ */
+ public Builder addSuggestions(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ ensureSuggestionsIsMutable();
+ suggestions_.add(value);
+ onChanged();
+ return this;
+ }
+ /**
+ * repeated string suggestions = 1;
+ */
+ public Builder addAllSuggestions(
+ java.lang.Iterablerepeated string suggestions = 1;
+ */
+ public Builder clearSuggestions() {
+ suggestions_ = com.google.protobuf.LazyStringArrayList.EMPTY;
+ bitField0_ = (bitField0_ & ~0x00000001);
+ onChanged();
+ return this;
+ }
+ /**
+ * repeated string suggestions = 1;
+ */
+ public Builder addSuggestionsBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+ ensureSuggestionsIsMutable();
+ suggestions_.add(value);
+ onChanged();
+ return this;
+ }
+ public final Builder setUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return this;
+ }
+
+ public final Builder mergeUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return this;
+ }
+
+
+ // @@protoc_insertion_point(builder_scope:CodeSuggestions)
+ }
+
+ // @@protoc_insertion_point(class_scope:CodeSuggestions)
+ private static final org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeSuggestions DEFAULT_INSTANCE;
+ static {
+ DEFAULT_INSTANCE = new org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeSuggestions();
+ }
+
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.CodeSuggestions getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.Parseroptional int32 progress = 1;
+ */
+ int getProgress();
+ }
+ /**
+ * Protobuf type {@code ProgressIndicator}
+ */
+ public static final class ProgressIndicator extends
+ com.google.protobuf.GeneratedMessage implements
+ // @@protoc_insertion_point(message_implements:ProgressIndicator)
+ ProgressIndicatorOrBuilder {
+ // Use ProgressIndicator.newBuilder() to construct.
+ private ProgressIndicator(com.google.protobuf.GeneratedMessage.Builder builder) {
+ super(builder);
+ }
+ private ProgressIndicator() {
+ progress_ = 0;
+ }
+
+ @java.lang.Override
+ public final com.google.protobuf.UnknownFieldSet
+ getUnknownFields() {
+ return com.google.protobuf.UnknownFieldSet.getDefaultInstance();
+ }
+ private ProgressIndicator(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry) {
+ this();
+ int mutable_bitField0_ = 0;
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ default: {
+ if (!input.skipField(tag)) {
+ done = true;
+ }
+ break;
+ }
+ case 8: {
+
+ progress_ = input.readInt32();
+ break;
+ }
+ }
+ }
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ throw new RuntimeException(e.setUnfinishedMessage(this));
+ } catch (java.io.IOException e) {
+ throw new RuntimeException(
+ new com.google.protobuf.InvalidProtocolBufferException(
+ e.getMessage()).setUnfinishedMessage(this));
+ } finally {
+ makeExtensionsImmutable();
+ }
+ }
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.internal_static_ProgressIndicator_descriptor;
+ }
+
+ protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.internal_static_ProgressIndicator_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.ProgressIndicator.class, org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.ProgressIndicator.Builder.class);
+ }
+
+ public static final int PROGRESS_FIELD_NUMBER = 1;
+ private int progress_;
+ /**
+ * optional int32 progress = 1;
+ */
+ public int getProgress() {
+ return progress_;
+ }
+
+ private byte memoizedIsInitialized = -1;
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized == 1) return true;
+ if (isInitialized == 0) return false;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ if (progress_ != 0) {
+ output.writeInt32(1, progress_);
+ }
+ }
+
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (progress_ != 0) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(1, progress_);
+ }
+ memoizedSize = size;
+ return size;
+ }
+
+ private static final long serialVersionUID = 0L;
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.ProgressIndicator parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.ProgressIndicator parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.ProgressIndicator parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.ProgressIndicator parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.ProgressIndicator parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.ProgressIndicator parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.ProgressIndicator parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.ProgressIndicator parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input, extensionRegistry);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.ProgressIndicator parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.ProgressIndicator parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+ public static Builder newBuilder(org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.ProgressIndicator prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
+ }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ * Protobuf type {@code ProgressIndicator}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessage.Builderoptional int32 progress = 1;
+ */
+ public int getProgress() {
+ return progress_;
+ }
+ /**
+ * optional int32 progress = 1;
+ */
+ public Builder setProgress(int value) {
+
+ progress_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * optional int32 progress = 1;
+ */
+ public Builder clearProgress() {
+
+ progress_ = 0;
+ onChanged();
+ return this;
+ }
+ public final Builder setUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return this;
+ }
+
+ public final Builder mergeUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return this;
+ }
+
+
+ // @@protoc_insertion_point(builder_scope:ProgressIndicator)
+ }
+
+ // @@protoc_insertion_point(class_scope:ProgressIndicator)
+ private static final org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.ProgressIndicator DEFAULT_INSTANCE;
+ static {
+ DEFAULT_INSTANCE = new org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.ProgressIndicator();
+ }
+
+ public static org.apache.zeppelin.python2.rpc.PythonInterpreterOuterClass.ProgressIndicator getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.ParserThe interpreter is compatible with Python 2 & 3.
+ To change Python version,
+ change in the interpreter configuration the python to the
+ desired version (example : python=/usr/bin/python3)
The interpreter can use all modules already installed + (with pip, easy_install, etc)
+ +print (z.input("f1","defaultValue"))
+ print(z.select("f2", [("o1","1"), ("o2","2")],2))
+ print("".join(z.checkbox("f3", [("o1","1"), ("o2","2")],["1"])))')
+
+ import matplotlib.pyplot as plt + plt.figure() + (.. ..) + z.show(plt) + plt.close() ++
z.show(plt,width='50px + z.show(plt,height='150px')
+ import pandas as pd
+ df = pd.read_csv("bank.csv", sep=";")
+ z.show(df)
+
+ %python
+ import pandas as pd
+ df = pd.read_csv("bank.csv", sep=";")
+
+ + %python.sql + %sql + SELECT * from df LIMIT 5 ++