zeppelin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zjf...@apache.org
Subject [07/13] zeppelin git commit: ZEPPELIN-2035. BI directional RPC framework between ZeppelinServer and InterpreterProcess on top of thrift
Date Fri, 15 Jun 2018 01:10:02 GMT
http://git-wip-us.apache.org/repos/asf/zeppelin/blob/7af86168/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterContext.java
----------------------------------------------------------------------
diff --git a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterContext.java
b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterContext.java
index b8abf86..1368f2c 100644
--- a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterContext.java
+++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterContext.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 /**
- * Autogenerated by Thrift Compiler (0.9.3)
+ * Autogenerated by Thrift Compiler (0.9.2)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2018-05-22")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2018-5-29")
 public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteInterpreterContext,
RemoteInterpreterContext._Fields>, java.io.Serializable, Cloneable, Comparable<RemoteInterpreterContext>
{
   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("RemoteInterpreterContext");
 
@@ -64,7 +64,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
   private static final org.apache.thrift.protocol.TField CONFIG_FIELD_DESC = new org.apache.thrift.protocol.TField("config",
org.apache.thrift.protocol.TType.STRING, (short)7);
   private static final org.apache.thrift.protocol.TField GUI_FIELD_DESC = new org.apache.thrift.protocol.TField("gui",
org.apache.thrift.protocol.TType.STRING, (short)8);
   private static final org.apache.thrift.protocol.TField NOTE_GUI_FIELD_DESC = new org.apache.thrift.protocol.TField("noteGui",
org.apache.thrift.protocol.TType.STRING, (short)9);
-  private static final org.apache.thrift.protocol.TField RUNNERS_FIELD_DESC = new org.apache.thrift.protocol.TField("runners",
org.apache.thrift.protocol.TType.STRING, (short)10);
 
   private static final Map<Class<? extends IScheme>, SchemeFactory> schemes =
new HashMap<Class<? extends IScheme>, SchemeFactory>();
   static {
@@ -81,7 +80,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
   public String config; // required
   public String gui; // required
   public String noteGui; // required
-  public String runners; // required
 
   /** The set of fields this struct contains, along with convenience methods for finding
and manipulating them. */
   public enum _Fields implements org.apache.thrift.TFieldIdEnum {
@@ -93,8 +91,7 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
     AUTHENTICATION_INFO((short)6, "authenticationInfo"),
     CONFIG((short)7, "config"),
     GUI((short)8, "gui"),
-    NOTE_GUI((short)9, "noteGui"),
-    RUNNERS((short)10, "runners");
+    NOTE_GUI((short)9, "noteGui");
 
     private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -127,8 +124,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
           return GUI;
         case 9: // NOTE_GUI
           return NOTE_GUI;
-        case 10: // RUNNERS
-          return RUNNERS;
         default:
           return null;
       }
@@ -190,8 +185,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
     tmpMap.put(_Fields.NOTE_GUI, new org.apache.thrift.meta_data.FieldMetaData("noteGui",
org.apache.thrift.TFieldRequirementType.DEFAULT, 
         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
-    tmpMap.put(_Fields.RUNNERS, new org.apache.thrift.meta_data.FieldMetaData("runners",
org.apache.thrift.TFieldRequirementType.DEFAULT, 
-        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
     metaDataMap = Collections.unmodifiableMap(tmpMap);
     org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(RemoteInterpreterContext.class,
metaDataMap);
   }
@@ -208,8 +201,7 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
     String authenticationInfo,
     String config,
     String gui,
-    String noteGui,
-    String runners)
+    String noteGui)
   {
     this();
     this.noteId = noteId;
@@ -221,7 +213,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
     this.config = config;
     this.gui = gui;
     this.noteGui = noteGui;
-    this.runners = runners;
   }
 
   /**
@@ -255,9 +246,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
     if (other.isSetNoteGui()) {
       this.noteGui = other.noteGui;
     }
-    if (other.isSetRunners()) {
-      this.runners = other.runners;
-    }
   }
 
   public RemoteInterpreterContext deepCopy() {
@@ -275,7 +263,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
     this.config = null;
     this.gui = null;
     this.noteGui = null;
-    this.runners = null;
   }
 
   public String getNoteId() {
@@ -494,30 +481,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
     }
   }
 
-  public String getRunners() {
-    return this.runners;
-  }
-
-  public RemoteInterpreterContext setRunners(String runners) {
-    this.runners = runners;
-    return this;
-  }
-
-  public void unsetRunners() {
-    this.runners = null;
-  }
-
-  /** Returns true if field runners is set (has been assigned a value) and false otherwise
*/
-  public boolean isSetRunners() {
-    return this.runners != null;
-  }
-
-  public void setRunnersIsSet(boolean value) {
-    if (!value) {
-      this.runners = null;
-    }
-  }
-
   public void setFieldValue(_Fields field, Object value) {
     switch (field) {
     case NOTE_ID:
@@ -592,14 +555,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
       }
       break;
 
-    case RUNNERS:
-      if (value == null) {
-        unsetRunners();
-      } else {
-        setRunners((String)value);
-      }
-      break;
-
     }
   }
 
