You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by ja...@apache.org on 2014/06/11 05:51:52 UTC
[07/61] [abbrv] Enable View persistence,
Storage Plugin and System option persistence.
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/872d0abf/protocol/src/main/java/org/apache/drill/exec/proto/SchemaExecProtos.java
----------------------------------------------------------------------
diff --git a/protocol/src/main/java/org/apache/drill/exec/proto/SchemaExecProtos.java b/protocol/src/main/java/org/apache/drill/exec/proto/SchemaExecProtos.java
new file mode 100644
index 0000000..4af5e68
--- /dev/null
+++ b/protocol/src/main/java/org/apache/drill/exec/proto/SchemaExecProtos.java
@@ -0,0 +1,272 @@
+/**
+ * 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 http://code.google.com/p/protostuff/ ... DO NOT EDIT!
+// Generated from protobuf
+
+package org.apache.drill.exec.proto;
+
+
+public final class SchemaExecProtos
+{
+
+ public static final class FragmentHandle
+ {
+ public static final org.apache.drill.exec.proto.SchemaExecProtos.FragmentHandle.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaExecProtos.FragmentHandle.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaExecProtos.FragmentHandle.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaExecProtos.FragmentHandle.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.ExecProtos.FragmentHandle>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.ExecProtos.FragmentHandle message) throws java.io.IOException
+ {
+ if(message.hasQueryId())
+ output.writeObject(1, message.getQueryId(), org.apache.drill.exec.proto.SchemaUserBitShared.QueryId.WRITE, false);
+
+ if(message.hasMajorFragmentId())
+ output.writeInt32(2, message.getMajorFragmentId(), false);
+ if(message.hasMinorFragmentId())
+ output.writeInt32(3, message.getMinorFragmentId(), false);
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.ExecProtos.FragmentHandle message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaExecProtos.FragmentHandle.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaExecProtos.FragmentHandle.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.ExecProtos.FragmentHandle> typeClass()
+ {
+ return org.apache.drill.exec.proto.ExecProtos.FragmentHandle.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.ExecProtos.FragmentHandle.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.ExecProtos.FragmentHandle.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.ExecProtos.FragmentHandle message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.ExecProtos.FragmentHandle newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.ExecProtos.FragmentHandle.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.ExecProtos.FragmentHandle.Builder builder) throws java.io.IOException
+ {
+ for(int number = input.readFieldNumber(this);; number = input.readFieldNumber(this))
+ {
+ switch(number)
+ {
+ case 0:
+ return;
+ case 1:
+ builder.setQueryId(input.mergeObject(org.apache.drill.exec.proto.UserBitShared.QueryId.newBuilder(), org.apache.drill.exec.proto.SchemaUserBitShared.QueryId.MERGE));
+
+ break;
+ case 2:
+ builder.setMajorFragmentId(input.readInt32());
+ break;
+ case 3:
+ builder.setMinorFragmentId(input.readInt32());
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.ExecProtos.FragmentHandle.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.ExecProtos.FragmentHandle.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.ExecProtos.FragmentHandle.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaExecProtos.FragmentHandle.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaExecProtos.FragmentHandle.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.ExecProtos.FragmentHandle.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.ExecProtos.FragmentHandle.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.ExecProtos.FragmentHandle.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.ExecProtos.FragmentHandle.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.ExecProtos.FragmentHandle.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 1: return "queryId";
+ case 2: return "majorFragmentId";
+ case 3: return "minorFragmentId";
+ default: return null;
+ }
+ }
+ public static int getFieldNumber(java.lang.String name)
+ {
+ java.lang.Integer number = fieldMap.get(name);
+ return number == null ? 0 : number.intValue();
+ }
+ private static final java.util.HashMap<java.lang.String,java.lang.Integer> fieldMap = new java.util.HashMap<java.lang.String,java.lang.Integer>();
+ static
+ {
+ fieldMap.put("queryId", 1);
+ fieldMap.put("majorFragmentId", 2);
+ fieldMap.put("minorFragmentId", 3);
+ }
+ }
+
+ public static final class ViewPointer
+ {
+ public static final org.apache.drill.exec.proto.SchemaExecProtos.ViewPointer.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaExecProtos.ViewPointer.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaExecProtos.ViewPointer.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaExecProtos.ViewPointer.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.ExecProtos.ViewPointer>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.ExecProtos.ViewPointer message) throws java.io.IOException
+ {
+ if(message.hasName())
+ output.writeString(1, message.getName(), false);
+ if(message.hasPath())
+ output.writeString(2, message.getPath(), false);
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.ExecProtos.ViewPointer message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaExecProtos.ViewPointer.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaExecProtos.ViewPointer.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.ExecProtos.ViewPointer> typeClass()
+ {
+ return org.apache.drill.exec.proto.ExecProtos.ViewPointer.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.ExecProtos.ViewPointer.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.ExecProtos.ViewPointer.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.ExecProtos.ViewPointer message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.ExecProtos.ViewPointer newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.ExecProtos.ViewPointer.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.ExecProtos.ViewPointer.Builder builder) throws java.io.IOException
+ {
+ for(int number = input.readFieldNumber(this);; number = input.readFieldNumber(this))
+ {
+ switch(number)
+ {
+ case 0:
+ return;
+ case 1:
+ builder.setName(input.readString());
+ break;
+ case 2:
+ builder.setPath(input.readString());
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.ExecProtos.ViewPointer.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.ExecProtos.ViewPointer.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.ExecProtos.ViewPointer.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaExecProtos.ViewPointer.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaExecProtos.ViewPointer.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.ExecProtos.ViewPointer.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.ExecProtos.ViewPointer.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.ExecProtos.ViewPointer.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.ExecProtos.ViewPointer.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.ExecProtos.ViewPointer.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 1: return "name";
+ case 2: return "path";
+ default: return null;
+ }
+ }
+ public static int getFieldNumber(java.lang.String name)
+ {
+ java.lang.Integer number = fieldMap.get(name);
+ return number == null ? 0 : number.intValue();
+ }
+ private static final java.util.HashMap<java.lang.String,java.lang.Integer> fieldMap = new java.util.HashMap<java.lang.String,java.lang.Integer>();
+ static
+ {
+ fieldMap.put("name", 1);
+ fieldMap.put("path", 2);
+ }
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/872d0abf/protocol/src/main/java/org/apache/drill/exec/proto/SchemaGeneralRPCProtos.java
----------------------------------------------------------------------
diff --git a/protocol/src/main/java/org/apache/drill/exec/proto/SchemaGeneralRPCProtos.java b/protocol/src/main/java/org/apache/drill/exec/proto/SchemaGeneralRPCProtos.java
new file mode 100644
index 0000000..087cc0d
--- /dev/null
+++ b/protocol/src/main/java/org/apache/drill/exec/proto/SchemaGeneralRPCProtos.java
@@ -0,0 +1,524 @@
+/**
+ * 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 http://code.google.com/p/protostuff/ ... DO NOT EDIT!
+// Generated from protobuf
+
+package org.apache.drill.exec.proto;
+
+
+public final class SchemaGeneralRPCProtos
+{
+
+ public static final class Ack
+ {
+ public static final org.apache.drill.exec.proto.SchemaGeneralRPCProtos.Ack.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaGeneralRPCProtos.Ack.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaGeneralRPCProtos.Ack.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaGeneralRPCProtos.Ack.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.GeneralRPCProtos.Ack>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.GeneralRPCProtos.Ack message) throws java.io.IOException
+ {
+ if(message.hasOk())
+ output.writeBool(1, message.getOk(), false);
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.GeneralRPCProtos.Ack message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaGeneralRPCProtos.Ack.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaGeneralRPCProtos.Ack.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.GeneralRPCProtos.Ack> typeClass()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.Ack.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.Ack.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.Ack.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.GeneralRPCProtos.Ack message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.GeneralRPCProtos.Ack newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.GeneralRPCProtos.Ack.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.GeneralRPCProtos.Ack.Builder builder) throws java.io.IOException
+ {
+ for(int number = input.readFieldNumber(this);; number = input.readFieldNumber(this))
+ {
+ switch(number)
+ {
+ case 0:
+ return;
+ case 1:
+ builder.setOk(input.readBool());
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.GeneralRPCProtos.Ack.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.GeneralRPCProtos.Ack.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.Ack.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaGeneralRPCProtos.Ack.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaGeneralRPCProtos.Ack.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.GeneralRPCProtos.Ack.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.Ack.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.Ack.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.Ack.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.GeneralRPCProtos.Ack.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 1: return "ok";
+ default: return null;
+ }
+ }
+ public static int getFieldNumber(java.lang.String name)
+ {
+ java.lang.Integer number = fieldMap.get(name);
+ return number == null ? 0 : number.intValue();
+ }
+ private static final java.util.HashMap<java.lang.String,java.lang.Integer> fieldMap = new java.util.HashMap<java.lang.String,java.lang.Integer>();
+ static
+ {
+ fieldMap.put("ok", 1);
+ }
+ }
+
+ public static final class RpcHeader
+ {
+ public static final org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcHeader.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcHeader.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcHeader.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcHeader.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader message) throws java.io.IOException
+ {
+ if(message.hasMode())
+ output.writeEnum(1, message.getMode().getNumber(), false);
+ if(message.hasCoordinationId())
+ output.writeInt32(2, message.getCoordinationId(), false);
+ if(message.hasRpcType())
+ output.writeInt32(3, message.getRpcType(), false);
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcHeader.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcHeader.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader> typeClass()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader.Builder builder) throws java.io.IOException
+ {
+ for(int number = input.readFieldNumber(this);; number = input.readFieldNumber(this))
+ {
+ switch(number)
+ {
+ case 0:
+ return;
+ case 1:
+ builder.setMode(org.apache.drill.exec.proto.GeneralRPCProtos.RpcMode.valueOf(input.readEnum()));
+ break;
+ case 2:
+ builder.setCoordinationId(input.readInt32());
+ break;
+ case 3:
+ builder.setRpcType(input.readInt32());
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcHeader.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcHeader.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 1: return "mode";
+ case 2: return "coordinationId";
+ case 3: return "rpcType";
+ default: return null;
+ }
+ }
+ public static int getFieldNumber(java.lang.String name)
+ {
+ java.lang.Integer number = fieldMap.get(name);
+ return number == null ? 0 : number.intValue();
+ }
+ private static final java.util.HashMap<java.lang.String,java.lang.Integer> fieldMap = new java.util.HashMap<java.lang.String,java.lang.Integer>();
+ static
+ {
+ fieldMap.put("mode", 1);
+ fieldMap.put("coordinationId", 2);
+ fieldMap.put("rpcType", 3);
+ }
+ }
+
+ public static final class CompleteRpcMessage
+ {
+ public static final org.apache.drill.exec.proto.SchemaGeneralRPCProtos.CompleteRpcMessage.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaGeneralRPCProtos.CompleteRpcMessage.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaGeneralRPCProtos.CompleteRpcMessage.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaGeneralRPCProtos.CompleteRpcMessage.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage message) throws java.io.IOException
+ {
+ if(message.hasHeader())
+ output.writeObject(1, message.getHeader(), org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcHeader.WRITE, false);
+
+ if(message.hasProtobufBody())
+ output.writeByteArray(2, message.getProtobufBody().toByteArray(), false);
+
+ if(message.hasRawBody())
+ output.writeByteArray(3, message.getRawBody().toByteArray(), false);
+
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaGeneralRPCProtos.CompleteRpcMessage.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaGeneralRPCProtos.CompleteRpcMessage.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage> typeClass()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage.Builder builder) throws java.io.IOException
+ {
+ for(int number = input.readFieldNumber(this);; number = input.readFieldNumber(this))
+ {
+ switch(number)
+ {
+ case 0:
+ return;
+ case 1:
+ builder.setHeader(input.mergeObject(org.apache.drill.exec.proto.GeneralRPCProtos.RpcHeader.newBuilder(), org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcHeader.MERGE));
+
+ break;
+ case 2:
+ builder.setProtobufBody(com.google.protobuf.ByteString.copyFrom(input.readByteArray()));
+ break;
+ case 3:
+ builder.setRawBody(com.google.protobuf.ByteString.copyFrom(input.readByteArray()));
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaGeneralRPCProtos.CompleteRpcMessage.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaGeneralRPCProtos.CompleteRpcMessage.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.GeneralRPCProtos.CompleteRpcMessage.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 1: return "header";
+ case 2: return "protobufBody";
+ case 3: return "rawBody";
+ default: return null;
+ }
+ }
+ public static int getFieldNumber(java.lang.String name)
+ {
+ java.lang.Integer number = fieldMap.get(name);
+ return number == null ? 0 : number.intValue();
+ }
+ private static final java.util.HashMap<java.lang.String,java.lang.Integer> fieldMap = new java.util.HashMap<java.lang.String,java.lang.Integer>();
+ static
+ {
+ fieldMap.put("header", 1);
+ fieldMap.put("protobufBody", 2);
+ fieldMap.put("rawBody", 3);
+ }
+ }
+
+ public static final class RpcFailure
+ {
+ public static final org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcFailure.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcFailure.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcFailure.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcFailure.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure message) throws java.io.IOException
+ {
+ if(message.hasErrorId())
+ output.writeInt64(1, message.getErrorId(), false);
+ if(message.hasErrorCode())
+ output.writeInt32(2, message.getErrorCode(), false);
+ if(message.hasShortError())
+ output.writeString(3, message.getShortError(), false);
+ if(message.hasLongError())
+ output.writeString(4, message.getLongError(), false);
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcFailure.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcFailure.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure> typeClass()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure.Builder builder) throws java.io.IOException
+ {
+ for(int number = input.readFieldNumber(this);; number = input.readFieldNumber(this))
+ {
+ switch(number)
+ {
+ case 0:
+ return;
+ case 1:
+ builder.setErrorId(input.readInt64());
+ break;
+ case 2:
+ builder.setErrorCode(input.readInt32());
+ break;
+ case 3:
+ builder.setShortError(input.readString());
+ break;
+ case 4:
+ builder.setLongError(input.readString());
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcFailure.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaGeneralRPCProtos.RpcFailure.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.GeneralRPCProtos.RpcFailure.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 1: return "errorId";
+ case 2: return "errorCode";
+ case 3: return "shortError";
+ case 4: return "longError";
+ default: return null;
+ }
+ }
+ public static int getFieldNumber(java.lang.String name)
+ {
+ java.lang.Integer number = fieldMap.get(name);
+ return number == null ? 0 : number.intValue();
+ }
+ private static final java.util.HashMap<java.lang.String,java.lang.Integer> fieldMap = new java.util.HashMap<java.lang.String,java.lang.Integer>();
+ static
+ {
+ fieldMap.put("errorId", 1);
+ fieldMap.put("errorCode", 2);
+ fieldMap.put("shortError", 3);
+ fieldMap.put("longError", 4);
+ }
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/872d0abf/protocol/src/main/java/org/apache/drill/exec/proto/SchemaSchemaDefProtos.java
----------------------------------------------------------------------
diff --git a/protocol/src/main/java/org/apache/drill/exec/proto/SchemaSchemaDefProtos.java b/protocol/src/main/java/org/apache/drill/exec/proto/SchemaSchemaDefProtos.java
new file mode 100644
index 0000000..7d4aa6b
--- /dev/null
+++ b/protocol/src/main/java/org/apache/drill/exec/proto/SchemaSchemaDefProtos.java
@@ -0,0 +1,26 @@
+/**
+ * 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 http://code.google.com/p/protostuff/ ... DO NOT EDIT!
+// Generated from protobuf
+
+package org.apache.drill.exec.proto;
+
+
+public final class SchemaSchemaDefProtos
+{
+}