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:51 UTC
[06/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/SchemaUserBitShared.java
----------------------------------------------------------------------
diff --git a/protocol/src/main/java/org/apache/drill/exec/proto/SchemaUserBitShared.java b/protocol/src/main/java/org/apache/drill/exec/proto/SchemaUserBitShared.java
new file mode 100644
index 0000000..cb13f52
--- /dev/null
+++ b/protocol/src/main/java/org/apache/drill/exec/proto/SchemaUserBitShared.java
@@ -0,0 +1,1801 @@
+/**
+ * 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 SchemaUserBitShared
+{
+
+ public static final class UserCredentials
+ {
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.UserCredentials.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.UserCredentials.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.UserCredentials.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.UserCredentials.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.UserCredentials>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.UserCredentials message) throws java.io.IOException
+ {
+ if(message.hasUserName())
+ output.writeString(1, message.getUserName(), false);
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.UserCredentials message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.UserCredentials.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.UserCredentials.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.UserCredentials> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.UserCredentials.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.UserCredentials.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.UserCredentials.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.UserCredentials message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.UserBitShared.UserCredentials newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.UserCredentials.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.UserCredentials.Builder builder) throws java.io.IOException
+ {
+ for(int number = input.readFieldNumber(this);; number = input.readFieldNumber(this))
+ {
+ switch(number)
+ {
+ case 0:
+ return;
+ case 1:
+ builder.setUserName(input.readString());
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.UserCredentials.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.UserBitShared.UserCredentials.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.UserCredentials.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.UserCredentials.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.UserCredentials.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.UserCredentials.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.UserCredentials.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.UserCredentials.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.UserCredentials.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.UserCredentials.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 1: return "userName";
+ 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("userName", 1);
+ }
+ }
+
+ public static final class QueryId
+ {
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.QueryId.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.QueryId.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.QueryId.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.QueryId.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.QueryId>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.QueryId message) throws java.io.IOException
+ {
+ if(message.hasPart1())
+ output.writeSFixed64(1, message.getPart1(), false);
+ if(message.hasPart2())
+ output.writeSFixed64(2, message.getPart2(), false);
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.QueryId message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.QueryId.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.QueryId.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.QueryId> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.QueryId.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.QueryId.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.QueryId.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.QueryId message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.UserBitShared.QueryId newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.QueryId.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.QueryId.Builder builder) throws java.io.IOException
+ {
+ for(int number = input.readFieldNumber(this);; number = input.readFieldNumber(this))
+ {
+ switch(number)
+ {
+ case 0:
+ return;
+ case 1:
+ builder.setPart1(input.readSFixed64());
+ break;
+ case 2:
+ builder.setPart2(input.readSFixed64());
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.QueryId.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.UserBitShared.QueryId.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.QueryId.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.QueryId.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.QueryId.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.QueryId.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.QueryId.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.QueryId.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.QueryId.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.QueryId.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 1: return "part1";
+ case 2: return "part2";
+ 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("part1", 1);
+ fieldMap.put("part2", 2);
+ }
+ }
+
+ public static final class DrillPBError
+ {
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.DrillPBError.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.DrillPBError.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.DrillPBError.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.DrillPBError.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.DrillPBError>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.DrillPBError message) throws java.io.IOException
+ {
+ if(message.hasErrorId())
+ output.writeString(1, message.getErrorId(), false);
+ if(message.hasEndpoint())
+ output.writeObject(2, message.getEndpoint(), org.apache.drill.exec.proto.SchemaCoordinationProtos.DrillbitEndpoint.WRITE, false);
+
+ if(message.hasErrorType())
+ output.writeInt32(3, message.getErrorType(), false);
+ if(message.hasMessage())
+ output.writeString(4, message.getMessage(), false);
+ for(org.apache.drill.exec.proto.UserBitShared.ParsingError parsingError : message.getParsingErrorList())
+ output.writeObject(5, parsingError, org.apache.drill.exec.proto.SchemaUserBitShared.ParsingError.WRITE, true);
+
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.DrillPBError message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.DrillPBError.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.DrillPBError.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.DrillPBError> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.DrillPBError.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.DrillPBError.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.DrillPBError.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.DrillPBError message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.UserBitShared.DrillPBError newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.DrillPBError.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.readString());
+ break;
+ case 2:
+ builder.setEndpoint(input.mergeObject(org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint.newBuilder(), org.apache.drill.exec.proto.SchemaCoordinationProtos.DrillbitEndpoint.MERGE));
+
+ break;
+ case 3:
+ builder.setErrorType(input.readInt32());
+ break;
+ case 4:
+ builder.setMessage(input.readString());
+ break;
+ case 5:
+ builder.addParsingError(input.mergeObject(org.apache.drill.exec.proto.UserBitShared.ParsingError.newBuilder(), org.apache.drill.exec.proto.SchemaUserBitShared.ParsingError.MERGE));
+
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.DrillPBError.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.DrillPBError.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.DrillPBError.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.DrillPBError.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.DrillPBError.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 1: return "errorId";
+ case 2: return "endpoint";
+ case 3: return "errorType";
+ case 4: return "message";
+ case 5: return "parsingError";
+ 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("endpoint", 2);
+ fieldMap.put("errorType", 3);
+ fieldMap.put("message", 4);
+ fieldMap.put("parsingError", 5);
+ }
+ }
+
+ public static final class ParsingError
+ {
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.ParsingError.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.ParsingError.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.ParsingError.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.ParsingError.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.ParsingError>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.ParsingError message) throws java.io.IOException
+ {
+ if(message.hasStartColumn())
+ output.writeInt32(2, message.getStartColumn(), false);
+ if(message.hasStartRow())
+ output.writeInt32(3, message.getStartRow(), false);
+ if(message.hasEndColumn())
+ output.writeInt32(4, message.getEndColumn(), false);
+ if(message.hasEndRow())
+ output.writeInt32(5, message.getEndRow(), false);
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.ParsingError message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.ParsingError.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.ParsingError.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.ParsingError> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.ParsingError.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.ParsingError.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.ParsingError.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.ParsingError message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.UserBitShared.ParsingError newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.ParsingError.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.ParsingError.Builder builder) throws java.io.IOException
+ {
+ for(int number = input.readFieldNumber(this);; number = input.readFieldNumber(this))
+ {
+ switch(number)
+ {
+ case 0:
+ return;
+ case 2:
+ builder.setStartColumn(input.readInt32());
+ break;
+ case 3:
+ builder.setStartRow(input.readInt32());
+ break;
+ case 4:
+ builder.setEndColumn(input.readInt32());
+ break;
+ case 5:
+ builder.setEndRow(input.readInt32());
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.ParsingError.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.UserBitShared.ParsingError.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.ParsingError.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.ParsingError.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.ParsingError.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.ParsingError.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.ParsingError.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.ParsingError.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.ParsingError.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.ParsingError.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 2: return "startColumn";
+ case 3: return "startRow";
+ case 4: return "endColumn";
+ case 5: return "endRow";
+ 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("startColumn", 2);
+ fieldMap.put("startRow", 3);
+ fieldMap.put("endColumn", 4);
+ fieldMap.put("endRow", 5);
+ }
+ }
+
+ public static final class RecordBatchDef
+ {
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.RecordBatchDef.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.RecordBatchDef.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.RecordBatchDef.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.RecordBatchDef.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.RecordBatchDef>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.RecordBatchDef message) throws java.io.IOException
+ {
+ if(message.hasRecordCount())
+ output.writeInt32(1, message.getRecordCount(), false);
+ for(org.apache.drill.exec.proto.UserBitShared.SerializedField field : message.getFieldList())
+ output.writeObject(2, field, org.apache.drill.exec.proto.SchemaUserBitShared.SerializedField.WRITE, true);
+
+ if(message.hasCarriesTwoByteSelectionVector())
+ output.writeBool(3, message.getCarriesTwoByteSelectionVector(), false);
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.RecordBatchDef message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.RecordBatchDef.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.RecordBatchDef.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.RecordBatchDef> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.RecordBatchDef message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.UserBitShared.RecordBatchDef newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.Builder builder) throws java.io.IOException
+ {
+ for(int number = input.readFieldNumber(this);; number = input.readFieldNumber(this))
+ {
+ switch(number)
+ {
+ case 0:
+ return;
+ case 1:
+ builder.setRecordCount(input.readInt32());
+ break;
+ case 2:
+ builder.addField(input.mergeObject(org.apache.drill.exec.proto.UserBitShared.SerializedField.newBuilder(), org.apache.drill.exec.proto.SchemaUserBitShared.SerializedField.MERGE));
+
+ break;
+ case 3:
+ builder.setCarriesTwoByteSelectionVector(input.readBool());
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.RecordBatchDef.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.RecordBatchDef.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 1: return "recordCount";
+ case 2: return "field";
+ case 3: return "carriesTwoByteSelectionVector";
+ 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("recordCount", 1);
+ fieldMap.put("field", 2);
+ fieldMap.put("carriesTwoByteSelectionVector", 3);
+ }
+ }
+
+ public static final class NamePart
+ {
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.NamePart.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.NamePart.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.NamePart.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.NamePart.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.NamePart>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.NamePart message) throws java.io.IOException
+ {
+ if(message.hasType())
+ output.writeEnum(1, message.getType().getNumber(), false);
+ if(message.hasName())
+ output.writeString(2, message.getName(), false);
+ if(message.hasChild())
+ output.writeObject(3, message.getChild(), org.apache.drill.exec.proto.SchemaUserBitShared.NamePart.WRITE, false);
+
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.NamePart message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.NamePart.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.NamePart.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.NamePart> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.NamePart.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.NamePart.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.NamePart.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.NamePart message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.UserBitShared.NamePart newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.NamePart.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.NamePart.Builder builder) throws java.io.IOException
+ {
+ for(int number = input.readFieldNumber(this);; number = input.readFieldNumber(this))
+ {
+ switch(number)
+ {
+ case 0:
+ return;
+ case 1:
+ builder.setType(org.apache.drill.exec.proto.UserBitShared.NamePart.Type.valueOf(input.readEnum()));
+ break;
+ case 2:
+ builder.setName(input.readString());
+ break;
+ case 3:
+ builder.setChild(input.mergeObject(org.apache.drill.exec.proto.UserBitShared.NamePart.newBuilder(), org.apache.drill.exec.proto.SchemaUserBitShared.NamePart.MERGE));
+
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.NamePart.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.UserBitShared.NamePart.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.NamePart.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.NamePart.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.NamePart.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.NamePart.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.NamePart.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.NamePart.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.NamePart.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.NamePart.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 1: return "type";
+ case 2: return "name";
+ case 3: return "child";
+ 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("type", 1);
+ fieldMap.put("name", 2);
+ fieldMap.put("child", 3);
+ }
+ }
+
+ public static final class SerializedField
+ {
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.SerializedField.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.SerializedField.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.SerializedField.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.SerializedField.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.SerializedField>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.SerializedField message) throws java.io.IOException
+ {
+ if(message.hasMajorType())
+ output.writeObject(1, message.getMajorType(), org.apache.drill.common.types.SchemaTypeProtos.MajorType.WRITE, false);
+
+ if(message.hasNamePart())
+ output.writeObject(2, message.getNamePart(), org.apache.drill.exec.proto.SchemaUserBitShared.NamePart.WRITE, false);
+
+ for(org.apache.drill.exec.proto.UserBitShared.SerializedField child : message.getChildList())
+ output.writeObject(3, child, org.apache.drill.exec.proto.SchemaUserBitShared.SerializedField.WRITE, true);
+
+ if(message.hasValueCount())
+ output.writeInt32(4, message.getValueCount(), false);
+ if(message.hasVarByteLength())
+ output.writeInt32(5, message.getVarByteLength(), false);
+ if(message.hasGroupCount())
+ output.writeInt32(6, message.getGroupCount(), false);
+ if(message.hasBufferLength())
+ output.writeInt32(7, message.getBufferLength(), false);
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.SerializedField message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.SerializedField.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.SerializedField.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.SerializedField> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.SerializedField.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.SerializedField.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.SerializedField.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.SerializedField message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.UserBitShared.SerializedField newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.SerializedField.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.SerializedField.Builder builder) throws java.io.IOException
+ {
+ for(int number = input.readFieldNumber(this);; number = input.readFieldNumber(this))
+ {
+ switch(number)
+ {
+ case 0:
+ return;
+ case 1:
+ builder.setMajorType(input.mergeObject(org.apache.drill.common.types.TypeProtos.MajorType.newBuilder(), org.apache.drill.common.types.SchemaTypeProtos.MajorType.MERGE));
+
+ break;
+ case 2:
+ builder.setNamePart(input.mergeObject(org.apache.drill.exec.proto.UserBitShared.NamePart.newBuilder(), org.apache.drill.exec.proto.SchemaUserBitShared.NamePart.MERGE));
+
+ break;
+ case 3:
+ builder.addChild(input.mergeObject(org.apache.drill.exec.proto.UserBitShared.SerializedField.newBuilder(), org.apache.drill.exec.proto.SchemaUserBitShared.SerializedField.MERGE));
+
+ break;
+ case 4:
+ builder.setValueCount(input.readInt32());
+ break;
+ case 5:
+ builder.setVarByteLength(input.readInt32());
+ break;
+ case 6:
+ builder.setGroupCount(input.readInt32());
+ break;
+ case 7:
+ builder.setBufferLength(input.readInt32());
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.SerializedField.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.UserBitShared.SerializedField.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.SerializedField.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.SerializedField.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.SerializedField.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.SerializedField.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.SerializedField.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.SerializedField.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.SerializedField.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.SerializedField.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 1: return "majorType";
+ case 2: return "namePart";
+ case 3: return "child";
+ case 4: return "valueCount";
+ case 5: return "varByteLength";
+ case 6: return "groupCount";
+ case 7: return "bufferLength";
+ 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("majorType", 1);
+ fieldMap.put("namePart", 2);
+ fieldMap.put("child", 3);
+ fieldMap.put("valueCount", 4);
+ fieldMap.put("varByteLength", 5);
+ fieldMap.put("groupCount", 6);
+ fieldMap.put("bufferLength", 7);
+ }
+ }
+
+ public static final class QueryProfile
+ {
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.QueryProfile.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.QueryProfile.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.QueryProfile.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.QueryProfile.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.QueryProfile>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.QueryProfile message) throws java.io.IOException
+ {
+ if(message.hasId())
+ output.writeObject(1, message.getId(), org.apache.drill.exec.proto.SchemaUserBitShared.QueryId.WRITE, false);
+
+ if(message.hasType())
+ output.writeEnum(2, message.getType().getNumber(), false);
+ if(message.hasStart())
+ output.writeInt64(3, message.getStart(), false);
+ if(message.hasEnd())
+ output.writeInt64(4, message.getEnd(), false);
+ if(message.hasQuery())
+ output.writeString(5, message.getQuery(), false);
+ if(message.hasPlan())
+ output.writeString(6, message.getPlan(), false);
+ for(org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile fragmentProfile : message.getFragmentProfileList())
+ output.writeObject(7, fragmentProfile, org.apache.drill.exec.proto.SchemaUserBitShared.MajorFragmentProfile.WRITE, true);
+
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.QueryProfile message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.QueryProfile.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.QueryProfile.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.QueryProfile> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.QueryProfile.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.QueryProfile.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.QueryProfile.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.QueryProfile message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.UserBitShared.QueryProfile newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.QueryProfile.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.QueryProfile.Builder builder) throws java.io.IOException
+ {
+ for(int number = input.readFieldNumber(this);; number = input.readFieldNumber(this))
+ {
+ switch(number)
+ {
+ case 0:
+ return;
+ case 1:
+ builder.setId(input.mergeObject(org.apache.drill.exec.proto.UserBitShared.QueryId.newBuilder(), org.apache.drill.exec.proto.SchemaUserBitShared.QueryId.MERGE));
+
+ break;
+ case 2:
+ builder.setType(org.apache.drill.exec.proto.UserBitShared.QueryType.valueOf(input.readEnum()));
+ break;
+ case 3:
+ builder.setStart(input.readInt64());
+ break;
+ case 4:
+ builder.setEnd(input.readInt64());
+ break;
+ case 5:
+ builder.setQuery(input.readString());
+ break;
+ case 6:
+ builder.setPlan(input.readString());
+ break;
+ case 7:
+ builder.addFragmentProfile(input.mergeObject(org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.newBuilder(), org.apache.drill.exec.proto.SchemaUserBitShared.MajorFragmentProfile.MERGE));
+
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.QueryProfile.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.UserBitShared.QueryProfile.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.QueryProfile.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.QueryProfile.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.QueryProfile.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.QueryProfile.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.QueryProfile.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.QueryProfile.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.QueryProfile.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.QueryProfile.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 1: return "id";
+ case 2: return "type";
+ case 3: return "start";
+ case 4: return "end";
+ case 5: return "query";
+ case 6: return "plan";
+ case 7: return "fragmentProfile";
+ 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("id", 1);
+ fieldMap.put("type", 2);
+ fieldMap.put("start", 3);
+ fieldMap.put("end", 4);
+ fieldMap.put("query", 5);
+ fieldMap.put("plan", 6);
+ fieldMap.put("fragmentProfile", 7);
+ }
+ }
+
+ public static final class MajorFragmentProfile
+ {
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.MajorFragmentProfile.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.MajorFragmentProfile.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.MajorFragmentProfile.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.MajorFragmentProfile.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile message) throws java.io.IOException
+ {
+ if(message.hasMajorFragmentId())
+ output.writeInt32(1, message.getMajorFragmentId(), false);
+ for(org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile minorFragmentProfile : message.getMinorFragmentProfileList())
+ output.writeObject(2, minorFragmentProfile, org.apache.drill.exec.proto.SchemaUserBitShared.MinorFragmentProfile.WRITE, true);
+
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.MajorFragmentProfile.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.MajorFragmentProfile.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.Builder builder) throws java.io.IOException
+ {
+ for(int number = input.readFieldNumber(this);; number = input.readFieldNumber(this))
+ {
+ switch(number)
+ {
+ case 0:
+ return;
+ case 1:
+ builder.setMajorFragmentId(input.readInt32());
+ break;
+ case 2:
+ builder.addMinorFragmentProfile(input.mergeObject(org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile.newBuilder(), org.apache.drill.exec.proto.SchemaUserBitShared.MinorFragmentProfile.MERGE));
+
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.MajorFragmentProfile.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.MajorFragmentProfile.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 1: return "majorFragmentId";
+ case 2: return "minorFragmentProfile";
+ 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("majorFragmentId", 1);
+ fieldMap.put("minorFragmentProfile", 2);
+ }
+ }
+
+ public static final class MinorFragmentProfile
+ {
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.MinorFragmentProfile.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.MinorFragmentProfile.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.MinorFragmentProfile.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.MinorFragmentProfile.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile message) throws java.io.IOException
+ {
+ if(message.hasState())
+ output.writeEnum(1, message.getState().getNumber(), false);
+ if(message.hasError())
+ output.writeObject(2, message.getError(), org.apache.drill.exec.proto.SchemaUserBitShared.DrillPBError.WRITE, false);
+
+ if(message.hasMinorFragmentId())
+ output.writeInt32(3, message.getMinorFragmentId(), false);
+ for(org.apache.drill.exec.proto.UserBitShared.OperatorProfile operatorProfile : message.getOperatorProfileList())
+ output.writeObject(4, operatorProfile, org.apache.drill.exec.proto.SchemaUserBitShared.OperatorProfile.WRITE, true);
+
+ if(message.hasStartTime())
+ output.writeInt64(5, message.getStartTime(), false);
+ if(message.hasEndTime())
+ output.writeInt64(6, message.getEndTime(), false);
+ if(message.hasMemoryUsed())
+ output.writeInt64(7, message.getMemoryUsed(), false);
+ if(message.hasMaxMemoryUsed())
+ output.writeInt64(8, message.getMaxMemoryUsed(), false);
+ if(message.hasEndpoint())
+ output.writeObject(9, message.getEndpoint(), org.apache.drill.exec.proto.SchemaCoordinationProtos.DrillbitEndpoint.WRITE, false);
+
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.MinorFragmentProfile.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.MinorFragmentProfile.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile.Builder builder) throws java.io.IOException
+ {
+ for(int number = input.readFieldNumber(this);; number = input.readFieldNumber(this))
+ {
+ switch(number)
+ {
+ case 0:
+ return;
+ case 1:
+ builder.setState(org.apache.drill.exec.proto.UserBitShared.FragmentState.valueOf(input.readEnum()));
+ break;
+ case 2:
+ builder.setError(input.mergeObject(org.apache.drill.exec.proto.UserBitShared.DrillPBError.newBuilder(), org.apache.drill.exec.proto.SchemaUserBitShared.DrillPBError.MERGE));
+
+ break;
+ case 3:
+ builder.setMinorFragmentId(input.readInt32());
+ break;
+ case 4:
+ builder.addOperatorProfile(input.mergeObject(org.apache.drill.exec.proto.UserBitShared.OperatorProfile.newBuilder(), org.apache.drill.exec.proto.SchemaUserBitShared.OperatorProfile.MERGE));
+
+ break;
+ case 5:
+ builder.setStartTime(input.readInt64());
+ break;
+ case 6:
+ builder.setEndTime(input.readInt64());
+ break;
+ case 7:
+ builder.setMemoryUsed(input.readInt64());
+ break;
+ case 8:
+ builder.setMaxMemoryUsed(input.readInt64());
+ break;
+ case 9:
+ builder.setEndpoint(input.mergeObject(org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint.newBuilder(), org.apache.drill.exec.proto.SchemaCoordinationProtos.DrillbitEndpoint.MERGE));
+
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.MinorFragmentProfile.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.MinorFragmentProfile.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 1: return "state";
+ case 2: return "error";
+ case 3: return "minorFragmentId";
+ case 4: return "operatorProfile";
+ case 5: return "startTime";
+ case 6: return "endTime";
+ case 7: return "memoryUsed";
+ case 8: return "maxMemoryUsed";
+ case 9: return "endpoint";
+ 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("state", 1);
+ fieldMap.put("error", 2);
+ fieldMap.put("minorFragmentId", 3);
+ fieldMap.put("operatorProfile", 4);
+ fieldMap.put("startTime", 5);
+ fieldMap.put("endTime", 6);
+ fieldMap.put("memoryUsed", 7);
+ fieldMap.put("maxMemoryUsed", 8);
+ fieldMap.put("endpoint", 9);
+ }
+ }
+
+ public static final class OperatorProfile
+ {
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.OperatorProfile.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.OperatorProfile.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.OperatorProfile.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.OperatorProfile.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.OperatorProfile>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.OperatorProfile message) throws java.io.IOException
+ {
+ for(org.apache.drill.exec.proto.UserBitShared.StreamProfile inputProfile : message.getInputProfileList())
+ output.writeObject(1, inputProfile, org.apache.drill.exec.proto.SchemaUserBitShared.StreamProfile.WRITE, true);
+
+ if(message.hasOperatorId())
+ output.writeInt32(3, message.getOperatorId(), false);
+ if(message.hasOperatorType())
+ output.writeInt32(4, message.getOperatorType(), false);
+ if(message.hasSetupNanos())
+ output.writeInt64(5, message.getSetupNanos(), false);
+ if(message.hasProcessNanos())
+ output.writeInt64(6, message.getProcessNanos(), false);
+ if(message.hasLocalMemoryAllocated())
+ output.writeInt64(7, message.getLocalMemoryAllocated(), false);
+ for(org.apache.drill.exec.proto.UserBitShared.MetricValue metric : message.getMetricList())
+ output.writeObject(8, metric, org.apache.drill.exec.proto.SchemaUserBitShared.MetricValue.WRITE, true);
+
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.OperatorProfile message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.OperatorProfile.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.OperatorProfile.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.OperatorProfile> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.OperatorProfile.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.OperatorProfile.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.OperatorProfile.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.OperatorProfile message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.UserBitShared.OperatorProfile newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.OperatorProfile.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.OperatorProfile.Builder builder) throws java.io.IOException
+ {
+ for(int number = input.readFieldNumber(this);; number = input.readFieldNumber(this))
+ {
+ switch(number)
+ {
+ case 0:
+ return;
+ case 1:
+ builder.addInputProfile(input.mergeObject(org.apache.drill.exec.proto.UserBitShared.StreamProfile.newBuilder(), org.apache.drill.exec.proto.SchemaUserBitShared.StreamProfile.MERGE));
+
+ break;
+ case 3:
+ builder.setOperatorId(input.readInt32());
+ break;
+ case 4:
+ builder.setOperatorType(input.readInt32());
+ break;
+ case 5:
+ builder.setSetupNanos(input.readInt64());
+ break;
+ case 6:
+ builder.setProcessNanos(input.readInt64());
+ break;
+ case 7:
+ builder.setLocalMemoryAllocated(input.readInt64());
+ break;
+ case 8:
+ builder.addMetric(input.mergeObject(org.apache.drill.exec.proto.UserBitShared.MetricValue.newBuilder(), org.apache.drill.exec.proto.SchemaUserBitShared.MetricValue.MERGE));
+
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.OperatorProfile.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.UserBitShared.OperatorProfile.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.OperatorProfile.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.OperatorProfile.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.OperatorProfile.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.OperatorProfile.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.OperatorProfile.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.OperatorProfile.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.OperatorProfile.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.OperatorProfile.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 1: return "inputProfile";
+ case 3: return "operatorId";
+ case 4: return "operatorType";
+ case 5: return "setupNanos";
+ case 6: return "processNanos";
+ case 7: return "localMemoryAllocated";
+ case 8: return "metric";
+ 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("inputProfile", 1);
+ fieldMap.put("operatorId", 3);
+ fieldMap.put("operatorType", 4);
+ fieldMap.put("setupNanos", 5);
+ fieldMap.put("processNanos", 6);
+ fieldMap.put("localMemoryAllocated", 7);
+ fieldMap.put("metric", 8);
+ }
+ }
+
+ public static final class StreamProfile
+ {
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.StreamProfile.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.StreamProfile.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.StreamProfile.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.StreamProfile.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.StreamProfile>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.StreamProfile message) throws java.io.IOException
+ {
+ if(message.hasRecords())
+ output.writeInt64(1, message.getRecords(), false);
+ if(message.hasBatches())
+ output.writeInt64(2, message.getBatches(), false);
+ if(message.hasSchemas())
+ output.writeInt64(3, message.getSchemas(), false);
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.StreamProfile message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.StreamProfile.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.StreamProfile.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.StreamProfile> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.StreamProfile.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.StreamProfile.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.StreamProfile.class.getName();
+ }
+ //unused
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.StreamProfile message) throws java.io.IOException {}
+ public org.apache.drill.exec.proto.UserBitShared.StreamProfile newMessage() { return null; }
+ }
+ public static class BuilderSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.StreamProfile.Builder>
+ {
+ public void mergeFrom(com.dyuproject.protostuff.Input input, org.apache.drill.exec.proto.UserBitShared.StreamProfile.Builder builder) throws java.io.IOException
+ {
+ for(int number = input.readFieldNumber(this);; number = input.readFieldNumber(this))
+ {
+ switch(number)
+ {
+ case 0:
+ return;
+ case 1:
+ builder.setRecords(input.readInt64());
+ break;
+ case 2:
+ builder.setBatches(input.readInt64());
+ break;
+ case 3:
+ builder.setSchemas(input.readInt64());
+ break;
+ default:
+ input.handleUnknownField(number, this);
+ }
+ }
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.StreamProfile.Builder builder)
+ {
+ return builder.isInitialized();
+ }
+ public org.apache.drill.exec.proto.UserBitShared.StreamProfile.Builder newMessage()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.StreamProfile.newBuilder();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.StreamProfile.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.StreamProfile.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.StreamProfile.Builder> typeClass()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.StreamProfile.Builder.class;
+ }
+ public java.lang.String messageName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.StreamProfile.class.getSimpleName();
+ }
+ public java.lang.String messageFullName()
+ {
+ return org.apache.drill.exec.proto.UserBitShared.StreamProfile.class.getName();
+ }
+ //unused
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.StreamProfile.Builder builder) throws java.io.IOException {}
+ }
+ public static java.lang.String getFieldName(int number)
+ {
+ switch(number)
+ {
+ case 1: return "records";
+ case 2: return "batches";
+ case 3: return "schemas";
+ 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("records", 1);
+ fieldMap.put("batches", 2);
+ fieldMap.put("schemas", 3);
+ }
+ }
+
+ public static final class MetricValue
+ {
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.MetricValue.MessageSchema WRITE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.MetricValue.MessageSchema();
+ public static final org.apache.drill.exec.proto.SchemaUserBitShared.MetricValue.BuilderSchema MERGE =
+ new org.apache.drill.exec.proto.SchemaUserBitShared.MetricValue.BuilderSchema();
+
+ public static class MessageSchema implements com.dyuproject.protostuff.Schema<org.apache.drill.exec.proto.UserBitShared.MetricValue>
+ {
+ public void writeTo(com.dyuproject.protostuff.Output output, org.apache.drill.exec.proto.UserBitShared.MetricValue message) throws java.io.IOException
+ {
+ if(message.hasMetricId())
+ output.writeInt32(1, message.getMetricId(), false);
+ if(message.hasLongValue())
+ output.writeInt64(2, message.getLongValue(), false);
+ if(message.hasDoubleValue())
+ output.writeDouble(3, message.getDoubleValue(), false);
+ }
+ public boolean isInitialized(org.apache.drill.exec.proto.UserBitShared.MetricValue message)
+ {
+ return message.isInitialized();
+ }
+ public java.lang.String getFieldName(int number)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.MetricValue.getFieldName(number);
+ }
+ public int getFieldNumber(java.lang.String name)
+ {
+ return org.apache.drill.exec.proto.SchemaUserBitShared.MetricValue.getFieldNumber(name);
+ }
+ public java.lang.Class<org.apache.drill.exec.proto.UserBitShared.MetricValue> typeClass()
+ {
+
<TRUNCATED>