@@ -632,9 +587,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
     case NOTE_GUI:
       return getNoteGui();
 
-    case RUNNERS:
-      return getRunners();
-
     }
     throw new IllegalStateException();
   }
@@ -664,8 +616,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
       return isSetGui();
     case NOTE_GUI:
       return isSetNoteGui();
-    case RUNNERS:
-      return isSetRunners();
     }
     throw new IllegalStateException();
   }
@@ -764,15 +714,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
         return false;
     }
 
-    boolean this_present_runners = true && this.isSetRunners();
-    boolean that_present_runners = true && that.isSetRunners();
-    if (this_present_runners || that_present_runners) {
-      if (!(this_present_runners && that_present_runners))
-        return false;
-      if (!this.runners.equals(that.runners))
-        return false;
-    }
-
     return true;
   }
 
@@ -825,11 +766,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
     if (present_noteGui)
       list.add(noteGui);
 
-    boolean present_runners = true && (isSetRunners());
-    list.add(present_runners);
-    if (present_runners)
-      list.add(runners);
-
     return list.hashCode();
   }
 
@@ -931,16 +867,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
         return lastComparison;
       }
     }
-    lastComparison = Boolean.valueOf(isSetRunners()).compareTo(other.isSetRunners());
-    if (lastComparison != 0) {
-      return lastComparison;
-    }
-    if (isSetRunners()) {
-      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.runners, other.runners);
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-    }
     return 0;
   }
 
@@ -1032,14 +958,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
       sb.append(this.noteGui);
     }
     first = false;
-    if (!first) sb.append(", ");
-    sb.append("runners:");
-    if (this.runners == null) {
-      sb.append("null");
-    } else {
-      sb.append(this.runners);
-    }
-    first = false;
     sb.append(")");
     return sb.toString();
   }
@@ -1155,14 +1073,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
             }
             break;
-          case 10: // RUNNERS
-            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
-              struct.runners = iprot.readString();
-              struct.setRunnersIsSet(true);
-            } else { 
-              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-            }
-            break;
           default:
             org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
         }
@@ -1223,11 +1133,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
         oprot.writeString(struct.noteGui);
         oprot.writeFieldEnd();
       }
-      if (struct.runners != null) {
-        oprot.writeFieldBegin(RUNNERS_FIELD_DESC);
-        oprot.writeString(struct.runners);
-        oprot.writeFieldEnd();
-      }
       oprot.writeFieldStop();
       oprot.writeStructEnd();
     }
@@ -1273,10 +1178,7 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
       if (struct.isSetNoteGui()) {
         optionals.set(8);
       }
-      if (struct.isSetRunners()) {
-        optionals.set(9);
-      }
-      oprot.writeBitSet(optionals, 10);
+      oprot.writeBitSet(optionals, 9);
       if (struct.isSetNoteId()) {
         oprot.writeString(struct.noteId);
       }
@@ -1304,15 +1206,12 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
       if (struct.isSetNoteGui()) {
         oprot.writeString(struct.noteGui);
       }
-      if (struct.isSetRunners()) {
-        oprot.writeString(struct.runners);
-      }
     }
 
     @Override
     public void read(org.apache.thrift.protocol.TProtocol prot, RemoteInterpreterContext
struct) throws org.apache.thrift.TException {
       TTupleProtocol iprot = (TTupleProtocol) prot;
-      BitSet incoming = iprot.readBitSet(10);
+      BitSet incoming = iprot.readBitSet(9);
       if (incoming.get(0)) {
         struct.noteId = iprot.readString();
         struct.setNoteIdIsSet(true);
@@ -1349,10 +1248,6 @@ public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteI
         struct.noteGui = iprot.readString();
         struct.setNoteGuiIsSet(true);
       }
-      if (incoming.get(9)) {
-        struct.runners = iprot.readString();
-        struct.setRunnersIsSet(true);
-      }
     }
   }
 

http://git-wip-us.apache.org/repos/asf/zeppelin/blob/7af86168/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEvent.java
----------------------------------------------------------------------
diff --git a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEvent.java
b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEvent.java
index 80c219f..6a416e5 100644
--- a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEvent.java
+++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEvent.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 /**
- * Autogenerated by Thrift Compiler (0.9.3)
+ * Autogenerated by Thrift Compiler (0.9.2)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2018-05-22")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2018-5-29")
 public class RemoteInterpreterEvent implements org.apache.thrift.TBase<RemoteInterpreterEvent,
RemoteInterpreterEvent._Fields>, java.io.Serializable, Cloneable, Comparable<RemoteInterpreterEvent>
{
   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("RemoteInterpreterEvent");
 


Mime
View raw message