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 +{ +}
