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:52:02 UTC
[17/61] [abbrv] Use PStore for profiles,
partial profiles on running queries
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/2dec152b/protocol/src/main/java/org/apache/drill/exec/proto/UserProtos.java
----------------------------------------------------------------------
diff --git a/protocol/src/main/java/org/apache/drill/exec/proto/UserProtos.java b/protocol/src/main/java/org/apache/drill/exec/proto/UserProtos.java
index 79d54a4..d9f4c20 100644
--- a/protocol/src/main/java/org/apache/drill/exec/proto/UserProtos.java
+++ b/protocol/src/main/java/org/apache/drill/exec/proto/UserProtos.java
@@ -4207,2600 +4207,6 @@ public final class UserProtos {
// @@protoc_insertion_point(class_scope:exec.user.BitToUserHandshake)
}
- public interface NodeStatusOrBuilder
- extends com.google.protobuf.MessageOrBuilder {
-
- // optional int32 node_id = 1;
- /**
- * <code>optional int32 node_id = 1;</code>
- */
- boolean hasNodeId();
- /**
- * <code>optional int32 node_id = 1;</code>
- */
- int getNodeId();
-
- // optional int64 memory_footprint = 2;
- /**
- * <code>optional int64 memory_footprint = 2;</code>
- */
- boolean hasMemoryFootprint();
- /**
- * <code>optional int64 memory_footprint = 2;</code>
- */
- long getMemoryFootprint();
- }
- /**
- * Protobuf type {@code exec.user.NodeStatus}
- */
- public static final class NodeStatus extends
- com.google.protobuf.GeneratedMessage
- implements NodeStatusOrBuilder {
- // Use NodeStatus.newBuilder() to construct.
- private NodeStatus(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
- super(builder);
- this.unknownFields = builder.getUnknownFields();
- }
- private NodeStatus(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
-
- private static final NodeStatus defaultInstance;
- public static NodeStatus getDefaultInstance() {
- return defaultInstance;
- }
-
- public NodeStatus getDefaultInstanceForType() {
- return defaultInstance;
- }
-
- private final com.google.protobuf.UnknownFieldSet unknownFields;
- @java.lang.Override
- public final com.google.protobuf.UnknownFieldSet
- getUnknownFields() {
- return this.unknownFields;
- }
- private NodeStatus(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- initFields();
- int mutable_bitField0_ = 0;
- com.google.protobuf.UnknownFieldSet.Builder unknownFields =
- com.google.protobuf.UnknownFieldSet.newBuilder();
- try {
- boolean done = false;
- while (!done) {
- int tag = input.readTag();
- switch (tag) {
- case 0:
- done = true;
- break;
- default: {
- if (!parseUnknownField(input, unknownFields,
- extensionRegistry, tag)) {
- done = true;
- }
- break;
- }
- case 8: {
- bitField0_ |= 0x00000001;
- nodeId_ = input.readInt32();
- break;
- }
- case 16: {
- bitField0_ |= 0x00000002;
- memoryFootprint_ = input.readInt64();
- break;
- }
- }
- }
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- throw e.setUnfinishedMessage(this);
- } catch (java.io.IOException e) {
- throw new com.google.protobuf.InvalidProtocolBufferException(
- e.getMessage()).setUnfinishedMessage(this);
- } finally {
- this.unknownFields = unknownFields.build();
- makeExtensionsImmutable();
- }
- }
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return org.apache.drill.exec.proto.UserProtos.internal_static_exec_user_NodeStatus_descriptor;
- }
-
- protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return org.apache.drill.exec.proto.UserProtos.internal_static_exec_user_NodeStatus_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- org.apache.drill.exec.proto.UserProtos.NodeStatus.class, org.apache.drill.exec.proto.UserProtos.NodeStatus.Builder.class);
- }
-
- public static com.google.protobuf.Parser<NodeStatus> PARSER =
- new com.google.protobuf.AbstractParser<NodeStatus>() {
- public NodeStatus parsePartialFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return new NodeStatus(input, extensionRegistry);
- }
- };
-
- @java.lang.Override
- public com.google.protobuf.Parser<NodeStatus> getParserForType() {
- return PARSER;
- }
-
- private int bitField0_;
- // optional int32 node_id = 1;
- public static final int NODE_ID_FIELD_NUMBER = 1;
- private int nodeId_;
- /**
- * <code>optional int32 node_id = 1;</code>
- */
- public boolean hasNodeId() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
- }
- /**
- * <code>optional int32 node_id = 1;</code>
- */
- public int getNodeId() {
- return nodeId_;
- }
-
- // optional int64 memory_footprint = 2;
- public static final int MEMORY_FOOTPRINT_FIELD_NUMBER = 2;
- private long memoryFootprint_;
- /**
- * <code>optional int64 memory_footprint = 2;</code>
- */
- public boolean hasMemoryFootprint() {
- return ((bitField0_ & 0x00000002) == 0x00000002);
- }
- /**
- * <code>optional int64 memory_footprint = 2;</code>
- */
- public long getMemoryFootprint() {
- return memoryFootprint_;
- }
-
- private void initFields() {
- nodeId_ = 0;
- memoryFootprint_ = 0L;
- }
- private byte memoizedIsInitialized = -1;
- public final boolean isInitialized() {
- byte isInitialized = memoizedIsInitialized;
- if (isInitialized != -1) return isInitialized == 1;
-
- memoizedIsInitialized = 1;
- return true;
- }
-
- public void writeTo(com.google.protobuf.CodedOutputStream output)
- throws java.io.IOException {
- getSerializedSize();
- if (((bitField0_ & 0x00000001) == 0x00000001)) {
- output.writeInt32(1, nodeId_);
- }
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
- output.writeInt64(2, memoryFootprint_);
- }
- getUnknownFields().writeTo(output);
- }
-
- private int memoizedSerializedSize = -1;
- public int getSerializedSize() {
- int size = memoizedSerializedSize;
- if (size != -1) return size;
-
- size = 0;
- if (((bitField0_ & 0x00000001) == 0x00000001)) {
- size += com.google.protobuf.CodedOutputStream
- .computeInt32Size(1, nodeId_);
- }
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
- size += com.google.protobuf.CodedOutputStream
- .computeInt64Size(2, memoryFootprint_);
- }
- size += getUnknownFields().getSerializedSize();
- memoizedSerializedSize = size;
- return size;
- }
-
- private static final long serialVersionUID = 0L;
- @java.lang.Override
- protected java.lang.Object writeReplace()
- throws java.io.ObjectStreamException {
- return super.writeReplace();
- }
-
- public static org.apache.drill.exec.proto.UserProtos.NodeStatus parseFrom(
- com.google.protobuf.ByteString data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static org.apache.drill.exec.proto.UserProtos.NodeStatus parseFrom(
- com.google.protobuf.ByteString data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static org.apache.drill.exec.proto.UserProtos.NodeStatus parseFrom(byte[] data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static org.apache.drill.exec.proto.UserProtos.NodeStatus parseFrom(
- byte[] data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static org.apache.drill.exec.proto.UserProtos.NodeStatus parseFrom(java.io.InputStream input)
- throws java.io.IOException {
- return PARSER.parseFrom(input);
- }
- public static org.apache.drill.exec.proto.UserProtos.NodeStatus parseFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseFrom(input, extensionRegistry);
- }
- public static org.apache.drill.exec.proto.UserProtos.NodeStatus parseDelimitedFrom(java.io.InputStream input)
- throws java.io.IOException {
- return PARSER.parseDelimitedFrom(input);
- }
- public static org.apache.drill.exec.proto.UserProtos.NodeStatus parseDelimitedFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseDelimitedFrom(input, extensionRegistry);
- }
- public static org.apache.drill.exec.proto.UserProtos.NodeStatus parseFrom(
- com.google.protobuf.CodedInputStream input)
- throws java.io.IOException {
- return PARSER.parseFrom(input);
- }
- public static org.apache.drill.exec.proto.UserProtos.NodeStatus parseFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseFrom(input, extensionRegistry);
- }
-
- public static Builder newBuilder() { return Builder.create(); }
- public Builder newBuilderForType() { return newBuilder(); }
- public static Builder newBuilder(org.apache.drill.exec.proto.UserProtos.NodeStatus prototype) {
- return newBuilder().mergeFrom(prototype);
- }
- public Builder toBuilder() { return newBuilder(this); }
-
- @java.lang.Override
- protected Builder newBuilderForType(
- com.google.protobuf.GeneratedMessage.BuilderParent parent) {
- Builder builder = new Builder(parent);
- return builder;
- }
- /**
- * Protobuf type {@code exec.user.NodeStatus}
- */
- public static final class Builder extends
- com.google.protobuf.GeneratedMessage.Builder<Builder>
- implements org.apache.drill.exec.proto.UserProtos.NodeStatusOrBuilder {
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return org.apache.drill.exec.proto.UserProtos.internal_static_exec_user_NodeStatus_descriptor;
- }
-
- protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return org.apache.drill.exec.proto.UserProtos.internal_static_exec_user_NodeStatus_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- org.apache.drill.exec.proto.UserProtos.NodeStatus.class, org.apache.drill.exec.proto.UserProtos.NodeStatus.Builder.class);
- }
-
- // Construct using org.apache.drill.exec.proto.UserProtos.NodeStatus.newBuilder()
- private Builder() {
- maybeForceBuilderInitialization();
- }
-
- private Builder(
- com.google.protobuf.GeneratedMessage.BuilderParent parent) {
- super(parent);
- maybeForceBuilderInitialization();
- }
- private void maybeForceBuilderInitialization() {
- if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
- }
- }
- private static Builder create() {
- return new Builder();
- }
-
- public Builder clear() {
- super.clear();
- nodeId_ = 0;
- bitField0_ = (bitField0_ & ~0x00000001);
- memoryFootprint_ = 0L;
- bitField0_ = (bitField0_ & ~0x00000002);
- return this;
- }
-
- public Builder clone() {
- return create().mergeFrom(buildPartial());
- }
-
- public com.google.protobuf.Descriptors.Descriptor
- getDescriptorForType() {
- return org.apache.drill.exec.proto.UserProtos.internal_static_exec_user_NodeStatus_descriptor;
- }
-
- public org.apache.drill.exec.proto.UserProtos.NodeStatus getDefaultInstanceForType() {
- return org.apache.drill.exec.proto.UserProtos.NodeStatus.getDefaultInstance();
- }
-
- public org.apache.drill.exec.proto.UserProtos.NodeStatus build() {
- org.apache.drill.exec.proto.UserProtos.NodeStatus result = buildPartial();
- if (!result.isInitialized()) {
- throw newUninitializedMessageException(result);
- }
- return result;
- }
-
- public org.apache.drill.exec.proto.UserProtos.NodeStatus buildPartial() {
- org.apache.drill.exec.proto.UserProtos.NodeStatus result = new org.apache.drill.exec.proto.UserProtos.NodeStatus(this);
- int from_bitField0_ = bitField0_;
- int to_bitField0_ = 0;
- if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
- to_bitField0_ |= 0x00000001;
- }
- result.nodeId_ = nodeId_;
- if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
- to_bitField0_ |= 0x00000002;
- }
- result.memoryFootprint_ = memoryFootprint_;
- result.bitField0_ = to_bitField0_;
- onBuilt();
- return result;
- }
-
- public Builder mergeFrom(com.google.protobuf.Message other) {
- if (other instanceof org.apache.drill.exec.proto.UserProtos.NodeStatus) {
- return mergeFrom((org.apache.drill.exec.proto.UserProtos.NodeStatus)other);
- } else {
- super.mergeFrom(other);
- return this;
- }
- }
-
- public Builder mergeFrom(org.apache.drill.exec.proto.UserProtos.NodeStatus other) {
- if (other == org.apache.drill.exec.proto.UserProtos.NodeStatus.getDefaultInstance()) return this;
- if (other.hasNodeId()) {
- setNodeId(other.getNodeId());
- }
- if (other.hasMemoryFootprint()) {
- setMemoryFootprint(other.getMemoryFootprint());
- }
- this.mergeUnknownFields(other.getUnknownFields());
- return this;
- }
-
- public final boolean isInitialized() {
- return true;
- }
-
- public Builder mergeFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- org.apache.drill.exec.proto.UserProtos.NodeStatus parsedMessage = null;
- try {
- parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- parsedMessage = (org.apache.drill.exec.proto.UserProtos.NodeStatus) e.getUnfinishedMessage();
- throw e;
- } finally {
- if (parsedMessage != null) {
- mergeFrom(parsedMessage);
- }
- }
- return this;
- }
- private int bitField0_;
-
- // optional int32 node_id = 1;
- private int nodeId_ ;
- /**
- * <code>optional int32 node_id = 1;</code>
- */
- public boolean hasNodeId() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
- }
- /**
- * <code>optional int32 node_id = 1;</code>
- */
- public int getNodeId() {
- return nodeId_;
- }
- /**
- * <code>optional int32 node_id = 1;</code>
- */
- public Builder setNodeId(int value) {
- bitField0_ |= 0x00000001;
- nodeId_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>optional int32 node_id = 1;</code>
- */
- public Builder clearNodeId() {
- bitField0_ = (bitField0_ & ~0x00000001);
- nodeId_ = 0;
- onChanged();
- return this;
- }
-
- // optional int64 memory_footprint = 2;
- private long memoryFootprint_ ;
- /**
- * <code>optional int64 memory_footprint = 2;</code>
- */
- public boolean hasMemoryFootprint() {
- return ((bitField0_ & 0x00000002) == 0x00000002);
- }
- /**
- * <code>optional int64 memory_footprint = 2;</code>
- */
- public long getMemoryFootprint() {
- return memoryFootprint_;
- }
- /**
- * <code>optional int64 memory_footprint = 2;</code>
- */
- public Builder setMemoryFootprint(long value) {
- bitField0_ |= 0x00000002;
- memoryFootprint_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>optional int64 memory_footprint = 2;</code>
- */
- public Builder clearMemoryFootprint() {
- bitField0_ = (bitField0_ & ~0x00000002);
- memoryFootprint_ = 0L;
- onChanged();
- return this;
- }
-
- // @@protoc_insertion_point(builder_scope:exec.user.NodeStatus)
- }
-
- static {
- defaultInstance = new NodeStatus(true);
- defaultInstance.initFields();
- }
-
- // @@protoc_insertion_point(class_scope:exec.user.NodeStatus)
- }
-
- public interface QueryResultOrBuilder
- extends com.google.protobuf.MessageOrBuilder {
-
- // optional .exec.user.QueryResult.QueryState query_state = 1;
- /**
- * <code>optional .exec.user.QueryResult.QueryState query_state = 1;</code>
- */
- boolean hasQueryState();
- /**
- * <code>optional .exec.user.QueryResult.QueryState query_state = 1;</code>
- */
- org.apache.drill.exec.proto.UserProtos.QueryResult.QueryState getQueryState();
-
- // optional .exec.shared.QueryId query_id = 2;
- /**
- * <code>optional .exec.shared.QueryId query_id = 2;</code>
- */
- boolean hasQueryId();
- /**
- * <code>optional .exec.shared.QueryId query_id = 2;</code>
- */
- org.apache.drill.exec.proto.UserBitShared.QueryId getQueryId();
- /**
- * <code>optional .exec.shared.QueryId query_id = 2;</code>
- */
- org.apache.drill.exec.proto.UserBitShared.QueryIdOrBuilder getQueryIdOrBuilder();
-
- // optional bool is_last_chunk = 3;
- /**
- * <code>optional bool is_last_chunk = 3;</code>
- */
- boolean hasIsLastChunk();
- /**
- * <code>optional bool is_last_chunk = 3;</code>
- */
- boolean getIsLastChunk();
-
- // optional int32 row_count = 4;
- /**
- * <code>optional int32 row_count = 4;</code>
- */
- boolean hasRowCount();
- /**
- * <code>optional int32 row_count = 4;</code>
- */
- int getRowCount();
-
- // optional int64 records_scan = 5;
- /**
- * <code>optional int64 records_scan = 5;</code>
- */
- boolean hasRecordsScan();
- /**
- * <code>optional int64 records_scan = 5;</code>
- */
- long getRecordsScan();
-
- // optional int64 records_error = 6;
- /**
- * <code>optional int64 records_error = 6;</code>
- */
- boolean hasRecordsError();
- /**
- * <code>optional int64 records_error = 6;</code>
- */
- long getRecordsError();
-
- // optional int64 submission_time = 7;
- /**
- * <code>optional int64 submission_time = 7;</code>
- */
- boolean hasSubmissionTime();
- /**
- * <code>optional int64 submission_time = 7;</code>
- */
- long getSubmissionTime();
-
- // repeated .exec.user.NodeStatus node_status = 8;
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- java.util.List<org.apache.drill.exec.proto.UserProtos.NodeStatus>
- getNodeStatusList();
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- org.apache.drill.exec.proto.UserProtos.NodeStatus getNodeStatus(int index);
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- int getNodeStatusCount();
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- java.util.List<? extends org.apache.drill.exec.proto.UserProtos.NodeStatusOrBuilder>
- getNodeStatusOrBuilderList();
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- org.apache.drill.exec.proto.UserProtos.NodeStatusOrBuilder getNodeStatusOrBuilder(
- int index);
-
- // repeated .exec.shared.DrillPBError error = 9;
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- java.util.List<org.apache.drill.exec.proto.UserBitShared.DrillPBError>
- getErrorList();
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- org.apache.drill.exec.proto.UserBitShared.DrillPBError getError(int index);
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- int getErrorCount();
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- java.util.List<? extends org.apache.drill.exec.proto.UserBitShared.DrillPBErrorOrBuilder>
- getErrorOrBuilderList();
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- org.apache.drill.exec.proto.UserBitShared.DrillPBErrorOrBuilder getErrorOrBuilder(
- int index);
-
- // optional .exec.shared.RecordBatchDef def = 10;
- /**
- * <code>optional .exec.shared.RecordBatchDef def = 10;</code>
- */
- boolean hasDef();
- /**
- * <code>optional .exec.shared.RecordBatchDef def = 10;</code>
- */
- org.apache.drill.exec.proto.UserBitShared.RecordBatchDef getDef();
- /**
- * <code>optional .exec.shared.RecordBatchDef def = 10;</code>
- */
- org.apache.drill.exec.proto.UserBitShared.RecordBatchDefOrBuilder getDefOrBuilder();
-
- // optional bool schema_changed = 11;
- /**
- * <code>optional bool schema_changed = 11;</code>
- */
- boolean hasSchemaChanged();
- /**
- * <code>optional bool schema_changed = 11;</code>
- */
- boolean getSchemaChanged();
- }
- /**
- * Protobuf type {@code exec.user.QueryResult}
- */
- public static final class QueryResult extends
- com.google.protobuf.GeneratedMessage
- implements QueryResultOrBuilder {
- // Use QueryResult.newBuilder() to construct.
- private QueryResult(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
- super(builder);
- this.unknownFields = builder.getUnknownFields();
- }
- private QueryResult(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
-
- private static final QueryResult defaultInstance;
- public static QueryResult getDefaultInstance() {
- return defaultInstance;
- }
-
- public QueryResult getDefaultInstanceForType() {
- return defaultInstance;
- }
-
- private final com.google.protobuf.UnknownFieldSet unknownFields;
- @java.lang.Override
- public final com.google.protobuf.UnknownFieldSet
- getUnknownFields() {
- return this.unknownFields;
- }
- private QueryResult(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- initFields();
- int mutable_bitField0_ = 0;
- com.google.protobuf.UnknownFieldSet.Builder unknownFields =
- com.google.protobuf.UnknownFieldSet.newBuilder();
- try {
- boolean done = false;
- while (!done) {
- int tag = input.readTag();
- switch (tag) {
- case 0:
- done = true;
- break;
- default: {
- if (!parseUnknownField(input, unknownFields,
- extensionRegistry, tag)) {
- done = true;
- }
- break;
- }
- case 8: {
- int rawValue = input.readEnum();
- org.apache.drill.exec.proto.UserProtos.QueryResult.QueryState value = org.apache.drill.exec.proto.UserProtos.QueryResult.QueryState.valueOf(rawValue);
- if (value == null) {
- unknownFields.mergeVarintField(1, rawValue);
- } else {
- bitField0_ |= 0x00000001;
- queryState_ = value;
- }
- break;
- }
- case 18: {
- org.apache.drill.exec.proto.UserBitShared.QueryId.Builder subBuilder = null;
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
- subBuilder = queryId_.toBuilder();
- }
- queryId_ = input.readMessage(org.apache.drill.exec.proto.UserBitShared.QueryId.PARSER, extensionRegistry);
- if (subBuilder != null) {
- subBuilder.mergeFrom(queryId_);
- queryId_ = subBuilder.buildPartial();
- }
- bitField0_ |= 0x00000002;
- break;
- }
- case 24: {
- bitField0_ |= 0x00000004;
- isLastChunk_ = input.readBool();
- break;
- }
- case 32: {
- bitField0_ |= 0x00000008;
- rowCount_ = input.readInt32();
- break;
- }
- case 40: {
- bitField0_ |= 0x00000010;
- recordsScan_ = input.readInt64();
- break;
- }
- case 48: {
- bitField0_ |= 0x00000020;
- recordsError_ = input.readInt64();
- break;
- }
- case 56: {
- bitField0_ |= 0x00000040;
- submissionTime_ = input.readInt64();
- break;
- }
- case 66: {
- if (!((mutable_bitField0_ & 0x00000080) == 0x00000080)) {
- nodeStatus_ = new java.util.ArrayList<org.apache.drill.exec.proto.UserProtos.NodeStatus>();
- mutable_bitField0_ |= 0x00000080;
- }
- nodeStatus_.add(input.readMessage(org.apache.drill.exec.proto.UserProtos.NodeStatus.PARSER, extensionRegistry));
- break;
- }
- case 74: {
- if (!((mutable_bitField0_ & 0x00000100) == 0x00000100)) {
- error_ = new java.util.ArrayList<org.apache.drill.exec.proto.UserBitShared.DrillPBError>();
- mutable_bitField0_ |= 0x00000100;
- }
- error_.add(input.readMessage(org.apache.drill.exec.proto.UserBitShared.DrillPBError.PARSER, extensionRegistry));
- break;
- }
- case 82: {
- org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.Builder subBuilder = null;
- if (((bitField0_ & 0x00000080) == 0x00000080)) {
- subBuilder = def_.toBuilder();
- }
- def_ = input.readMessage(org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.PARSER, extensionRegistry);
- if (subBuilder != null) {
- subBuilder.mergeFrom(def_);
- def_ = subBuilder.buildPartial();
- }
- bitField0_ |= 0x00000080;
- break;
- }
- case 88: {
- bitField0_ |= 0x00000100;
- schemaChanged_ = input.readBool();
- break;
- }
- }
- }
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- throw e.setUnfinishedMessage(this);
- } catch (java.io.IOException e) {
- throw new com.google.protobuf.InvalidProtocolBufferException(
- e.getMessage()).setUnfinishedMessage(this);
- } finally {
- if (((mutable_bitField0_ & 0x00000080) == 0x00000080)) {
- nodeStatus_ = java.util.Collections.unmodifiableList(nodeStatus_);
- }
- if (((mutable_bitField0_ & 0x00000100) == 0x00000100)) {
- error_ = java.util.Collections.unmodifiableList(error_);
- }
- this.unknownFields = unknownFields.build();
- makeExtensionsImmutable();
- }
- }
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return org.apache.drill.exec.proto.UserProtos.internal_static_exec_user_QueryResult_descriptor;
- }
-
- protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return org.apache.drill.exec.proto.UserProtos.internal_static_exec_user_QueryResult_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- org.apache.drill.exec.proto.UserProtos.QueryResult.class, org.apache.drill.exec.proto.UserProtos.QueryResult.Builder.class);
- }
-
- public static com.google.protobuf.Parser<QueryResult> PARSER =
- new com.google.protobuf.AbstractParser<QueryResult>() {
- public QueryResult parsePartialFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return new QueryResult(input, extensionRegistry);
- }
- };
-
- @java.lang.Override
- public com.google.protobuf.Parser<QueryResult> getParserForType() {
- return PARSER;
- }
-
- /**
- * Protobuf enum {@code exec.user.QueryResult.QueryState}
- */
- public enum QueryState
- implements com.google.protobuf.ProtocolMessageEnum {
- /**
- * <code>PENDING = 0;</code>
- */
- PENDING(0, 0),
- /**
- * <code>RUNNING = 1;</code>
- */
- RUNNING(1, 1),
- /**
- * <code>COMPLETED = 2;</code>
- */
- COMPLETED(2, 2),
- /**
- * <code>CANCELED = 3;</code>
- */
- CANCELED(3, 3),
- /**
- * <code>FAILED = 4;</code>
- */
- FAILED(4, 4),
- /**
- * <code>UNKNOWN_QUERY = 5;</code>
- */
- UNKNOWN_QUERY(5, 5),
- ;
-
- /**
- * <code>PENDING = 0;</code>
- */
- public static final int PENDING_VALUE = 0;
- /**
- * <code>RUNNING = 1;</code>
- */
- public static final int RUNNING_VALUE = 1;
- /**
- * <code>COMPLETED = 2;</code>
- */
- public static final int COMPLETED_VALUE = 2;
- /**
- * <code>CANCELED = 3;</code>
- */
- public static final int CANCELED_VALUE = 3;
- /**
- * <code>FAILED = 4;</code>
- */
- public static final int FAILED_VALUE = 4;
- /**
- * <code>UNKNOWN_QUERY = 5;</code>
- */
- public static final int UNKNOWN_QUERY_VALUE = 5;
-
-
- public final int getNumber() { return value; }
-
- public static QueryState valueOf(int value) {
- switch (value) {
- case 0: return PENDING;
- case 1: return RUNNING;
- case 2: return COMPLETED;
- case 3: return CANCELED;
- case 4: return FAILED;
- case 5: return UNKNOWN_QUERY;
- default: return null;
- }
- }
-
- public static com.google.protobuf.Internal.EnumLiteMap<QueryState>
- internalGetValueMap() {
- return internalValueMap;
- }
- private static com.google.protobuf.Internal.EnumLiteMap<QueryState>
- internalValueMap =
- new com.google.protobuf.Internal.EnumLiteMap<QueryState>() {
- public QueryState findValueByNumber(int number) {
- return QueryState.valueOf(number);
- }
- };
-
- public final com.google.protobuf.Descriptors.EnumValueDescriptor
- getValueDescriptor() {
- return getDescriptor().getValues().get(index);
- }
- public final com.google.protobuf.Descriptors.EnumDescriptor
- getDescriptorForType() {
- return getDescriptor();
- }
- public static final com.google.protobuf.Descriptors.EnumDescriptor
- getDescriptor() {
- return org.apache.drill.exec.proto.UserProtos.QueryResult.getDescriptor().getEnumTypes().get(0);
- }
-
- private static final QueryState[] VALUES = values();
-
- public static QueryState valueOf(
- com.google.protobuf.Descriptors.EnumValueDescriptor desc) {
- if (desc.getType() != getDescriptor()) {
- throw new java.lang.IllegalArgumentException(
- "EnumValueDescriptor is not for this type.");
- }
- return VALUES[desc.getIndex()];
- }
-
- private final int index;
- private final int value;
-
- private QueryState(int index, int value) {
- this.index = index;
- this.value = value;
- }
-
- // @@protoc_insertion_point(enum_scope:exec.user.QueryResult.QueryState)
- }
-
- private int bitField0_;
- // optional .exec.user.QueryResult.QueryState query_state = 1;
- public static final int QUERY_STATE_FIELD_NUMBER = 1;
- private org.apache.drill.exec.proto.UserProtos.QueryResult.QueryState queryState_;
- /**
- * <code>optional .exec.user.QueryResult.QueryState query_state = 1;</code>
- */
- public boolean hasQueryState() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
- }
- /**
- * <code>optional .exec.user.QueryResult.QueryState query_state = 1;</code>
- */
- public org.apache.drill.exec.proto.UserProtos.QueryResult.QueryState getQueryState() {
- return queryState_;
- }
-
- // optional .exec.shared.QueryId query_id = 2;
- public static final int QUERY_ID_FIELD_NUMBER = 2;
- private org.apache.drill.exec.proto.UserBitShared.QueryId queryId_;
- /**
- * <code>optional .exec.shared.QueryId query_id = 2;</code>
- */
- public boolean hasQueryId() {
- return ((bitField0_ & 0x00000002) == 0x00000002);
- }
- /**
- * <code>optional .exec.shared.QueryId query_id = 2;</code>
- */
- public org.apache.drill.exec.proto.UserBitShared.QueryId getQueryId() {
- return queryId_;
- }
- /**
- * <code>optional .exec.shared.QueryId query_id = 2;</code>
- */
- public org.apache.drill.exec.proto.UserBitShared.QueryIdOrBuilder getQueryIdOrBuilder() {
- return queryId_;
- }
-
- // optional bool is_last_chunk = 3;
- public static final int IS_LAST_CHUNK_FIELD_NUMBER = 3;
- private boolean isLastChunk_;
- /**
- * <code>optional bool is_last_chunk = 3;</code>
- */
- public boolean hasIsLastChunk() {
- return ((bitField0_ & 0x00000004) == 0x00000004);
- }
- /**
- * <code>optional bool is_last_chunk = 3;</code>
- */
- public boolean getIsLastChunk() {
- return isLastChunk_;
- }
-
- // optional int32 row_count = 4;
- public static final int ROW_COUNT_FIELD_NUMBER = 4;
- private int rowCount_;
- /**
- * <code>optional int32 row_count = 4;</code>
- */
- public boolean hasRowCount() {
- return ((bitField0_ & 0x00000008) == 0x00000008);
- }
- /**
- * <code>optional int32 row_count = 4;</code>
- */
- public int getRowCount() {
- return rowCount_;
- }
-
- // optional int64 records_scan = 5;
- public static final int RECORDS_SCAN_FIELD_NUMBER = 5;
- private long recordsScan_;
- /**
- * <code>optional int64 records_scan = 5;</code>
- */
- public boolean hasRecordsScan() {
- return ((bitField0_ & 0x00000010) == 0x00000010);
- }
- /**
- * <code>optional int64 records_scan = 5;</code>
- */
- public long getRecordsScan() {
- return recordsScan_;
- }
-
- // optional int64 records_error = 6;
- public static final int RECORDS_ERROR_FIELD_NUMBER = 6;
- private long recordsError_;
- /**
- * <code>optional int64 records_error = 6;</code>
- */
- public boolean hasRecordsError() {
- return ((bitField0_ & 0x00000020) == 0x00000020);
- }
- /**
- * <code>optional int64 records_error = 6;</code>
- */
- public long getRecordsError() {
- return recordsError_;
- }
-
- // optional int64 submission_time = 7;
- public static final int SUBMISSION_TIME_FIELD_NUMBER = 7;
- private long submissionTime_;
- /**
- * <code>optional int64 submission_time = 7;</code>
- */
- public boolean hasSubmissionTime() {
- return ((bitField0_ & 0x00000040) == 0x00000040);
- }
- /**
- * <code>optional int64 submission_time = 7;</code>
- */
- public long getSubmissionTime() {
- return submissionTime_;
- }
-
- // repeated .exec.user.NodeStatus node_status = 8;
- public static final int NODE_STATUS_FIELD_NUMBER = 8;
- private java.util.List<org.apache.drill.exec.proto.UserProtos.NodeStatus> nodeStatus_;
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public java.util.List<org.apache.drill.exec.proto.UserProtos.NodeStatus> getNodeStatusList() {
- return nodeStatus_;
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public java.util.List<? extends org.apache.drill.exec.proto.UserProtos.NodeStatusOrBuilder>
- getNodeStatusOrBuilderList() {
- return nodeStatus_;
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public int getNodeStatusCount() {
- return nodeStatus_.size();
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public org.apache.drill.exec.proto.UserProtos.NodeStatus getNodeStatus(int index) {
- return nodeStatus_.get(index);
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public org.apache.drill.exec.proto.UserProtos.NodeStatusOrBuilder getNodeStatusOrBuilder(
- int index) {
- return nodeStatus_.get(index);
- }
-
- // repeated .exec.shared.DrillPBError error = 9;
- public static final int ERROR_FIELD_NUMBER = 9;
- private java.util.List<org.apache.drill.exec.proto.UserBitShared.DrillPBError> error_;
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public java.util.List<org.apache.drill.exec.proto.UserBitShared.DrillPBError> getErrorList() {
- return error_;
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public java.util.List<? extends org.apache.drill.exec.proto.UserBitShared.DrillPBErrorOrBuilder>
- getErrorOrBuilderList() {
- return error_;
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public int getErrorCount() {
- return error_.size();
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public org.apache.drill.exec.proto.UserBitShared.DrillPBError getError(int index) {
- return error_.get(index);
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public org.apache.drill.exec.proto.UserBitShared.DrillPBErrorOrBuilder getErrorOrBuilder(
- int index) {
- return error_.get(index);
- }
-
- // optional .exec.shared.RecordBatchDef def = 10;
- public static final int DEF_FIELD_NUMBER = 10;
- private org.apache.drill.exec.proto.UserBitShared.RecordBatchDef def_;
- /**
- * <code>optional .exec.shared.RecordBatchDef def = 10;</code>
- */
- public boolean hasDef() {
- return ((bitField0_ & 0x00000080) == 0x00000080);
- }
- /**
- * <code>optional .exec.shared.RecordBatchDef def = 10;</code>
- */
- public org.apache.drill.exec.proto.UserBitShared.RecordBatchDef getDef() {
- return def_;
- }
- /**
- * <code>optional .exec.shared.RecordBatchDef def = 10;</code>
- */
- public org.apache.drill.exec.proto.UserBitShared.RecordBatchDefOrBuilder getDefOrBuilder() {
- return def_;
- }
-
- // optional bool schema_changed = 11;
- public static final int SCHEMA_CHANGED_FIELD_NUMBER = 11;
- private boolean schemaChanged_;
- /**
- * <code>optional bool schema_changed = 11;</code>
- */
- public boolean hasSchemaChanged() {
- return ((bitField0_ & 0x00000100) == 0x00000100);
- }
- /**
- * <code>optional bool schema_changed = 11;</code>
- */
- public boolean getSchemaChanged() {
- return schemaChanged_;
- }
-
- private void initFields() {
- queryState_ = org.apache.drill.exec.proto.UserProtos.QueryResult.QueryState.PENDING;
- queryId_ = org.apache.drill.exec.proto.UserBitShared.QueryId.getDefaultInstance();
- isLastChunk_ = false;
- rowCount_ = 0;
- recordsScan_ = 0L;
- recordsError_ = 0L;
- submissionTime_ = 0L;
- nodeStatus_ = java.util.Collections.emptyList();
- error_ = java.util.Collections.emptyList();
- def_ = org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.getDefaultInstance();
- schemaChanged_ = false;
- }
- private byte memoizedIsInitialized = -1;
- public final boolean isInitialized() {
- byte isInitialized = memoizedIsInitialized;
- if (isInitialized != -1) return isInitialized == 1;
-
- memoizedIsInitialized = 1;
- return true;
- }
-
- public void writeTo(com.google.protobuf.CodedOutputStream output)
- throws java.io.IOException {
- getSerializedSize();
- if (((bitField0_ & 0x00000001) == 0x00000001)) {
- output.writeEnum(1, queryState_.getNumber());
- }
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
- output.writeMessage(2, queryId_);
- }
- if (((bitField0_ & 0x00000004) == 0x00000004)) {
- output.writeBool(3, isLastChunk_);
- }
- if (((bitField0_ & 0x00000008) == 0x00000008)) {
- output.writeInt32(4, rowCount_);
- }
- if (((bitField0_ & 0x00000010) == 0x00000010)) {
- output.writeInt64(5, recordsScan_);
- }
- if (((bitField0_ & 0x00000020) == 0x00000020)) {
- output.writeInt64(6, recordsError_);
- }
- if (((bitField0_ & 0x00000040) == 0x00000040)) {
- output.writeInt64(7, submissionTime_);
- }
- for (int i = 0; i < nodeStatus_.size(); i++) {
- output.writeMessage(8, nodeStatus_.get(i));
- }
- for (int i = 0; i < error_.size(); i++) {
- output.writeMessage(9, error_.get(i));
- }
- if (((bitField0_ & 0x00000080) == 0x00000080)) {
- output.writeMessage(10, def_);
- }
- if (((bitField0_ & 0x00000100) == 0x00000100)) {
- output.writeBool(11, schemaChanged_);
- }
- getUnknownFields().writeTo(output);
- }
-
- private int memoizedSerializedSize = -1;
- public int getSerializedSize() {
- int size = memoizedSerializedSize;
- if (size != -1) return size;
-
- size = 0;
- if (((bitField0_ & 0x00000001) == 0x00000001)) {
- size += com.google.protobuf.CodedOutputStream
- .computeEnumSize(1, queryState_.getNumber());
- }
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
- size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(2, queryId_);
- }
- if (((bitField0_ & 0x00000004) == 0x00000004)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBoolSize(3, isLastChunk_);
- }
- if (((bitField0_ & 0x00000008) == 0x00000008)) {
- size += com.google.protobuf.CodedOutputStream
- .computeInt32Size(4, rowCount_);
- }
- if (((bitField0_ & 0x00000010) == 0x00000010)) {
- size += com.google.protobuf.CodedOutputStream
- .computeInt64Size(5, recordsScan_);
- }
- if (((bitField0_ & 0x00000020) == 0x00000020)) {
- size += com.google.protobuf.CodedOutputStream
- .computeInt64Size(6, recordsError_);
- }
- if (((bitField0_ & 0x00000040) == 0x00000040)) {
- size += com.google.protobuf.CodedOutputStream
- .computeInt64Size(7, submissionTime_);
- }
- for (int i = 0; i < nodeStatus_.size(); i++) {
- size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(8, nodeStatus_.get(i));
- }
- for (int i = 0; i < error_.size(); i++) {
- size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(9, error_.get(i));
- }
- if (((bitField0_ & 0x00000080) == 0x00000080)) {
- size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(10, def_);
- }
- if (((bitField0_ & 0x00000100) == 0x00000100)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBoolSize(11, schemaChanged_);
- }
- size += getUnknownFields().getSerializedSize();
- memoizedSerializedSize = size;
- return size;
- }
-
- private static final long serialVersionUID = 0L;
- @java.lang.Override
- protected java.lang.Object writeReplace()
- throws java.io.ObjectStreamException {
- return super.writeReplace();
- }
-
- public static org.apache.drill.exec.proto.UserProtos.QueryResult parseFrom(
- com.google.protobuf.ByteString data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static org.apache.drill.exec.proto.UserProtos.QueryResult parseFrom(
- com.google.protobuf.ByteString data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static org.apache.drill.exec.proto.UserProtos.QueryResult parseFrom(byte[] data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static org.apache.drill.exec.proto.UserProtos.QueryResult parseFrom(
- byte[] data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static org.apache.drill.exec.proto.UserProtos.QueryResult parseFrom(java.io.InputStream input)
- throws java.io.IOException {
- return PARSER.parseFrom(input);
- }
- public static org.apache.drill.exec.proto.UserProtos.QueryResult parseFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseFrom(input, extensionRegistry);
- }
- public static org.apache.drill.exec.proto.UserProtos.QueryResult parseDelimitedFrom(java.io.InputStream input)
- throws java.io.IOException {
- return PARSER.parseDelimitedFrom(input);
- }
- public static org.apache.drill.exec.proto.UserProtos.QueryResult parseDelimitedFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseDelimitedFrom(input, extensionRegistry);
- }
- public static org.apache.drill.exec.proto.UserProtos.QueryResult parseFrom(
- com.google.protobuf.CodedInputStream input)
- throws java.io.IOException {
- return PARSER.parseFrom(input);
- }
- public static org.apache.drill.exec.proto.UserProtos.QueryResult parseFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseFrom(input, extensionRegistry);
- }
-
- public static Builder newBuilder() { return Builder.create(); }
- public Builder newBuilderForType() { return newBuilder(); }
- public static Builder newBuilder(org.apache.drill.exec.proto.UserProtos.QueryResult prototype) {
- return newBuilder().mergeFrom(prototype);
- }
- public Builder toBuilder() { return newBuilder(this); }
-
- @java.lang.Override
- protected Builder newBuilderForType(
- com.google.protobuf.GeneratedMessage.BuilderParent parent) {
- Builder builder = new Builder(parent);
- return builder;
- }
- /**
- * Protobuf type {@code exec.user.QueryResult}
- */
- public static final class Builder extends
- com.google.protobuf.GeneratedMessage.Builder<Builder>
- implements org.apache.drill.exec.proto.UserProtos.QueryResultOrBuilder {
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return org.apache.drill.exec.proto.UserProtos.internal_static_exec_user_QueryResult_descriptor;
- }
-
- protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return org.apache.drill.exec.proto.UserProtos.internal_static_exec_user_QueryResult_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- org.apache.drill.exec.proto.UserProtos.QueryResult.class, org.apache.drill.exec.proto.UserProtos.QueryResult.Builder.class);
- }
-
- // Construct using org.apache.drill.exec.proto.UserProtos.QueryResult.newBuilder()
- private Builder() {
- maybeForceBuilderInitialization();
- }
-
- private Builder(
- com.google.protobuf.GeneratedMessage.BuilderParent parent) {
- super(parent);
- maybeForceBuilderInitialization();
- }
- private void maybeForceBuilderInitialization() {
- if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
- getQueryIdFieldBuilder();
- getNodeStatusFieldBuilder();
- getErrorFieldBuilder();
- getDefFieldBuilder();
- }
- }
- private static Builder create() {
- return new Builder();
- }
-
- public Builder clear() {
- super.clear();
- queryState_ = org.apache.drill.exec.proto.UserProtos.QueryResult.QueryState.PENDING;
- bitField0_ = (bitField0_ & ~0x00000001);
- if (queryIdBuilder_ == null) {
- queryId_ = org.apache.drill.exec.proto.UserBitShared.QueryId.getDefaultInstance();
- } else {
- queryIdBuilder_.clear();
- }
- bitField0_ = (bitField0_ & ~0x00000002);
- isLastChunk_ = false;
- bitField0_ = (bitField0_ & ~0x00000004);
- rowCount_ = 0;
- bitField0_ = (bitField0_ & ~0x00000008);
- recordsScan_ = 0L;
- bitField0_ = (bitField0_ & ~0x00000010);
- recordsError_ = 0L;
- bitField0_ = (bitField0_ & ~0x00000020);
- submissionTime_ = 0L;
- bitField0_ = (bitField0_ & ~0x00000040);
- if (nodeStatusBuilder_ == null) {
- nodeStatus_ = java.util.Collections.emptyList();
- bitField0_ = (bitField0_ & ~0x00000080);
- } else {
- nodeStatusBuilder_.clear();
- }
- if (errorBuilder_ == null) {
- error_ = java.util.Collections.emptyList();
- bitField0_ = (bitField0_ & ~0x00000100);
- } else {
- errorBuilder_.clear();
- }
- if (defBuilder_ == null) {
- def_ = org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.getDefaultInstance();
- } else {
- defBuilder_.clear();
- }
- bitField0_ = (bitField0_ & ~0x00000200);
- schemaChanged_ = false;
- bitField0_ = (bitField0_ & ~0x00000400);
- return this;
- }
-
- public Builder clone() {
- return create().mergeFrom(buildPartial());
- }
-
- public com.google.protobuf.Descriptors.Descriptor
- getDescriptorForType() {
- return org.apache.drill.exec.proto.UserProtos.internal_static_exec_user_QueryResult_descriptor;
- }
-
- public org.apache.drill.exec.proto.UserProtos.QueryResult getDefaultInstanceForType() {
- return org.apache.drill.exec.proto.UserProtos.QueryResult.getDefaultInstance();
- }
-
- public org.apache.drill.exec.proto.UserProtos.QueryResult build() {
- org.apache.drill.exec.proto.UserProtos.QueryResult result = buildPartial();
- if (!result.isInitialized()) {
- throw newUninitializedMessageException(result);
- }
- return result;
- }
-
- public org.apache.drill.exec.proto.UserProtos.QueryResult buildPartial() {
- org.apache.drill.exec.proto.UserProtos.QueryResult result = new org.apache.drill.exec.proto.UserProtos.QueryResult(this);
- int from_bitField0_ = bitField0_;
- int to_bitField0_ = 0;
- if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
- to_bitField0_ |= 0x00000001;
- }
- result.queryState_ = queryState_;
- if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
- to_bitField0_ |= 0x00000002;
- }
- if (queryIdBuilder_ == null) {
- result.queryId_ = queryId_;
- } else {
- result.queryId_ = queryIdBuilder_.build();
- }
- if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
- to_bitField0_ |= 0x00000004;
- }
- result.isLastChunk_ = isLastChunk_;
- if (((from_bitField0_ & 0x00000008) == 0x00000008)) {
- to_bitField0_ |= 0x00000008;
- }
- result.rowCount_ = rowCount_;
- if (((from_bitField0_ & 0x00000010) == 0x00000010)) {
- to_bitField0_ |= 0x00000010;
- }
- result.recordsScan_ = recordsScan_;
- if (((from_bitField0_ & 0x00000020) == 0x00000020)) {
- to_bitField0_ |= 0x00000020;
- }
- result.recordsError_ = recordsError_;
- if (((from_bitField0_ & 0x00000040) == 0x00000040)) {
- to_bitField0_ |= 0x00000040;
- }
- result.submissionTime_ = submissionTime_;
- if (nodeStatusBuilder_ == null) {
- if (((bitField0_ & 0x00000080) == 0x00000080)) {
- nodeStatus_ = java.util.Collections.unmodifiableList(nodeStatus_);
- bitField0_ = (bitField0_ & ~0x00000080);
- }
- result.nodeStatus_ = nodeStatus_;
- } else {
- result.nodeStatus_ = nodeStatusBuilder_.build();
- }
- if (errorBuilder_ == null) {
- if (((bitField0_ & 0x00000100) == 0x00000100)) {
- error_ = java.util.Collections.unmodifiableList(error_);
- bitField0_ = (bitField0_ & ~0x00000100);
- }
- result.error_ = error_;
- } else {
- result.error_ = errorBuilder_.build();
- }
- if (((from_bitField0_ & 0x00000200) == 0x00000200)) {
- to_bitField0_ |= 0x00000080;
- }
- if (defBuilder_ == null) {
- result.def_ = def_;
- } else {
- result.def_ = defBuilder_.build();
- }
- if (((from_bitField0_ & 0x00000400) == 0x00000400)) {
- to_bitField0_ |= 0x00000100;
- }
- result.schemaChanged_ = schemaChanged_;
- result.bitField0_ = to_bitField0_;
- onBuilt();
- return result;
- }
-
- public Builder mergeFrom(com.google.protobuf.Message other) {
- if (other instanceof org.apache.drill.exec.proto.UserProtos.QueryResult) {
- return mergeFrom((org.apache.drill.exec.proto.UserProtos.QueryResult)other);
- } else {
- super.mergeFrom(other);
- return this;
- }
- }
-
- public Builder mergeFrom(org.apache.drill.exec.proto.UserProtos.QueryResult other) {
- if (other == org.apache.drill.exec.proto.UserProtos.QueryResult.getDefaultInstance()) return this;
- if (other.hasQueryState()) {
- setQueryState(other.getQueryState());
- }
- if (other.hasQueryId()) {
- mergeQueryId(other.getQueryId());
- }
- if (other.hasIsLastChunk()) {
- setIsLastChunk(other.getIsLastChunk());
- }
- if (other.hasRowCount()) {
- setRowCount(other.getRowCount());
- }
- if (other.hasRecordsScan()) {
- setRecordsScan(other.getRecordsScan());
- }
- if (other.hasRecordsError()) {
- setRecordsError(other.getRecordsError());
- }
- if (other.hasSubmissionTime()) {
- setSubmissionTime(other.getSubmissionTime());
- }
- if (nodeStatusBuilder_ == null) {
- if (!other.nodeStatus_.isEmpty()) {
- if (nodeStatus_.isEmpty()) {
- nodeStatus_ = other.nodeStatus_;
- bitField0_ = (bitField0_ & ~0x00000080);
- } else {
- ensureNodeStatusIsMutable();
- nodeStatus_.addAll(other.nodeStatus_);
- }
- onChanged();
- }
- } else {
- if (!other.nodeStatus_.isEmpty()) {
- if (nodeStatusBuilder_.isEmpty()) {
- nodeStatusBuilder_.dispose();
- nodeStatusBuilder_ = null;
- nodeStatus_ = other.nodeStatus_;
- bitField0_ = (bitField0_ & ~0x00000080);
- nodeStatusBuilder_ =
- com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders ?
- getNodeStatusFieldBuilder() : null;
- } else {
- nodeStatusBuilder_.addAllMessages(other.nodeStatus_);
- }
- }
- }
- if (errorBuilder_ == null) {
- if (!other.error_.isEmpty()) {
- if (error_.isEmpty()) {
- error_ = other.error_;
- bitField0_ = (bitField0_ & ~0x00000100);
- } else {
- ensureErrorIsMutable();
- error_.addAll(other.error_);
- }
- onChanged();
- }
- } else {
- if (!other.error_.isEmpty()) {
- if (errorBuilder_.isEmpty()) {
- errorBuilder_.dispose();
- errorBuilder_ = null;
- error_ = other.error_;
- bitField0_ = (bitField0_ & ~0x00000100);
- errorBuilder_ =
- com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders ?
- getErrorFieldBuilder() : null;
- } else {
- errorBuilder_.addAllMessages(other.error_);
- }
- }
- }
- if (other.hasDef()) {
- mergeDef(other.getDef());
- }
- if (other.hasSchemaChanged()) {
- setSchemaChanged(other.getSchemaChanged());
- }
- this.mergeUnknownFields(other.getUnknownFields());
- return this;
- }
-
- public final boolean isInitialized() {
- return true;
- }
-
- public Builder mergeFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- org.apache.drill.exec.proto.UserProtos.QueryResult parsedMessage = null;
- try {
- parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- parsedMessage = (org.apache.drill.exec.proto.UserProtos.QueryResult) e.getUnfinishedMessage();
- throw e;
- } finally {
- if (parsedMessage != null) {
- mergeFrom(parsedMessage);
- }
- }
- return this;
- }
- private int bitField0_;
-
- // optional .exec.user.QueryResult.QueryState query_state = 1;
- private org.apache.drill.exec.proto.UserProtos.QueryResult.QueryState queryState_ = org.apache.drill.exec.proto.UserProtos.QueryResult.QueryState.PENDING;
- /**
- * <code>optional .exec.user.QueryResult.QueryState query_state = 1;</code>
- */
- public boolean hasQueryState() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
- }
- /**
- * <code>optional .exec.user.QueryResult.QueryState query_state = 1;</code>
- */
- public org.apache.drill.exec.proto.UserProtos.QueryResult.QueryState getQueryState() {
- return queryState_;
- }
- /**
- * <code>optional .exec.user.QueryResult.QueryState query_state = 1;</code>
- */
- public Builder setQueryState(org.apache.drill.exec.proto.UserProtos.QueryResult.QueryState value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000001;
- queryState_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>optional .exec.user.QueryResult.QueryState query_state = 1;</code>
- */
- public Builder clearQueryState() {
- bitField0_ = (bitField0_ & ~0x00000001);
- queryState_ = org.apache.drill.exec.proto.UserProtos.QueryResult.QueryState.PENDING;
- onChanged();
- return this;
- }
-
- // optional .exec.shared.QueryId query_id = 2;
- private org.apache.drill.exec.proto.UserBitShared.QueryId queryId_ = org.apache.drill.exec.proto.UserBitShared.QueryId.getDefaultInstance();
- private com.google.protobuf.SingleFieldBuilder<
- org.apache.drill.exec.proto.UserBitShared.QueryId, org.apache.drill.exec.proto.UserBitShared.QueryId.Builder, org.apache.drill.exec.proto.UserBitShared.QueryIdOrBuilder> queryIdBuilder_;
- /**
- * <code>optional .exec.shared.QueryId query_id = 2;</code>
- */
- public boolean hasQueryId() {
- return ((bitField0_ & 0x00000002) == 0x00000002);
- }
- /**
- * <code>optional .exec.shared.QueryId query_id = 2;</code>
- */
- public org.apache.drill.exec.proto.UserBitShared.QueryId getQueryId() {
- if (queryIdBuilder_ == null) {
- return queryId_;
- } else {
- return queryIdBuilder_.getMessage();
- }
- }
- /**
- * <code>optional .exec.shared.QueryId query_id = 2;</code>
- */
- public Builder setQueryId(org.apache.drill.exec.proto.UserBitShared.QueryId value) {
- if (queryIdBuilder_ == null) {
- if (value == null) {
- throw new NullPointerException();
- }
- queryId_ = value;
- onChanged();
- } else {
- queryIdBuilder_.setMessage(value);
- }
- bitField0_ |= 0x00000002;
- return this;
- }
- /**
- * <code>optional .exec.shared.QueryId query_id = 2;</code>
- */
- public Builder setQueryId(
- org.apache.drill.exec.proto.UserBitShared.QueryId.Builder builderForValue) {
- if (queryIdBuilder_ == null) {
- queryId_ = builderForValue.build();
- onChanged();
- } else {
- queryIdBuilder_.setMessage(builderForValue.build());
- }
- bitField0_ |= 0x00000002;
- return this;
- }
- /**
- * <code>optional .exec.shared.QueryId query_id = 2;</code>
- */
- public Builder mergeQueryId(org.apache.drill.exec.proto.UserBitShared.QueryId value) {
- if (queryIdBuilder_ == null) {
- if (((bitField0_ & 0x00000002) == 0x00000002) &&
- queryId_ != org.apache.drill.exec.proto.UserBitShared.QueryId.getDefaultInstance()) {
- queryId_ =
- org.apache.drill.exec.proto.UserBitShared.QueryId.newBuilder(queryId_).mergeFrom(value).buildPartial();
- } else {
- queryId_ = value;
- }
- onChanged();
- } else {
- queryIdBuilder_.mergeFrom(value);
- }
- bitField0_ |= 0x00000002;
- return this;
- }
- /**
- * <code>optional .exec.shared.QueryId query_id = 2;</code>
- */
- public Builder clearQueryId() {
- if (queryIdBuilder_ == null) {
- queryId_ = org.apache.drill.exec.proto.UserBitShared.QueryId.getDefaultInstance();
- onChanged();
- } else {
- queryIdBuilder_.clear();
- }
- bitField0_ = (bitField0_ & ~0x00000002);
- return this;
- }
- /**
- * <code>optional .exec.shared.QueryId query_id = 2;</code>
- */
- public org.apache.drill.exec.proto.UserBitShared.QueryId.Builder getQueryIdBuilder() {
- bitField0_ |= 0x00000002;
- onChanged();
- return getQueryIdFieldBuilder().getBuilder();
- }
- /**
- * <code>optional .exec.shared.QueryId query_id = 2;</code>
- */
- public org.apache.drill.exec.proto.UserBitShared.QueryIdOrBuilder getQueryIdOrBuilder() {
- if (queryIdBuilder_ != null) {
- return queryIdBuilder_.getMessageOrBuilder();
- } else {
- return queryId_;
- }
- }
- /**
- * <code>optional .exec.shared.QueryId query_id = 2;</code>
- */
- private com.google.protobuf.SingleFieldBuilder<
- org.apache.drill.exec.proto.UserBitShared.QueryId, org.apache.drill.exec.proto.UserBitShared.QueryId.Builder, org.apache.drill.exec.proto.UserBitShared.QueryIdOrBuilder>
- getQueryIdFieldBuilder() {
- if (queryIdBuilder_ == null) {
- queryIdBuilder_ = new com.google.protobuf.SingleFieldBuilder<
- org.apache.drill.exec.proto.UserBitShared.QueryId, org.apache.drill.exec.proto.UserBitShared.QueryId.Builder, org.apache.drill.exec.proto.UserBitShared.QueryIdOrBuilder>(
- queryId_,
- getParentForChildren(),
- isClean());
- queryId_ = null;
- }
- return queryIdBuilder_;
- }
-
- // optional bool is_last_chunk = 3;
- private boolean isLastChunk_ ;
- /**
- * <code>optional bool is_last_chunk = 3;</code>
- */
- public boolean hasIsLastChunk() {
- return ((bitField0_ & 0x00000004) == 0x00000004);
- }
- /**
- * <code>optional bool is_last_chunk = 3;</code>
- */
- public boolean getIsLastChunk() {
- return isLastChunk_;
- }
- /**
- * <code>optional bool is_last_chunk = 3;</code>
- */
- public Builder setIsLastChunk(boolean value) {
- bitField0_ |= 0x00000004;
- isLastChunk_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>optional bool is_last_chunk = 3;</code>
- */
- public Builder clearIsLastChunk() {
- bitField0_ = (bitField0_ & ~0x00000004);
- isLastChunk_ = false;
- onChanged();
- return this;
- }
-
- // optional int32 row_count = 4;
- private int rowCount_ ;
- /**
- * <code>optional int32 row_count = 4;</code>
- */
- public boolean hasRowCount() {
- return ((bitField0_ & 0x00000008) == 0x00000008);
- }
- /**
- * <code>optional int32 row_count = 4;</code>
- */
- public int getRowCount() {
- return rowCount_;
- }
- /**
- * <code>optional int32 row_count = 4;</code>
- */
- public Builder setRowCount(int value) {
- bitField0_ |= 0x00000008;
- rowCount_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>optional int32 row_count = 4;</code>
- */
- public Builder clearRowCount() {
- bitField0_ = (bitField0_ & ~0x00000008);
- rowCount_ = 0;
- onChanged();
- return this;
- }
-
- // optional int64 records_scan = 5;
- private long recordsScan_ ;
- /**
- * <code>optional int64 records_scan = 5;</code>
- */
- public boolean hasRecordsScan() {
- return ((bitField0_ & 0x00000010) == 0x00000010);
- }
- /**
- * <code>optional int64 records_scan = 5;</code>
- */
- public long getRecordsScan() {
- return recordsScan_;
- }
- /**
- * <code>optional int64 records_scan = 5;</code>
- */
- public Builder setRecordsScan(long value) {
- bitField0_ |= 0x00000010;
- recordsScan_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>optional int64 records_scan = 5;</code>
- */
- public Builder clearRecordsScan() {
- bitField0_ = (bitField0_ & ~0x00000010);
- recordsScan_ = 0L;
- onChanged();
- return this;
- }
-
- // optional int64 records_error = 6;
- private long recordsError_ ;
- /**
- * <code>optional int64 records_error = 6;</code>
- */
- public boolean hasRecordsError() {
- return ((bitField0_ & 0x00000020) == 0x00000020);
- }
- /**
- * <code>optional int64 records_error = 6;</code>
- */
- public long getRecordsError() {
- return recordsError_;
- }
- /**
- * <code>optional int64 records_error = 6;</code>
- */
- public Builder setRecordsError(long value) {
- bitField0_ |= 0x00000020;
- recordsError_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>optional int64 records_error = 6;</code>
- */
- public Builder clearRecordsError() {
- bitField0_ = (bitField0_ & ~0x00000020);
- recordsError_ = 0L;
- onChanged();
- return this;
- }
-
- // optional int64 submission_time = 7;
- private long submissionTime_ ;
- /**
- * <code>optional int64 submission_time = 7;</code>
- */
- public boolean hasSubmissionTime() {
- return ((bitField0_ & 0x00000040) == 0x00000040);
- }
- /**
- * <code>optional int64 submission_time = 7;</code>
- */
- public long getSubmissionTime() {
- return submissionTime_;
- }
- /**
- * <code>optional int64 submission_time = 7;</code>
- */
- public Builder setSubmissionTime(long value) {
- bitField0_ |= 0x00000040;
- submissionTime_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>optional int64 submission_time = 7;</code>
- */
- public Builder clearSubmissionTime() {
- bitField0_ = (bitField0_ & ~0x00000040);
- submissionTime_ = 0L;
- onChanged();
- return this;
- }
-
- // repeated .exec.user.NodeStatus node_status = 8;
- private java.util.List<org.apache.drill.exec.proto.UserProtos.NodeStatus> nodeStatus_ =
- java.util.Collections.emptyList();
- private void ensureNodeStatusIsMutable() {
- if (!((bitField0_ & 0x00000080) == 0x00000080)) {
- nodeStatus_ = new java.util.ArrayList<org.apache.drill.exec.proto.UserProtos.NodeStatus>(nodeStatus_);
- bitField0_ |= 0x00000080;
- }
- }
-
- private com.google.protobuf.RepeatedFieldBuilder<
- org.apache.drill.exec.proto.UserProtos.NodeStatus, org.apache.drill.exec.proto.UserProtos.NodeStatus.Builder, org.apache.drill.exec.proto.UserProtos.NodeStatusOrBuilder> nodeStatusBuilder_;
-
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public java.util.List<org.apache.drill.exec.proto.UserProtos.NodeStatus> getNodeStatusList() {
- if (nodeStatusBuilder_ == null) {
- return java.util.Collections.unmodifiableList(nodeStatus_);
- } else {
- return nodeStatusBuilder_.getMessageList();
- }
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public int getNodeStatusCount() {
- if (nodeStatusBuilder_ == null) {
- return nodeStatus_.size();
- } else {
- return nodeStatusBuilder_.getCount();
- }
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public org.apache.drill.exec.proto.UserProtos.NodeStatus getNodeStatus(int index) {
- if (nodeStatusBuilder_ == null) {
- return nodeStatus_.get(index);
- } else {
- return nodeStatusBuilder_.getMessage(index);
- }
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public Builder setNodeStatus(
- int index, org.apache.drill.exec.proto.UserProtos.NodeStatus value) {
- if (nodeStatusBuilder_ == null) {
- if (value == null) {
- throw new NullPointerException();
- }
- ensureNodeStatusIsMutable();
- nodeStatus_.set(index, value);
- onChanged();
- } else {
- nodeStatusBuilder_.setMessage(index, value);
- }
- return this;
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public Builder setNodeStatus(
- int index, org.apache.drill.exec.proto.UserProtos.NodeStatus.Builder builderForValue) {
- if (nodeStatusBuilder_ == null) {
- ensureNodeStatusIsMutable();
- nodeStatus_.set(index, builderForValue.build());
- onChanged();
- } else {
- nodeStatusBuilder_.setMessage(index, builderForValue.build());
- }
- return this;
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public Builder addNodeStatus(org.apache.drill.exec.proto.UserProtos.NodeStatus value) {
- if (nodeStatusBuilder_ == null) {
- if (value == null) {
- throw new NullPointerException();
- }
- ensureNodeStatusIsMutable();
- nodeStatus_.add(value);
- onChanged();
- } else {
- nodeStatusBuilder_.addMessage(value);
- }
- return this;
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public Builder addNodeStatus(
- int index, org.apache.drill.exec.proto.UserProtos.NodeStatus value) {
- if (nodeStatusBuilder_ == null) {
- if (value == null) {
- throw new NullPointerException();
- }
- ensureNodeStatusIsMutable();
- nodeStatus_.add(index, value);
- onChanged();
- } else {
- nodeStatusBuilder_.addMessage(index, value);
- }
- return this;
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public Builder addNodeStatus(
- org.apache.drill.exec.proto.UserProtos.NodeStatus.Builder builderForValue) {
- if (nodeStatusBuilder_ == null) {
- ensureNodeStatusIsMutable();
- nodeStatus_.add(builderForValue.build());
- onChanged();
- } else {
- nodeStatusBuilder_.addMessage(builderForValue.build());
- }
- return this;
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public Builder addNodeStatus(
- int index, org.apache.drill.exec.proto.UserProtos.NodeStatus.Builder builderForValue) {
- if (nodeStatusBuilder_ == null) {
- ensureNodeStatusIsMutable();
- nodeStatus_.add(index, builderForValue.build());
- onChanged();
- } else {
- nodeStatusBuilder_.addMessage(index, builderForValue.build());
- }
- return this;
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public Builder addAllNodeStatus(
- java.lang.Iterable<? extends org.apache.drill.exec.proto.UserProtos.NodeStatus> values) {
- if (nodeStatusBuilder_ == null) {
- ensureNodeStatusIsMutable();
- super.addAll(values, nodeStatus_);
- onChanged();
- } else {
- nodeStatusBuilder_.addAllMessages(values);
- }
- return this;
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public Builder clearNodeStatus() {
- if (nodeStatusBuilder_ == null) {
- nodeStatus_ = java.util.Collections.emptyList();
- bitField0_ = (bitField0_ & ~0x00000080);
- onChanged();
- } else {
- nodeStatusBuilder_.clear();
- }
- return this;
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public Builder removeNodeStatus(int index) {
- if (nodeStatusBuilder_ == null) {
- ensureNodeStatusIsMutable();
- nodeStatus_.remove(index);
- onChanged();
- } else {
- nodeStatusBuilder_.remove(index);
- }
- return this;
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public org.apache.drill.exec.proto.UserProtos.NodeStatus.Builder getNodeStatusBuilder(
- int index) {
- return getNodeStatusFieldBuilder().getBuilder(index);
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public org.apache.drill.exec.proto.UserProtos.NodeStatusOrBuilder getNodeStatusOrBuilder(
- int index) {
- if (nodeStatusBuilder_ == null) {
- return nodeStatus_.get(index); } else {
- return nodeStatusBuilder_.getMessageOrBuilder(index);
- }
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public java.util.List<? extends org.apache.drill.exec.proto.UserProtos.NodeStatusOrBuilder>
- getNodeStatusOrBuilderList() {
- if (nodeStatusBuilder_ != null) {
- return nodeStatusBuilder_.getMessageOrBuilderList();
- } else {
- return java.util.Collections.unmodifiableList(nodeStatus_);
- }
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public org.apache.drill.exec.proto.UserProtos.NodeStatus.Builder addNodeStatusBuilder() {
- return getNodeStatusFieldBuilder().addBuilder(
- org.apache.drill.exec.proto.UserProtos.NodeStatus.getDefaultInstance());
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public org.apache.drill.exec.proto.UserProtos.NodeStatus.Builder addNodeStatusBuilder(
- int index) {
- return getNodeStatusFieldBuilder().addBuilder(
- index, org.apache.drill.exec.proto.UserProtos.NodeStatus.getDefaultInstance());
- }
- /**
- * <code>repeated .exec.user.NodeStatus node_status = 8;</code>
- */
- public java.util.List<org.apache.drill.exec.proto.UserProtos.NodeStatus.Builder>
- getNodeStatusBuilderList() {
- return getNodeStatusFieldBuilder().getBuilderList();
- }
- private com.google.protobuf.RepeatedFieldBuilder<
- org.apache.drill.exec.proto.UserProtos.NodeStatus, org.apache.drill.exec.proto.UserProtos.NodeStatus.Builder, org.apache.drill.exec.proto.UserProtos.NodeStatusOrBuilder>
- getNodeStatusFieldBuilder() {
- if (nodeStatusBuilder_ == null) {
- nodeStatusBuilder_ = new com.google.protobuf.RepeatedFieldBuilder<
- org.apache.drill.exec.proto.UserProtos.NodeStatus, org.apache.drill.exec.proto.UserProtos.NodeStatus.Builder, org.apache.drill.exec.proto.UserProtos.NodeStatusOrBuilder>(
- nodeStatus_,
- ((bitField0_ & 0x00000080) == 0x00000080),
- getParentForChildren(),
- isClean());
- nodeStatus_ = null;
- }
- return nodeStatusBuilder_;
- }
-
- // repeated .exec.shared.DrillPBError error = 9;
- private java.util.List<org.apache.drill.exec.proto.UserBitShared.DrillPBError> error_ =
- java.util.Collections.emptyList();
- private void ensureErrorIsMutable() {
- if (!((bitField0_ & 0x00000100) == 0x00000100)) {
- error_ = new java.util.ArrayList<org.apache.drill.exec.proto.UserBitShared.DrillPBError>(error_);
- bitField0_ |= 0x00000100;
- }
- }
-
- private com.google.protobuf.RepeatedFieldBuilder<
- org.apache.drill.exec.proto.UserBitShared.DrillPBError, org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder, org.apache.drill.exec.proto.UserBitShared.DrillPBErrorOrBuilder> errorBuilder_;
-
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public java.util.List<org.apache.drill.exec.proto.UserBitShared.DrillPBError> getErrorList() {
- if (errorBuilder_ == null) {
- return java.util.Collections.unmodifiableList(error_);
- } else {
- return errorBuilder_.getMessageList();
- }
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public int getErrorCount() {
- if (errorBuilder_ == null) {
- return error_.size();
- } else {
- return errorBuilder_.getCount();
- }
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public org.apache.drill.exec.proto.UserBitShared.DrillPBError getError(int index) {
- if (errorBuilder_ == null) {
- return error_.get(index);
- } else {
- return errorBuilder_.getMessage(index);
- }
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public Builder setError(
- int index, org.apache.drill.exec.proto.UserBitShared.DrillPBError value) {
- if (errorBuilder_ == null) {
- if (value == null) {
- throw new NullPointerException();
- }
- ensureErrorIsMutable();
- error_.set(index, value);
- onChanged();
- } else {
- errorBuilder_.setMessage(index, value);
- }
- return this;
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public Builder setError(
- int index, org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder builderForValue) {
- if (errorBuilder_ == null) {
- ensureErrorIsMutable();
- error_.set(index, builderForValue.build());
- onChanged();
- } else {
- errorBuilder_.setMessage(index, builderForValue.build());
- }
- return this;
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public Builder addError(org.apache.drill.exec.proto.UserBitShared.DrillPBError value) {
- if (errorBuilder_ == null) {
- if (value == null) {
- throw new NullPointerException();
- }
- ensureErrorIsMutable();
- error_.add(value);
- onChanged();
- } else {
- errorBuilder_.addMessage(value);
- }
- return this;
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public Builder addError(
- int index, org.apache.drill.exec.proto.UserBitShared.DrillPBError value) {
- if (errorBuilder_ == null) {
- if (value == null) {
- throw new NullPointerException();
- }
- ensureErrorIsMutable();
- error_.add(index, value);
- onChanged();
- } else {
- errorBuilder_.addMessage(index, value);
- }
- return this;
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public Builder addError(
- org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder builderForValue) {
- if (errorBuilder_ == null) {
- ensureErrorIsMutable();
- error_.add(builderForValue.build());
- onChanged();
- } else {
- errorBuilder_.addMessage(builderForValue.build());
- }
- return this;
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public Builder addError(
- int index, org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder builderForValue) {
- if (errorBuilder_ == null) {
- ensureErrorIsMutable();
- error_.add(index, builderForValue.build());
- onChanged();
- } else {
- errorBuilder_.addMessage(index, builderForValue.build());
- }
- return this;
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public Builder addAllError(
- java.lang.Iterable<? extends org.apache.drill.exec.proto.UserBitShared.DrillPBError> values) {
- if (errorBuilder_ == null) {
- ensureErrorIsMutable();
- super.addAll(values, error_);
- onChanged();
- } else {
- errorBuilder_.addAllMessages(values);
- }
- return this;
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public Builder clearError() {
- if (errorBuilder_ == null) {
- error_ = java.util.Collections.emptyList();
- bitField0_ = (bitField0_ & ~0x00000100);
- onChanged();
- } else {
- errorBuilder_.clear();
- }
- return this;
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public Builder removeError(int index) {
- if (errorBuilder_ == null) {
- ensureErrorIsMutable();
- error_.remove(index);
- onChanged();
- } else {
- errorBuilder_.remove(index);
- }
- return this;
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder getErrorBuilder(
- int index) {
- return getErrorFieldBuilder().getBuilder(index);
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public org.apache.drill.exec.proto.UserBitShared.DrillPBErrorOrBuilder getErrorOrBuilder(
- int index) {
- if (errorBuilder_ == null) {
- return error_.get(index); } else {
- return errorBuilder_.getMessageOrBuilder(index);
- }
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public java.util.List<? extends org.apache.drill.exec.proto.UserBitShared.DrillPBErrorOrBuilder>
- getErrorOrBuilderList() {
- if (errorBuilder_ != null) {
- return errorBuilder_.getMessageOrBuilderList();
- } else {
- return java.util.Collections.unmodifiableList(error_);
- }
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder addErrorBuilder() {
- return getErrorFieldBuilder().addBuilder(
- org.apache.drill.exec.proto.UserBitShared.DrillPBError.getDefaultInstance());
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder addErrorBuilder(
- int index) {
- return getErrorFieldBuilder().addBuilder(
- index, org.apache.drill.exec.proto.UserBitShared.DrillPBError.getDefaultInstance());
- }
- /**
- * <code>repeated .exec.shared.DrillPBError error = 9;</code>
- */
- public java.util.List<org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder>
- getErrorBuilderList() {
- return getErrorFieldBuilder().getBuilderList();
- }
- private com.google.protobuf.RepeatedFieldBuilder<
- org.apache.drill.exec.proto.UserBitShared.DrillPBError, org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder, org.apache.drill.exec.proto.UserBitShared.DrillPBErrorOrBuilder>
- getErrorFieldBuilder() {
- if (errorBuilder_ == null) {
- errorBuilder_ = new com.google.protobuf.RepeatedFieldBuilder<
- org.apache.drill.exec.proto.UserBitShared.DrillPBError, org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder, org.apache.drill.exec.proto.UserBitShared.DrillPBErrorOrBuilder>(
- error_,
- ((bitField0_ & 0x00000100) == 0x00000100),
- getParentForChildren(),
- isClean());
- error_ = null;
- }
- return errorBuilder_;
- }
-
- // optional .exec.shared.RecordBatchDef def = 10;
- private org.apache.drill.exec.proto.UserBitShared.RecordBatchDef def_ = org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.getDefaultInstance();
- private com.google.protobuf.SingleFieldBuilder<
- org.apache.drill.exec.proto.UserBitShared.RecordBatchDef, org.apache.drill.exec.proto.UserBitShared.RecordBatchDef.Builder, org.apache.drill.exec.proto.UserBitShared.RecordBatchDefOrBuilder> defBuilder_;
- /**
- * <code>optional .exec.shared.RecordBatchDef def = 10;</code>
- */
- public boolean hasDef
<TRUNCATED>