Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Drill, mail # dev - [08/12] DRILL-233: Move protobuf IDLs to a separate module and check in the compile Java sources


Copy link to this message
-
[08/12] DRILL-233: Move protobuf IDLs to a separate module and check in the compile Java sources
jacques@... 2013-09-19, 16:45
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/07c6c21d/protocol/src/main/java/org/apache/drill/exec/proto/CoordinationProtos.java
----------------------------------------------------------------------
diff --git a/protocol/src/main/java/org/apache/drill/exec/proto/CoordinationProtos.java b/protocol/src/main/java/org/apache/drill/exec/proto/CoordinationProtos.java
new file mode 100644
index 0000000..01b8889
--- /dev/null
+++ b/protocol/src/main/java/org/apache/drill/exec/proto/CoordinationProtos.java
@@ -0,0 +1,2387 @@
+/**
+ * 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.
+ */
+// Generated by the protocol buffer compiler.  DO NOT EDIT!
+// source: Coordination.proto
+
+package org.apache.drill.exec.proto;
+
+public final class CoordinationProtos {
+  private CoordinationProtos() {}
+  public static void registerAllExtensions(
+      com.google.protobuf.ExtensionRegistry registry) {
+  }
+  public interface DrillbitEndpointOrBuilder
+      extends com.google.protobuf.MessageOrBuilder {
+
+    // optional string address = 1;
+    /**
+     * <code>optional string address = 1;</code>
+     */
+    boolean hasAddress();
+    /**
+     * <code>optional string address = 1;</code>
+     */
+    java.lang.String getAddress();
+    /**
+     * <code>optional string address = 1;</code>
+     */
+    com.google.protobuf.ByteString
+        getAddressBytes();
+
+    // optional int32 user_port = 2;
+    /**
+     * <code>optional int32 user_port = 2;</code>
+     */
+    boolean hasUserPort();
+    /**
+     * <code>optional int32 user_port = 2;</code>
+     */
+    int getUserPort();
+
+    // optional int32 bit_port = 3;
+    /**
+     * <code>optional int32 bit_port = 3;</code>
+     */
+    boolean hasBitPort();
+    /**
+     * <code>optional int32 bit_port = 3;</code>
+     */
+    int getBitPort();
+
+    // optional .exec.Roles roles = 4;
+    /**
+     * <code>optional .exec.Roles roles = 4;</code>
+     */
+    boolean hasRoles();
+    /**
+     * <code>optional .exec.Roles roles = 4;</code>
+     */
+    org.apache.drill.exec.proto.CoordinationProtos.Roles getRoles();
+    /**
+     * <code>optional .exec.Roles roles = 4;</code>
+     */
+    org.apache.drill.exec.proto.CoordinationProtos.RolesOrBuilder getRolesOrBuilder();
+  }
+  /**
+   * Protobuf type {@code exec.DrillbitEndpoint}
+   */
+  public static final class DrillbitEndpoint extends
+      com.google.protobuf.GeneratedMessage
+      implements DrillbitEndpointOrBuilder {
+    // Use DrillbitEndpoint.newBuilder() to construct.
+    private DrillbitEndpoint(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
+      super(builder);
+      this.unknownFields = builder.getUnknownFields();
+    }
+    private DrillbitEndpoint(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
+
+    private static final DrillbitEndpoint defaultInstance;
+    public static DrillbitEndpoint getDefaultInstance() {
+      return defaultInstance;
+    }
+
+    public DrillbitEndpoint getDefaultInstanceForType() {
+      return defaultInstance;
+    }
+
+    private final com.google.protobuf.UnknownFieldSet unknownFields;
+    @java.lang.Override
+    public final com.google.protobuf.UnknownFieldSet
+        getUnknownFields() {
+      return this.unknownFields;
+    }
+    private DrillbitEndpoint(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      initFields();
+      int mutable_bitField0_ = 0;
+      com.google.protobuf.UnknownFieldSet.Builder unknownFields +          com.google.protobuf.UnknownFieldSet.newBuilder();
+      try {
+        boolean done = false;
+        while (!done) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              done = true;
+              break;
+            default: {
+              if (!parseUnknownField(input, unknownFields,
+                                     extensionRegistry, tag)) {
+                done = true;
+              }
+              break;
+            }
+            case 10: {
+              bitField0_ |= 0x00000001;
+              address_ = input.readBytes();
+              break;
+            }
+            case 16: {
+              bitField0_ |= 0x00000002;
+              userPort_ = input.readInt32();
+              break;
+            }
+            case 24: {
+              bitField0_ |= 0x00000004;
+              bitPort_ = input.readInt32();
+              break;
+            }
+            case 34: {
+              org.apache.drill.exec.proto.CoordinationProtos.Roles.Builder subBuilder = null;
+              if (((bitField0_ & 0x00000008) == 0x00000008)) {
+                subBuilder = roles_.toBuilder();
+              }
+              roles_ = input.readMessage(org.apache.drill.exec.proto.CoordinationProtos.Roles.PARSER, extensionRegistry);
+              if (subBuilder != null) {
+                subBuilder.mergeFrom(roles_);
+                roles_ = subBuilder.buildPartial();
+              }
+              bitField0_ |= 0x00000008;
+              break;
+            }
+          }
+