You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@drill.apache.org by ja...@apache.org on 2014/05/22 03:14:51 UTC
[14/24] diag wip
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/cb90852a/protocol/src/main/java/org/apache/drill/exec/proto/UserBitShared.java
----------------------------------------------------------------------
diff --git a/protocol/src/main/java/org/apache/drill/exec/proto/UserBitShared.java b/protocol/src/main/java/org/apache/drill/exec/proto/UserBitShared.java
index 26c74a1..2ec7ba9 100644
--- a/protocol/src/main/java/org/apache/drill/exec/proto/UserBitShared.java
+++ b/protocol/src/main/java/org/apache/drill/exec/proto/UserBitShared.java
@@ -208,6 +208,124 @@ public final class UserBitShared {
}
/**
+ * Protobuf enum {@code exec.shared.FragmentState}
+ */
+ public enum FragmentState
+ implements com.google.protobuf.ProtocolMessageEnum {
+ /**
+ * <code>SENDING = 0;</code>
+ */
+ SENDING(0, 0),
+ /**
+ * <code>AWAITING_ALLOCATION = 1;</code>
+ */
+ AWAITING_ALLOCATION(1, 1),
+ /**
+ * <code>RUNNING = 2;</code>
+ */
+ RUNNING(2, 2),
+ /**
+ * <code>FINISHED = 3;</code>
+ */
+ FINISHED(3, 3),
+ /**
+ * <code>CANCELLED = 4;</code>
+ */
+ CANCELLED(4, 4),
+ /**
+ * <code>FAILED = 5;</code>
+ */
+ FAILED(5, 5),
+ ;
+
+ /**
+ * <code>SENDING = 0;</code>
+ */
+ public static final int SENDING_VALUE = 0;
+ /**
+ * <code>AWAITING_ALLOCATION = 1;</code>
+ */
+ public static final int AWAITING_ALLOCATION_VALUE = 1;
+ /**
+ * <code>RUNNING = 2;</code>
+ */
+ public static final int RUNNING_VALUE = 2;
+ /**
+ * <code>FINISHED = 3;</code>
+ */
+ public static final int FINISHED_VALUE = 3;
+ /**
+ * <code>CANCELLED = 4;</code>
+ */
+ public static final int CANCELLED_VALUE = 4;
+ /**
+ * <code>FAILED = 5;</code>
+ */
+ public static final int FAILED_VALUE = 5;
+
+
+ public final int getNumber() { return value; }
+
+ public static FragmentState valueOf(int value) {
+ switch (value) {
+ case 0: return SENDING;
+ case 1: return AWAITING_ALLOCATION;
+ case 2: return RUNNING;
+ case 3: return FINISHED;
+ case 4: return CANCELLED;
+ case 5: return FAILED;
+ default: return null;
+ }
+ }
+
+ public static com.google.protobuf.Internal.EnumLiteMap<FragmentState>
+ internalGetValueMap() {
+ return internalValueMap;
+ }
+ private static com.google.protobuf.Internal.EnumLiteMap<FragmentState>
+ internalValueMap =
+ new com.google.protobuf.Internal.EnumLiteMap<FragmentState>() {
+ public FragmentState findValueByNumber(int number) {
+ return FragmentState.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.UserBitShared.getDescriptor().getEnumTypes().get(2);
+ }
+
+ private static final FragmentState[] VALUES = values();
+
+ public static FragmentState 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 FragmentState(int index, int value) {
+ this.index = index;
+ this.value = value;
+ }
+
+ // @@protoc_insertion_point(enum_scope:exec.shared.FragmentState)
+ }
+
+ /**
* Protobuf enum {@code exec.shared.CoreOperatorType}
*/
public enum CoreOperatorType
@@ -525,7 +643,7 @@ public final class UserBitShared {
}
public static final com.google.protobuf.Descriptors.EnumDescriptor
getDescriptor() {
- return org.apache.drill.exec.proto.UserBitShared.getDescriptor().getEnumTypes().get(2);
+ return org.apache.drill.exec.proto.UserBitShared.getDescriptor().getEnumTypes().get(3);
}
private static final CoreOperatorType[] VALUES = values();
@@ -6884,27 +7002,42 @@ public final class UserBitShared {
com.google.protobuf.ByteString
getQueryBytes();
- // repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;
+ // optional string plan = 6;
+ /**
+ * <code>optional string plan = 6;</code>
+ */
+ boolean hasPlan();
+ /**
+ * <code>optional string plan = 6;</code>
+ */
+ java.lang.String getPlan();
+ /**
+ * <code>optional string plan = 6;</code>
+ */
+ com.google.protobuf.ByteString
+ getPlanBytes();
+
+ // repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
java.util.List<org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile>
getFragmentProfileList();
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile getFragmentProfile(int index);
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
int getFragmentProfileCount();
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
java.util.List<? extends org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfileOrBuilder>
getFragmentProfileOrBuilderList();
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfileOrBuilder getFragmentProfileOrBuilder(
int index);
@@ -7000,9 +7133,14 @@ public final class UserBitShared {
break;
}
case 50: {
- if (!((mutable_bitField0_ & 0x00000020) == 0x00000020)) {
+ bitField0_ |= 0x00000020;
+ plan_ = input.readBytes();
+ break;
+ }
+ case 58: {
+ if (!((mutable_bitField0_ & 0x00000040) == 0x00000040)) {
fragmentProfile_ = new java.util.ArrayList<org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile>();
- mutable_bitField0_ |= 0x00000020;
+ mutable_bitField0_ |= 0x00000040;
}
fragmentProfile_.add(input.readMessage(org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.PARSER, extensionRegistry));
break;
@@ -7015,7 +7153,7 @@ public final class UserBitShared {
throw new com.google.protobuf.InvalidProtocolBufferException(
e.getMessage()).setUnfinishedMessage(this);
} finally {
- if (((mutable_bitField0_ & 0x00000020) == 0x00000020)) {
+ if (((mutable_bitField0_ & 0x00000040) == 0x00000040)) {
fragmentProfile_ = java.util.Collections.unmodifiableList(fragmentProfile_);
}
this.unknownFields = unknownFields.build();
@@ -7163,36 +7301,79 @@ public final class UserBitShared {
}
}
- // repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;
- public static final int FRAGMENT_PROFILE_FIELD_NUMBER = 6;
+ // optional string plan = 6;
+ public static final int PLAN_FIELD_NUMBER = 6;
+ private java.lang.Object plan_;
+ /**
+ * <code>optional string plan = 6;</code>
+ */
+ public boolean hasPlan() {
+ return ((bitField0_ & 0x00000020) == 0x00000020);
+ }
+ /**
+ * <code>optional string plan = 6;</code>
+ */
+ public java.lang.String getPlan() {
+ java.lang.Object ref = plan_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ if (bs.isValidUtf8()) {
+ plan_ = s;
+ }
+ return s;
+ }
+ }
+ /**
+ * <code>optional string plan = 6;</code>
+ */
+ public com.google.protobuf.ByteString
+ getPlanBytes() {
+ java.lang.Object ref = plan_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ plan_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ // repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;
+ public static final int FRAGMENT_PROFILE_FIELD_NUMBER = 7;
private java.util.List<org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile> fragmentProfile_;
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public java.util.List<org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile> getFragmentProfileList() {
return fragmentProfile_;
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public java.util.List<? extends org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfileOrBuilder>
getFragmentProfileOrBuilderList() {
return fragmentProfile_;
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public int getFragmentProfileCount() {
return fragmentProfile_.size();
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile getFragmentProfile(int index) {
return fragmentProfile_.get(index);
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfileOrBuilder getFragmentProfileOrBuilder(
int index) {
@@ -7205,6 +7386,7 @@ public final class UserBitShared {
start_ = 0L;
end_ = 0L;
query_ = "";
+ plan_ = "";
fragmentProfile_ = java.util.Collections.emptyList();
}
private byte memoizedIsInitialized = -1;
@@ -7234,8 +7416,11 @@ public final class UserBitShared {
if (((bitField0_ & 0x00000010) == 0x00000010)) {
output.writeBytes(5, getQueryBytes());
}
+ if (((bitField0_ & 0x00000020) == 0x00000020)) {
+ output.writeBytes(6, getPlanBytes());
+ }
for (int i = 0; i < fragmentProfile_.size(); i++) {
- output.writeMessage(6, fragmentProfile_.get(i));
+ output.writeMessage(7, fragmentProfile_.get(i));
}
getUnknownFields().writeTo(output);
}
@@ -7266,9 +7451,13 @@ public final class UserBitShared {
size += com.google.protobuf.CodedOutputStream
.computeBytesSize(5, getQueryBytes());
}
+ if (((bitField0_ & 0x00000020) == 0x00000020)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeBytesSize(6, getPlanBytes());
+ }
for (int i = 0; i < fragmentProfile_.size(); i++) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(6, fragmentProfile_.get(i));
+ .computeMessageSize(7, fragmentProfile_.get(i));
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
@@ -7402,9 +7591,11 @@ public final class UserBitShared {
bitField0_ = (bitField0_ & ~0x00000008);
query_ = "";
bitField0_ = (bitField0_ & ~0x00000010);
+ plan_ = "";
+ bitField0_ = (bitField0_ & ~0x00000020);
if (fragmentProfileBuilder_ == null) {
fragmentProfile_ = java.util.Collections.emptyList();
- bitField0_ = (bitField0_ & ~0x00000020);
+ bitField0_ = (bitField0_ & ~0x00000040);
} else {
fragmentProfileBuilder_.clear();
}
@@ -7460,10 +7651,14 @@ public final class UserBitShared {
to_bitField0_ |= 0x00000010;
}
result.query_ = query_;
+ if (((from_bitField0_ & 0x00000020) == 0x00000020)) {
+ to_bitField0_ |= 0x00000020;
+ }
+ result.plan_ = plan_;
if (fragmentProfileBuilder_ == null) {
- if (((bitField0_ & 0x00000020) == 0x00000020)) {
+ if (((bitField0_ & 0x00000040) == 0x00000040)) {
fragmentProfile_ = java.util.Collections.unmodifiableList(fragmentProfile_);
- bitField0_ = (bitField0_ & ~0x00000020);
+ bitField0_ = (bitField0_ & ~0x00000040);
}
result.fragmentProfile_ = fragmentProfile_;
} else {
@@ -7502,11 +7697,16 @@ public final class UserBitShared {
query_ = other.query_;
onChanged();
}
+ if (other.hasPlan()) {
+ bitField0_ |= 0x00000020;
+ plan_ = other.plan_;
+ onChanged();
+ }
if (fragmentProfileBuilder_ == null) {
if (!other.fragmentProfile_.isEmpty()) {
if (fragmentProfile_.isEmpty()) {
fragmentProfile_ = other.fragmentProfile_;
- bitField0_ = (bitField0_ & ~0x00000020);
+ bitField0_ = (bitField0_ & ~0x00000040);
} else {
ensureFragmentProfileIsMutable();
fragmentProfile_.addAll(other.fragmentProfile_);
@@ -7519,7 +7719,7 @@ public final class UserBitShared {
fragmentProfileBuilder_.dispose();
fragmentProfileBuilder_ = null;
fragmentProfile_ = other.fragmentProfile_;
- bitField0_ = (bitField0_ & ~0x00000020);
+ bitField0_ = (bitField0_ & ~0x00000040);
fragmentProfileBuilder_ =
com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders ?
getFragmentProfileFieldBuilder() : null;
@@ -7848,13 +8048,87 @@ public final class UserBitShared {
return this;
}
- // repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;
+ // optional string plan = 6;
+ private java.lang.Object plan_ = "";
+ /**
+ * <code>optional string plan = 6;</code>
+ */
+ public boolean hasPlan() {
+ return ((bitField0_ & 0x00000020) == 0x00000020);
+ }
+ /**
+ * <code>optional string plan = 6;</code>
+ */
+ public java.lang.String getPlan() {
+ java.lang.Object ref = plan_;
+ if (!(ref instanceof java.lang.String)) {
+ java.lang.String s = ((com.google.protobuf.ByteString) ref)
+ .toStringUtf8();
+ plan_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * <code>optional string plan = 6;</code>
+ */
+ public com.google.protobuf.ByteString
+ getPlanBytes() {
+ java.lang.Object ref = plan_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ plan_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * <code>optional string plan = 6;</code>
+ */
+ public Builder setPlan(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ bitField0_ |= 0x00000020;
+ plan_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * <code>optional string plan = 6;</code>
+ */
+ public Builder clearPlan() {
+ bitField0_ = (bitField0_ & ~0x00000020);
+ plan_ = getDefaultInstance().getPlan();
+ onChanged();
+ return this;
+ }
+ /**
+ * <code>optional string plan = 6;</code>
+ */
+ public Builder setPlanBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ bitField0_ |= 0x00000020;
+ plan_ = value;
+ onChanged();
+ return this;
+ }
+
+ // repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;
private java.util.List<org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile> fragmentProfile_ =
java.util.Collections.emptyList();
private void ensureFragmentProfileIsMutable() {
- if (!((bitField0_ & 0x00000020) == 0x00000020)) {
+ if (!((bitField0_ & 0x00000040) == 0x00000040)) {
fragmentProfile_ = new java.util.ArrayList<org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile>(fragmentProfile_);
- bitField0_ |= 0x00000020;
+ bitField0_ |= 0x00000040;
}
}
@@ -7862,7 +8136,7 @@ public final class UserBitShared {
org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile, org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.Builder, org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfileOrBuilder> fragmentProfileBuilder_;
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public java.util.List<org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile> getFragmentProfileList() {
if (fragmentProfileBuilder_ == null) {
@@ -7872,7 +8146,7 @@ public final class UserBitShared {
}
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public int getFragmentProfileCount() {
if (fragmentProfileBuilder_ == null) {
@@ -7882,7 +8156,7 @@ public final class UserBitShared {
}
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile getFragmentProfile(int index) {
if (fragmentProfileBuilder_ == null) {
@@ -7892,7 +8166,7 @@ public final class UserBitShared {
}
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public Builder setFragmentProfile(
int index, org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile value) {
@@ -7909,7 +8183,7 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public Builder setFragmentProfile(
int index, org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.Builder builderForValue) {
@@ -7923,7 +8197,7 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public Builder addFragmentProfile(org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile value) {
if (fragmentProfileBuilder_ == null) {
@@ -7939,7 +8213,7 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public Builder addFragmentProfile(
int index, org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile value) {
@@ -7956,7 +8230,7 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public Builder addFragmentProfile(
org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.Builder builderForValue) {
@@ -7970,7 +8244,7 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public Builder addFragmentProfile(
int index, org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.Builder builderForValue) {
@@ -7984,7 +8258,7 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public Builder addAllFragmentProfile(
java.lang.Iterable<? extends org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile> values) {
@@ -7998,12 +8272,12 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public Builder clearFragmentProfile() {
if (fragmentProfileBuilder_ == null) {
fragmentProfile_ = java.util.Collections.emptyList();
- bitField0_ = (bitField0_ & ~0x00000020);
+ bitField0_ = (bitField0_ & ~0x00000040);
onChanged();
} else {
fragmentProfileBuilder_.clear();
@@ -8011,7 +8285,7 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public Builder removeFragmentProfile(int index) {
if (fragmentProfileBuilder_ == null) {
@@ -8024,14 +8298,14 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.Builder getFragmentProfileBuilder(
int index) {
return getFragmentProfileFieldBuilder().getBuilder(index);
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfileOrBuilder getFragmentProfileOrBuilder(
int index) {
@@ -8041,7 +8315,7 @@ public final class UserBitShared {
}
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public java.util.List<? extends org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfileOrBuilder>
getFragmentProfileOrBuilderList() {
@@ -8052,14 +8326,14 @@ public final class UserBitShared {
}
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.Builder addFragmentProfileBuilder() {
return getFragmentProfileFieldBuilder().addBuilder(
org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.getDefaultInstance());
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.Builder addFragmentProfileBuilder(
int index) {
@@ -8067,7 +8341,7 @@ public final class UserBitShared {
index, org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.getDefaultInstance());
}
/**
- * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 6;</code>
+ * <code>repeated .exec.shared.MajorFragmentProfile fragment_profile = 7;</code>
*/
public java.util.List<org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.Builder>
getFragmentProfileBuilderList() {
@@ -8080,7 +8354,7 @@ public final class UserBitShared {
fragmentProfileBuilder_ = new com.google.protobuf.RepeatedFieldBuilder<
org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile, org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfile.Builder, org.apache.drill.exec.proto.UserBitShared.MajorFragmentProfileOrBuilder>(
fragmentProfile_,
- ((bitField0_ & 0x00000020) == 0x00000020),
+ ((bitField0_ & 0x00000040) == 0x00000040),
getParentForChildren(),
isClean());
fragmentProfile_ = null;
@@ -8860,60 +9134,118 @@ public final class UserBitShared {
public interface MinorFragmentProfileOrBuilder
extends com.google.protobuf.MessageOrBuilder {
- // optional int32 minor_fragment_id = 1;
+ // optional .exec.shared.FragmentState state = 1;
+ /**
+ * <code>optional .exec.shared.FragmentState state = 1;</code>
+ */
+ boolean hasState();
+ /**
+ * <code>optional .exec.shared.FragmentState state = 1;</code>
+ */
+ org.apache.drill.exec.proto.UserBitShared.FragmentState getState();
+
+ // optional .exec.shared.DrillPBError error = 2;
+ /**
+ * <code>optional .exec.shared.DrillPBError error = 2;</code>
+ */
+ boolean hasError();
+ /**
+ * <code>optional .exec.shared.DrillPBError error = 2;</code>
+ */
+ org.apache.drill.exec.proto.UserBitShared.DrillPBError getError();
+ /**
+ * <code>optional .exec.shared.DrillPBError error = 2;</code>
+ */
+ org.apache.drill.exec.proto.UserBitShared.DrillPBErrorOrBuilder getErrorOrBuilder();
+
+ // optional int32 minor_fragment_id = 3;
/**
- * <code>optional int32 minor_fragment_id = 1;</code>
+ * <code>optional int32 minor_fragment_id = 3;</code>
*/
boolean hasMinorFragmentId();
/**
- * <code>optional int32 minor_fragment_id = 1;</code>
+ * <code>optional int32 minor_fragment_id = 3;</code>
*/
int getMinorFragmentId();
- // repeated .exec.shared.OperatorProfile operator_profile = 2;
+ // repeated .exec.shared.OperatorProfile operator_profile = 4;
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
java.util.List<org.apache.drill.exec.proto.UserBitShared.OperatorProfile>
getOperatorProfileList();
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
org.apache.drill.exec.proto.UserBitShared.OperatorProfile getOperatorProfile(int index);
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
int getOperatorProfileCount();
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
java.util.List<? extends org.apache.drill.exec.proto.UserBitShared.OperatorProfileOrBuilder>
getOperatorProfileOrBuilderList();
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
org.apache.drill.exec.proto.UserBitShared.OperatorProfileOrBuilder getOperatorProfileOrBuilder(
int index);
- // optional int64 start_time = 3;
+ // optional int64 start_time = 5;
/**
- * <code>optional int64 start_time = 3;</code>
+ * <code>optional int64 start_time = 5;</code>
*/
boolean hasStartTime();
/**
- * <code>optional int64 start_time = 3;</code>
+ * <code>optional int64 start_time = 5;</code>
*/
long getStartTime();
- // optional int64 end_time = 4;
+ // optional int64 end_time = 6;
/**
- * <code>optional int64 end_time = 4;</code>
+ * <code>optional int64 end_time = 6;</code>
*/
boolean hasEndTime();
/**
- * <code>optional int64 end_time = 4;</code>
+ * <code>optional int64 end_time = 6;</code>
*/
long getEndTime();
+
+ // optional int64 memory_used = 7;
+ /**
+ * <code>optional int64 memory_used = 7;</code>
+ */
+ boolean hasMemoryUsed();
+ /**
+ * <code>optional int64 memory_used = 7;</code>
+ */
+ long getMemoryUsed();
+
+ // optional int64 max_memory_used = 8;
+ /**
+ * <code>optional int64 max_memory_used = 8;</code>
+ */
+ boolean hasMaxMemoryUsed();
+ /**
+ * <code>optional int64 max_memory_used = 8;</code>
+ */
+ long getMaxMemoryUsed();
+
+ // optional .exec.DrillbitEndpoint endpoint = 9;
+ /**
+ * <code>optional .exec.DrillbitEndpoint endpoint = 9;</code>
+ */
+ boolean hasEndpoint();
+ /**
+ * <code>optional .exec.DrillbitEndpoint endpoint = 9;</code>
+ */
+ org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint getEndpoint();
+ /**
+ * <code>optional .exec.DrillbitEndpoint endpoint = 9;</code>
+ */
+ org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpointOrBuilder getEndpointOrBuilder();
}
/**
* Protobuf type {@code exec.shared.MinorFragmentProfile}
@@ -8967,39 +9299,86 @@ public final class UserBitShared {
break;
}
case 8: {
- bitField0_ |= 0x00000001;
- minorFragmentId_ = input.readInt32();
+ int rawValue = input.readEnum();
+ org.apache.drill.exec.proto.UserBitShared.FragmentState value = org.apache.drill.exec.proto.UserBitShared.FragmentState.valueOf(rawValue);
+ if (value == null) {
+ unknownFields.mergeVarintField(1, rawValue);
+ } else {
+ bitField0_ |= 0x00000001;
+ state_ = value;
+ }
break;
}
case 18: {
- if (!((mutable_bitField0_ & 0x00000002) == 0x00000002)) {
+ org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder subBuilder = null;
+ if (((bitField0_ & 0x00000002) == 0x00000002)) {
+ subBuilder = error_.toBuilder();
+ }
+ error_ = input.readMessage(org.apache.drill.exec.proto.UserBitShared.DrillPBError.PARSER, extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(error_);
+ error_ = subBuilder.buildPartial();
+ }
+ bitField0_ |= 0x00000002;
+ break;
+ }
+ case 24: {
+ bitField0_ |= 0x00000004;
+ minorFragmentId_ = input.readInt32();
+ break;
+ }
+ case 34: {
+ if (!((mutable_bitField0_ & 0x00000008) == 0x00000008)) {
operatorProfile_ = new java.util.ArrayList<org.apache.drill.exec.proto.UserBitShared.OperatorProfile>();
- mutable_bitField0_ |= 0x00000002;
+ mutable_bitField0_ |= 0x00000008;
}
operatorProfile_.add(input.readMessage(org.apache.drill.exec.proto.UserBitShared.OperatorProfile.PARSER, extensionRegistry));
break;
}
- case 24: {
- bitField0_ |= 0x00000002;
+ case 40: {
+ bitField0_ |= 0x00000008;
startTime_ = input.readInt64();
break;
}
- case 32: {
- bitField0_ |= 0x00000004;
+ case 48: {
+ bitField0_ |= 0x00000010;
endTime_ = 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 {
- if (((mutable_bitField0_ & 0x00000002) == 0x00000002)) {
- operatorProfile_ = java.util.Collections.unmodifiableList(operatorProfile_);
- }
+ case 56: {
+ bitField0_ |= 0x00000020;
+ memoryUsed_ = input.readInt64();
+ break;
+ }
+ case 64: {
+ bitField0_ |= 0x00000040;
+ maxMemoryUsed_ = input.readInt64();
+ break;
+ }
+ case 74: {
+ org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint.Builder subBuilder = null;
+ if (((bitField0_ & 0x00000080) == 0x00000080)) {
+ subBuilder = endpoint_.toBuilder();
+ }
+ endpoint_ = input.readMessage(org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint.PARSER, extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(endpoint_);
+ endpoint_ = subBuilder.buildPartial();
+ }
+ bitField0_ |= 0x00000080;
+ 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_ & 0x00000008) == 0x00000008)) {
+ operatorProfile_ = java.util.Collections.unmodifiableList(operatorProfile_);
+ }
this.unknownFields = unknownFields.build();
makeExtensionsImmutable();
}
@@ -9032,95 +9411,192 @@ public final class UserBitShared {
}
private int bitField0_;
- // optional int32 minor_fragment_id = 1;
- public static final int MINOR_FRAGMENT_ID_FIELD_NUMBER = 1;
+ // optional .exec.shared.FragmentState state = 1;
+ public static final int STATE_FIELD_NUMBER = 1;
+ private org.apache.drill.exec.proto.UserBitShared.FragmentState state_;
+ /**
+ * <code>optional .exec.shared.FragmentState state = 1;</code>
+ */
+ public boolean hasState() {
+ return ((bitField0_ & 0x00000001) == 0x00000001);
+ }
+ /**
+ * <code>optional .exec.shared.FragmentState state = 1;</code>
+ */
+ public org.apache.drill.exec.proto.UserBitShared.FragmentState getState() {
+ return state_;
+ }
+
+ // optional .exec.shared.DrillPBError error = 2;
+ public static final int ERROR_FIELD_NUMBER = 2;
+ private org.apache.drill.exec.proto.UserBitShared.DrillPBError error_;
+ /**
+ * <code>optional .exec.shared.DrillPBError error = 2;</code>
+ */
+ public boolean hasError() {
+ return ((bitField0_ & 0x00000002) == 0x00000002);
+ }
+ /**
+ * <code>optional .exec.shared.DrillPBError error = 2;</code>
+ */
+ public org.apache.drill.exec.proto.UserBitShared.DrillPBError getError() {
+ return error_;
+ }
+ /**
+ * <code>optional .exec.shared.DrillPBError error = 2;</code>
+ */
+ public org.apache.drill.exec.proto.UserBitShared.DrillPBErrorOrBuilder getErrorOrBuilder() {
+ return error_;
+ }
+
+ // optional int32 minor_fragment_id = 3;
+ public static final int MINOR_FRAGMENT_ID_FIELD_NUMBER = 3;
private int minorFragmentId_;
/**
- * <code>optional int32 minor_fragment_id = 1;</code>
+ * <code>optional int32 minor_fragment_id = 3;</code>
*/
public boolean hasMinorFragmentId() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
+ return ((bitField0_ & 0x00000004) == 0x00000004);
}
/**
- * <code>optional int32 minor_fragment_id = 1;</code>
+ * <code>optional int32 minor_fragment_id = 3;</code>
*/
public int getMinorFragmentId() {
return minorFragmentId_;
}
- // repeated .exec.shared.OperatorProfile operator_profile = 2;
- public static final int OPERATOR_PROFILE_FIELD_NUMBER = 2;
+ // repeated .exec.shared.OperatorProfile operator_profile = 4;
+ public static final int OPERATOR_PROFILE_FIELD_NUMBER = 4;
private java.util.List<org.apache.drill.exec.proto.UserBitShared.OperatorProfile> operatorProfile_;
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public java.util.List<org.apache.drill.exec.proto.UserBitShared.OperatorProfile> getOperatorProfileList() {
return operatorProfile_;
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public java.util.List<? extends org.apache.drill.exec.proto.UserBitShared.OperatorProfileOrBuilder>
getOperatorProfileOrBuilderList() {
return operatorProfile_;
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public int getOperatorProfileCount() {
return operatorProfile_.size();
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public org.apache.drill.exec.proto.UserBitShared.OperatorProfile getOperatorProfile(int index) {
return operatorProfile_.get(index);
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public org.apache.drill.exec.proto.UserBitShared.OperatorProfileOrBuilder getOperatorProfileOrBuilder(
int index) {
return operatorProfile_.get(index);
}
- // optional int64 start_time = 3;
- public static final int START_TIME_FIELD_NUMBER = 3;
+ // optional int64 start_time = 5;
+ public static final int START_TIME_FIELD_NUMBER = 5;
private long startTime_;
/**
- * <code>optional int64 start_time = 3;</code>
+ * <code>optional int64 start_time = 5;</code>
*/
public boolean hasStartTime() {
- return ((bitField0_ & 0x00000002) == 0x00000002);
+ return ((bitField0_ & 0x00000008) == 0x00000008);
}
/**
- * <code>optional int64 start_time = 3;</code>
+ * <code>optional int64 start_time = 5;</code>
*/
public long getStartTime() {
return startTime_;
}
- // optional int64 end_time = 4;
- public static final int END_TIME_FIELD_NUMBER = 4;
+ // optional int64 end_time = 6;
+ public static final int END_TIME_FIELD_NUMBER = 6;
private long endTime_;
/**
- * <code>optional int64 end_time = 4;</code>
+ * <code>optional int64 end_time = 6;</code>
*/
public boolean hasEndTime() {
- return ((bitField0_ & 0x00000004) == 0x00000004);
+ return ((bitField0_ & 0x00000010) == 0x00000010);
}
/**
- * <code>optional int64 end_time = 4;</code>
+ * <code>optional int64 end_time = 6;</code>
*/
public long getEndTime() {
return endTime_;
}
+ // optional int64 memory_used = 7;
+ public static final int MEMORY_USED_FIELD_NUMBER = 7;
+ private long memoryUsed_;
+ /**
+ * <code>optional int64 memory_used = 7;</code>
+ */
+ public boolean hasMemoryUsed() {
+ return ((bitField0_ & 0x00000020) == 0x00000020);
+ }
+ /**
+ * <code>optional int64 memory_used = 7;</code>
+ */
+ public long getMemoryUsed() {
+ return memoryUsed_;
+ }
+
+ // optional int64 max_memory_used = 8;
+ public static final int MAX_MEMORY_USED_FIELD_NUMBER = 8;
+ private long maxMemoryUsed_;
+ /**
+ * <code>optional int64 max_memory_used = 8;</code>
+ */
+ public boolean hasMaxMemoryUsed() {
+ return ((bitField0_ & 0x00000040) == 0x00000040);
+ }
+ /**
+ * <code>optional int64 max_memory_used = 8;</code>
+ */
+ public long getMaxMemoryUsed() {
+ return maxMemoryUsed_;
+ }
+
+ // optional .exec.DrillbitEndpoint endpoint = 9;
+ public static final int ENDPOINT_FIELD_NUMBER = 9;
+ private org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint endpoint_;
+ /**
+ * <code>optional .exec.DrillbitEndpoint endpoint = 9;</code>
+ */
+ public boolean hasEndpoint() {
+ return ((bitField0_ & 0x00000080) == 0x00000080);
+ }
+ /**
+ * <code>optional .exec.DrillbitEndpoint endpoint = 9;</code>
+ */
+ public org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint getEndpoint() {
+ return endpoint_;
+ }
+ /**
+ * <code>optional .exec.DrillbitEndpoint endpoint = 9;</code>
+ */
+ public org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpointOrBuilder getEndpointOrBuilder() {
+ return endpoint_;
+ }
+
private void initFields() {
+ state_ = org.apache.drill.exec.proto.UserBitShared.FragmentState.SENDING;
+ error_ = org.apache.drill.exec.proto.UserBitShared.DrillPBError.getDefaultInstance();
minorFragmentId_ = 0;
operatorProfile_ = java.util.Collections.emptyList();
startTime_ = 0L;
endTime_ = 0L;
+ memoryUsed_ = 0L;
+ maxMemoryUsed_ = 0L;
+ endpoint_ = org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint.getDefaultInstance();
}
private byte memoizedIsInitialized = -1;
public final boolean isInitialized() {
@@ -9135,16 +9611,31 @@ public final class UserBitShared {
throws java.io.IOException {
getSerializedSize();
if (((bitField0_ & 0x00000001) == 0x00000001)) {
- output.writeInt32(1, minorFragmentId_);
- }
- for (int i = 0; i < operatorProfile_.size(); i++) {
- output.writeMessage(2, operatorProfile_.get(i));
+ output.writeEnum(1, state_.getNumber());
}
if (((bitField0_ & 0x00000002) == 0x00000002)) {
- output.writeInt64(3, startTime_);
+ output.writeMessage(2, error_);
}
if (((bitField0_ & 0x00000004) == 0x00000004)) {
- output.writeInt64(4, endTime_);
+ output.writeInt32(3, minorFragmentId_);
+ }
+ for (int i = 0; i < operatorProfile_.size(); i++) {
+ output.writeMessage(4, operatorProfile_.get(i));
+ }
+ if (((bitField0_ & 0x00000008) == 0x00000008)) {
+ output.writeInt64(5, startTime_);
+ }
+ if (((bitField0_ & 0x00000010) == 0x00000010)) {
+ output.writeInt64(6, endTime_);
+ }
+ if (((bitField0_ & 0x00000020) == 0x00000020)) {
+ output.writeInt64(7, memoryUsed_);
+ }
+ if (((bitField0_ & 0x00000040) == 0x00000040)) {
+ output.writeInt64(8, maxMemoryUsed_);
+ }
+ if (((bitField0_ & 0x00000080) == 0x00000080)) {
+ output.writeMessage(9, endpoint_);
}
getUnknownFields().writeTo(output);
}
@@ -9157,19 +9648,39 @@ public final class UserBitShared {
size = 0;
if (((bitField0_ & 0x00000001) == 0x00000001)) {
size += com.google.protobuf.CodedOutputStream
- .computeInt32Size(1, minorFragmentId_);
+ .computeEnumSize(1, state_.getNumber());
+ }
+ if (((bitField0_ & 0x00000002) == 0x00000002)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(2, error_);
+ }
+ if (((bitField0_ & 0x00000004) == 0x00000004)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(3, minorFragmentId_);
}
for (int i = 0; i < operatorProfile_.size(); i++) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(2, operatorProfile_.get(i));
+ .computeMessageSize(4, operatorProfile_.get(i));
}
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
+ if (((bitField0_ & 0x00000008) == 0x00000008)) {
size += com.google.protobuf.CodedOutputStream
- .computeInt64Size(3, startTime_);
+ .computeInt64Size(5, startTime_);
}
- if (((bitField0_ & 0x00000004) == 0x00000004)) {
+ if (((bitField0_ & 0x00000010) == 0x00000010)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt64Size(6, endTime_);
+ }
+ if (((bitField0_ & 0x00000020) == 0x00000020)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt64Size(7, memoryUsed_);
+ }
+ if (((bitField0_ & 0x00000040) == 0x00000040)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt64Size(8, maxMemoryUsed_);
+ }
+ if (((bitField0_ & 0x00000080) == 0x00000080)) {
size += com.google.protobuf.CodedOutputStream
- .computeInt64Size(4, endTime_);
+ .computeMessageSize(9, endpoint_);
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
@@ -9279,7 +9790,9 @@ public final class UserBitShared {
}
private void maybeForceBuilderInitialization() {
if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
+ getErrorFieldBuilder();
getOperatorProfileFieldBuilder();
+ getEndpointFieldBuilder();
}
}
private static Builder create() {
@@ -9288,18 +9801,36 @@ public final class UserBitShared {
public Builder clear() {
super.clear();
- minorFragmentId_ = 0;
+ state_ = org.apache.drill.exec.proto.UserBitShared.FragmentState.SENDING;
bitField0_ = (bitField0_ & ~0x00000001);
+ if (errorBuilder_ == null) {
+ error_ = org.apache.drill.exec.proto.UserBitShared.DrillPBError.getDefaultInstance();
+ } else {
+ errorBuilder_.clear();
+ }
+ bitField0_ = (bitField0_ & ~0x00000002);
+ minorFragmentId_ = 0;
+ bitField0_ = (bitField0_ & ~0x00000004);
if (operatorProfileBuilder_ == null) {
operatorProfile_ = java.util.Collections.emptyList();
- bitField0_ = (bitField0_ & ~0x00000002);
+ bitField0_ = (bitField0_ & ~0x00000008);
} else {
operatorProfileBuilder_.clear();
}
startTime_ = 0L;
- bitField0_ = (bitField0_ & ~0x00000004);
+ bitField0_ = (bitField0_ & ~0x00000010);
endTime_ = 0L;
- bitField0_ = (bitField0_ & ~0x00000008);
+ bitField0_ = (bitField0_ & ~0x00000020);
+ memoryUsed_ = 0L;
+ bitField0_ = (bitField0_ & ~0x00000040);
+ maxMemoryUsed_ = 0L;
+ bitField0_ = (bitField0_ & ~0x00000080);
+ if (endpointBuilder_ == null) {
+ endpoint_ = org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint.getDefaultInstance();
+ } else {
+ endpointBuilder_.clear();
+ }
+ bitField0_ = (bitField0_ & ~0x00000100);
return this;
}
@@ -9331,24 +9862,52 @@ public final class UserBitShared {
if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
to_bitField0_ |= 0x00000001;
}
+ result.state_ = state_;
+ if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
+ to_bitField0_ |= 0x00000002;
+ }
+ if (errorBuilder_ == null) {
+ result.error_ = error_;
+ } else {
+ result.error_ = errorBuilder_.build();
+ }
+ if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
+ to_bitField0_ |= 0x00000004;
+ }
result.minorFragmentId_ = minorFragmentId_;
if (operatorProfileBuilder_ == null) {
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
+ if (((bitField0_ & 0x00000008) == 0x00000008)) {
operatorProfile_ = java.util.Collections.unmodifiableList(operatorProfile_);
- bitField0_ = (bitField0_ & ~0x00000002);
+ bitField0_ = (bitField0_ & ~0x00000008);
}
result.operatorProfile_ = operatorProfile_;
} else {
result.operatorProfile_ = operatorProfileBuilder_.build();
}
- if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
- to_bitField0_ |= 0x00000002;
+ if (((from_bitField0_ & 0x00000010) == 0x00000010)) {
+ to_bitField0_ |= 0x00000008;
}
result.startTime_ = startTime_;
- if (((from_bitField0_ & 0x00000008) == 0x00000008)) {
- to_bitField0_ |= 0x00000004;
+ if (((from_bitField0_ & 0x00000020) == 0x00000020)) {
+ to_bitField0_ |= 0x00000010;
}
result.endTime_ = endTime_;
+ if (((from_bitField0_ & 0x00000040) == 0x00000040)) {
+ to_bitField0_ |= 0x00000020;
+ }
+ result.memoryUsed_ = memoryUsed_;
+ if (((from_bitField0_ & 0x00000080) == 0x00000080)) {
+ to_bitField0_ |= 0x00000040;
+ }
+ result.maxMemoryUsed_ = maxMemoryUsed_;
+ if (((from_bitField0_ & 0x00000100) == 0x00000100)) {
+ to_bitField0_ |= 0x00000080;
+ }
+ if (endpointBuilder_ == null) {
+ result.endpoint_ = endpoint_;
+ } else {
+ result.endpoint_ = endpointBuilder_.build();
+ }
result.bitField0_ = to_bitField0_;
onBuilt();
return result;
@@ -9365,6 +9924,12 @@ public final class UserBitShared {
public Builder mergeFrom(org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile other) {
if (other == org.apache.drill.exec.proto.UserBitShared.MinorFragmentProfile.getDefaultInstance()) return this;
+ if (other.hasState()) {
+ setState(other.getState());
+ }
+ if (other.hasError()) {
+ mergeError(other.getError());
+ }
if (other.hasMinorFragmentId()) {
setMinorFragmentId(other.getMinorFragmentId());
}
@@ -9372,7 +9937,7 @@ public final class UserBitShared {
if (!other.operatorProfile_.isEmpty()) {
if (operatorProfile_.isEmpty()) {
operatorProfile_ = other.operatorProfile_;
- bitField0_ = (bitField0_ & ~0x00000002);
+ bitField0_ = (bitField0_ & ~0x00000008);
} else {
ensureOperatorProfileIsMutable();
operatorProfile_.addAll(other.operatorProfile_);
@@ -9385,7 +9950,7 @@ public final class UserBitShared {
operatorProfileBuilder_.dispose();
operatorProfileBuilder_ = null;
operatorProfile_ = other.operatorProfile_;
- bitField0_ = (bitField0_ & ~0x00000002);
+ bitField0_ = (bitField0_ & ~0x00000008);
operatorProfileBuilder_ =
com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders ?
getOperatorProfileFieldBuilder() : null;
@@ -9400,6 +9965,15 @@ public final class UserBitShared {
if (other.hasEndTime()) {
setEndTime(other.getEndTime());
}
+ if (other.hasMemoryUsed()) {
+ setMemoryUsed(other.getMemoryUsed());
+ }
+ if (other.hasMaxMemoryUsed()) {
+ setMaxMemoryUsed(other.getMaxMemoryUsed());
+ }
+ if (other.hasEndpoint()) {
+ mergeEndpoint(other.getEndpoint());
+ }
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
@@ -9427,46 +10001,199 @@ public final class UserBitShared {
}
private int bitField0_;
- // optional int32 minor_fragment_id = 1;
+ // optional .exec.shared.FragmentState state = 1;
+ private org.apache.drill.exec.proto.UserBitShared.FragmentState state_ = org.apache.drill.exec.proto.UserBitShared.FragmentState.SENDING;
+ /**
+ * <code>optional .exec.shared.FragmentState state = 1;</code>
+ */
+ public boolean hasState() {
+ return ((bitField0_ & 0x00000001) == 0x00000001);
+ }
+ /**
+ * <code>optional .exec.shared.FragmentState state = 1;</code>
+ */
+ public org.apache.drill.exec.proto.UserBitShared.FragmentState getState() {
+ return state_;
+ }
+ /**
+ * <code>optional .exec.shared.FragmentState state = 1;</code>
+ */
+ public Builder setState(org.apache.drill.exec.proto.UserBitShared.FragmentState value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ bitField0_ |= 0x00000001;
+ state_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * <code>optional .exec.shared.FragmentState state = 1;</code>
+ */
+ public Builder clearState() {
+ bitField0_ = (bitField0_ & ~0x00000001);
+ state_ = org.apache.drill.exec.proto.UserBitShared.FragmentState.SENDING;
+ onChanged();
+ return this;
+ }
+
+ // optional .exec.shared.DrillPBError error = 2;
+ private org.apache.drill.exec.proto.UserBitShared.DrillPBError error_ = org.apache.drill.exec.proto.UserBitShared.DrillPBError.getDefaultInstance();
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.drill.exec.proto.UserBitShared.DrillPBError, org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder, org.apache.drill.exec.proto.UserBitShared.DrillPBErrorOrBuilder> errorBuilder_;
+ /**
+ * <code>optional .exec.shared.DrillPBError error = 2;</code>
+ */
+ public boolean hasError() {
+ return ((bitField0_ & 0x00000002) == 0x00000002);
+ }
+ /**
+ * <code>optional .exec.shared.DrillPBError error = 2;</code>
+ */
+ public org.apache.drill.exec.proto.UserBitShared.DrillPBError getError() {
+ if (errorBuilder_ == null) {
+ return error_;
+ } else {
+ return errorBuilder_.getMessage();
+ }
+ }
+ /**
+ * <code>optional .exec.shared.DrillPBError error = 2;</code>
+ */
+ public Builder setError(org.apache.drill.exec.proto.UserBitShared.DrillPBError value) {
+ if (errorBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ error_ = value;
+ onChanged();
+ } else {
+ errorBuilder_.setMessage(value);
+ }
+ bitField0_ |= 0x00000002;
+ return this;
+ }
+ /**
+ * <code>optional .exec.shared.DrillPBError error = 2;</code>
+ */
+ public Builder setError(
+ org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder builderForValue) {
+ if (errorBuilder_ == null) {
+ error_ = builderForValue.build();
+ onChanged();
+ } else {
+ errorBuilder_.setMessage(builderForValue.build());
+ }
+ bitField0_ |= 0x00000002;
+ return this;
+ }
+ /**
+ * <code>optional .exec.shared.DrillPBError error = 2;</code>
+ */
+ public Builder mergeError(org.apache.drill.exec.proto.UserBitShared.DrillPBError value) {
+ if (errorBuilder_ == null) {
+ if (((bitField0_ & 0x00000002) == 0x00000002) &&
+ error_ != org.apache.drill.exec.proto.UserBitShared.DrillPBError.getDefaultInstance()) {
+ error_ =
+ org.apache.drill.exec.proto.UserBitShared.DrillPBError.newBuilder(error_).mergeFrom(value).buildPartial();
+ } else {
+ error_ = value;
+ }
+ onChanged();
+ } else {
+ errorBuilder_.mergeFrom(value);
+ }
+ bitField0_ |= 0x00000002;
+ return this;
+ }
+ /**
+ * <code>optional .exec.shared.DrillPBError error = 2;</code>
+ */
+ public Builder clearError() {
+ if (errorBuilder_ == null) {
+ error_ = org.apache.drill.exec.proto.UserBitShared.DrillPBError.getDefaultInstance();
+ onChanged();
+ } else {
+ errorBuilder_.clear();
+ }
+ bitField0_ = (bitField0_ & ~0x00000002);
+ return this;
+ }
+ /**
+ * <code>optional .exec.shared.DrillPBError error = 2;</code>
+ */
+ public org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder getErrorBuilder() {
+ bitField0_ |= 0x00000002;
+ onChanged();
+ return getErrorFieldBuilder().getBuilder();
+ }
+ /**
+ * <code>optional .exec.shared.DrillPBError error = 2;</code>
+ */
+ public org.apache.drill.exec.proto.UserBitShared.DrillPBErrorOrBuilder getErrorOrBuilder() {
+ if (errorBuilder_ != null) {
+ return errorBuilder_.getMessageOrBuilder();
+ } else {
+ return error_;
+ }
+ }
+ /**
+ * <code>optional .exec.shared.DrillPBError error = 2;</code>
+ */
+ private com.google.protobuf.SingleFieldBuilder<
+ 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.SingleFieldBuilder<
+ org.apache.drill.exec.proto.UserBitShared.DrillPBError, org.apache.drill.exec.proto.UserBitShared.DrillPBError.Builder, org.apache.drill.exec.proto.UserBitShared.DrillPBErrorOrBuilder>(
+ error_,
+ getParentForChildren(),
+ isClean());
+ error_ = null;
+ }
+ return errorBuilder_;
+ }
+
+ // optional int32 minor_fragment_id = 3;
private int minorFragmentId_ ;
/**
- * <code>optional int32 minor_fragment_id = 1;</code>
+ * <code>optional int32 minor_fragment_id = 3;</code>
*/
public boolean hasMinorFragmentId() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
+ return ((bitField0_ & 0x00000004) == 0x00000004);
}
/**
- * <code>optional int32 minor_fragment_id = 1;</code>
+ * <code>optional int32 minor_fragment_id = 3;</code>
*/
public int getMinorFragmentId() {
return minorFragmentId_;
}
/**
- * <code>optional int32 minor_fragment_id = 1;</code>
+ * <code>optional int32 minor_fragment_id = 3;</code>
*/
public Builder setMinorFragmentId(int value) {
- bitField0_ |= 0x00000001;
+ bitField0_ |= 0x00000004;
minorFragmentId_ = value;
onChanged();
return this;
}
/**
- * <code>optional int32 minor_fragment_id = 1;</code>
+ * <code>optional int32 minor_fragment_id = 3;</code>
*/
public Builder clearMinorFragmentId() {
- bitField0_ = (bitField0_ & ~0x00000001);
+ bitField0_ = (bitField0_ & ~0x00000004);
minorFragmentId_ = 0;
onChanged();
return this;
}
- // repeated .exec.shared.OperatorProfile operator_profile = 2;
+ // repeated .exec.shared.OperatorProfile operator_profile = 4;
private java.util.List<org.apache.drill.exec.proto.UserBitShared.OperatorProfile> operatorProfile_ =
java.util.Collections.emptyList();
private void ensureOperatorProfileIsMutable() {
- if (!((bitField0_ & 0x00000002) == 0x00000002)) {
+ if (!((bitField0_ & 0x00000008) == 0x00000008)) {
operatorProfile_ = new java.util.ArrayList<org.apache.drill.exec.proto.UserBitShared.OperatorProfile>(operatorProfile_);
- bitField0_ |= 0x00000002;
+ bitField0_ |= 0x00000008;
}
}
@@ -9474,7 +10201,7 @@ public final class UserBitShared {
org.apache.drill.exec.proto.UserBitShared.OperatorProfile, org.apache.drill.exec.proto.UserBitShared.OperatorProfile.Builder, org.apache.drill.exec.proto.UserBitShared.OperatorProfileOrBuilder> operatorProfileBuilder_;
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public java.util.List<org.apache.drill.exec.proto.UserBitShared.OperatorProfile> getOperatorProfileList() {
if (operatorProfileBuilder_ == null) {
@@ -9484,7 +10211,7 @@ public final class UserBitShared {
}
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public int getOperatorProfileCount() {
if (operatorProfileBuilder_ == null) {
@@ -9494,7 +10221,7 @@ public final class UserBitShared {
}
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public org.apache.drill.exec.proto.UserBitShared.OperatorProfile getOperatorProfile(int index) {
if (operatorProfileBuilder_ == null) {
@@ -9504,7 +10231,7 @@ public final class UserBitShared {
}
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public Builder setOperatorProfile(
int index, org.apache.drill.exec.proto.UserBitShared.OperatorProfile value) {
@@ -9521,7 +10248,7 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public Builder setOperatorProfile(
int index, org.apache.drill.exec.proto.UserBitShared.OperatorProfile.Builder builderForValue) {
@@ -9535,7 +10262,7 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public Builder addOperatorProfile(org.apache.drill.exec.proto.UserBitShared.OperatorProfile value) {
if (operatorProfileBuilder_ == null) {
@@ -9551,7 +10278,7 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public Builder addOperatorProfile(
int index, org.apache.drill.exec.proto.UserBitShared.OperatorProfile value) {
@@ -9568,7 +10295,7 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public Builder addOperatorProfile(
org.apache.drill.exec.proto.UserBitShared.OperatorProfile.Builder builderForValue) {
@@ -9582,7 +10309,7 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public Builder addOperatorProfile(
int index, org.apache.drill.exec.proto.UserBitShared.OperatorProfile.Builder builderForValue) {
@@ -9596,7 +10323,7 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public Builder addAllOperatorProfile(
java.lang.Iterable<? extends org.apache.drill.exec.proto.UserBitShared.OperatorProfile> values) {
@@ -9610,12 +10337,12 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public Builder clearOperatorProfile() {
if (operatorProfileBuilder_ == null) {
operatorProfile_ = java.util.Collections.emptyList();
- bitField0_ = (bitField0_ & ~0x00000002);
+ bitField0_ = (bitField0_ & ~0x00000008);
onChanged();
} else {
operatorProfileBuilder_.clear();
@@ -9623,7 +10350,7 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public Builder removeOperatorProfile(int index) {
if (operatorProfileBuilder_ == null) {
@@ -9636,14 +10363,14 @@ public final class UserBitShared {
return this;
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public org.apache.drill.exec.proto.UserBitShared.OperatorProfile.Builder getOperatorProfileBuilder(
int index) {
return getOperatorProfileFieldBuilder().getBuilder(index);
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public org.apache.drill.exec.proto.UserBitShared.OperatorProfileOrBuilder getOperatorProfileOrBuilder(
int index) {
@@ -9653,7 +10380,7 @@ public final class UserBitShared {
}
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public java.util.List<? extends org.apache.drill.exec.proto.UserBitShared.OperatorProfileOrBuilder>
getOperatorProfileOrBuilderList() {
@@ -9664,14 +10391,14 @@ public final class UserBitShared {
}
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public org.apache.drill.exec.proto.UserBitShared.OperatorProfile.Builder addOperatorProfileBuilder() {
return getOperatorProfileFieldBuilder().addBuilder(
org.apache.drill.exec.proto.UserBitShared.OperatorProfile.getDefaultInstance());
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public org.apache.drill.exec.proto.UserBitShared.OperatorProfile.Builder addOperatorProfileBuilder(
int index) {
@@ -9679,7 +10406,7 @@ public final class UserBitShared {
index, org.apache.drill.exec.proto.UserBitShared.OperatorProfile.getDefaultInstance());
}
/**
- * <code>repeated .exec.shared.OperatorProfile operator_profile = 2;</code>
+ * <code>repeated .exec.shared.OperatorProfile operator_profile = 4;</code>
*/
public java.util.List<org.apache.drill.exec.proto.UserBitShared.OperatorProfile.Builder>
getOperatorProfileBuilderList() {
@@ -9692,7 +10419,7 @@ public final class UserBitShared {
operatorProfileBuilder_ = new com.google.protobuf.RepeatedFieldBuilder<
org.apache.drill.exec.proto.UserBitShared.OperatorProfile, org.apache.drill.exec.proto.UserBitShared.OperatorProfile.Builder, org.apache.drill.exec.proto.UserBitShared.OperatorProfileOrBuilder>(
operatorProfile_,
- ((bitField0_ & 0x00000002) == 0x00000002),
+ ((bitField0_ & 0x00000008) == 0x00000008),
getParentForChildren(),
isClean());
operatorProfile_ = null;
@@ -9700,70 +10427,253 @@ public final class UserBitShared {
return operatorProfileBuilder_;
}
- // optional int64 start_time = 3;
+ // optional int64 start_time = 5;
private long startTime_ ;
/**
- * <code>optional int64 start_time = 3;</code>
+ * <code>optional int64 start_time = 5;</code>
*/
public boolean hasStartTime() {
- return ((bitField0_ & 0x00000004) == 0x00000004);
+ return ((bitField0_ & 0x00000010) == 0x00000010);
}
/**
- * <code>optional int64 start_time = 3;</code>
+ * <code>optional int64 start_time = 5;</code>
*/
public long getStartTime() {
return startTime_;
}
/**
- * <code>optional int64 start_time = 3;</code>
+ * <code>optional int64 start_time = 5;</code>
*/
public Builder setStartTime(long value) {
- bitField0_ |= 0x00000004;
+ bitField0_ |= 0x00000010;
startTime_ = value;
onChanged();
return this;
}
/**
- * <code>optional int64 start_time = 3;</code>
+ * <code>optional int64 start_time = 5;</code>
+ */
+ public Builder clearStartTime() {
+ bitField0_ = (bitField0_ & ~0x00000010);
+ startTime_ = 0L;
+ onChanged();
+ return this;
+ }
+
+ // optional int64 end_time = 6;
+ private long endTime_ ;
+ /**
+ * <code>optional int64 end_time = 6;</code>
+ */
+ public boolean hasEndTime() {
+ return ((bitField0_ & 0x00000020) == 0x00000020);
+ }
+ /**
+ * <code>optional int64 end_time = 6;</code>
+ */
+ public long getEndTime() {
+ return endTime_;
+ }
+ /**
+ * <code>optional int64 end_time = 6;</code>
+ */
+ public Builder setEndTime(long value) {
+ bitField0_ |= 0x00000020;
+ endTime_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * <code>optional int64 end_time = 6;</code>
+ */
+ public Builder clearEndTime() {
+ bitField0_ = (bitField0_ & ~0x00000020);
+ endTime_ = 0L;
+ onChanged();
+ return this;
+ }
+
+ // optional int64 memory_used = 7;
+ private long memoryUsed_ ;
+ /**
+ * <code>optional int64 memory_used = 7;</code>
+ */
+ public boolean hasMemoryUsed() {
+ return ((bitField0_ & 0x00000040) == 0x00000040);
+ }
+ /**
+ * <code>optional int64 memory_used = 7;</code>
+ */
+ public long getMemoryUsed() {
+ return memoryUsed_;
+ }
+ /**
+ * <code>optional int64 memory_used = 7;</code>
+ */
+ public Builder setMemoryUsed(long value) {
+ bitField0_ |= 0x00000040;
+ memoryUsed_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * <code>optional int64 memory_used = 7;</code>
+ */
+ public Builder clearMemoryUsed() {
+ bitField0_ = (bitField0_ & ~0x00000040);
+ memoryUsed_ = 0L;
+ onChanged();
+ return this;
+ }
+
+ // optional int64 max_memory_used = 8;
+ private long maxMemoryUsed_ ;
+ /**
+ * <code>optional int64 max_memory_used = 8;</code>
+ */
+ public boolean hasMaxMemoryUsed() {
+ return ((bitField0_ & 0x00000080) == 0x00000080);
+ }
+ /**
+ * <code>optional int64 max_memory_used = 8;</code>
+ */
+ public long getMaxMemoryUsed() {
+ return maxMemoryUsed_;
+ }
+ /**
+ * <code>optional int64 max_memory_used = 8;</code>
+ */
+ public Builder setMaxMemoryUsed(long value) {
+ bitField0_ |= 0x00000080;
+ maxMemoryUsed_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * <code>optional int64 max_memory_used = 8;</code>
+ */
+ public Builder clearMaxMemoryUsed() {
+ bitField0_ = (bitField0_ & ~0x00000080);
+ maxMemoryUsed_ = 0L;
+ onChanged();
+ return this;
+ }
+
+ // optional .exec.DrillbitEndpoint endpoint = 9;
+ private org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint endpoint_ = org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint.getDefaultInstance();
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint, org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint.Builder, org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpointOrBuilder> endpointBuilder_;
+ /**
+ * <code>optional .exec.DrillbitEndpoint endpoint = 9;</code>
+ */
+ public boolean hasEndpoint() {
+ return ((bitField0_ & 0x00000100) == 0x00000100);
+ }
+ /**
+ * <code>optional .exec.DrillbitEndpoint endpoint = 9;</code>
+ */
+ public org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint getEndpoint() {
+ if (endpointBuilder_ == null) {
+ return endpoint_;
+ } else {
+ return endpointBuilder_.getMessage();
+ }
+ }
+ /**
+ * <code>optional .exec.DrillbitEndpoint endpoint = 9;</code>
+ */
+ public Builder setEndpoint(org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint value) {
+ if (endpointBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ endpoint_ = value;
+ onChanged();
+ } else {
+ endpointBuilder_.setMessage(value);
+ }
+ bitField0_ |= 0x00000100;
+ return this;
+ }
+ /**
+ * <code>optional .exec.DrillbitEndpoint endpoint = 9;</code>
+ */
+ public Builder setEndpoint(
+ org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint.Builder builderForValue) {
+ if (endpointBuilder_ == null) {
+ endpoint_ = builderForValue.build();
+ onChanged();
+ } else {
+ endpointBuilder_.setMessage(builderForValue.build());
+ }
+ bitField0_ |= 0x00000100;
+ return this;
+ }
+ /**
+ * <code>optional .exec.DrillbitEndpoint endpoint = 9;</code>
*/
- public Builder clearStartTime() {
- bitField0_ = (bitField0_ & ~0x00000004);
- startTime_ = 0L;
- onChanged();
+ public Builder mergeEndpoint(org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint value) {
+ if (endpointBuilder_ == null) {
+ if (((bitField0_ & 0x00000100) == 0x00000100) &&
+ endpoint_ != org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint.getDefaultInstance()) {
+ endpoint_ =
+ org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint.newBuilder(endpoint_).mergeFrom(value).buildPartial();
+ } else {
+ endpoint_ = value;
+ }
+ onChanged();
+ } else {
+ endpointBuilder_.mergeFrom(value);
+ }
+ bitField0_ |= 0x00000100;
return this;
}
-
- // optional int64 end_time = 4;
- private long endTime_ ;
/**
- * <code>optional int64 end_time = 4;</code>
+ * <code>optional .exec.DrillbitEndpoint endpoint = 9;</code>
*/
- public boolean hasEndTime() {
- return ((bitField0_ & 0x00000008) == 0x00000008);
+ public Builder clearEndpoint() {
+ if (endpointBuilder_ == null) {
+ endpoint_ = org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint.getDefaultInstance();
+ onChanged();
+ } else {
+ endpointBuilder_.clear();
+ }
+ bitField0_ = (bitField0_ & ~0x00000100);
+ return this;
}
/**
- * <code>optional int64 end_time = 4;</code>
+ * <code>optional .exec.DrillbitEndpoint endpoint = 9;</code>
*/
- public long getEndTime() {
- return endTime_;
+ public org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint.Builder getEndpointBuilder() {
+ bitField0_ |= 0x00000100;
+ onChanged();
+ return getEndpointFieldBuilder().getBuilder();
}
/**
- * <code>optional int64 end_time = 4;</code>
+ * <code>optional .exec.DrillbitEndpoint endpoint = 9;</code>
*/
- public Builder setEndTime(long value) {
- bitField0_ |= 0x00000008;
- endTime_ = value;
- onChanged();
- return this;
+ public org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpointOrBuilder getEndpointOrBuilder() {
+ if (endpointBuilder_ != null) {
+ return endpointBuilder_.getMessageOrBuilder();
+ } else {
+ return endpoint_;
+ }
}
/**
- * <code>optional int64 end_time = 4;</code>
+ * <code>optional .exec.DrillbitEndpoint endpoint = 9;</code>
*/
- public Builder clearEndTime() {
- bitField0_ = (bitField0_ & ~0x00000008);
- endTime_ = 0L;
- onChanged();
- return this;
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint, org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint.Builder, org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpointOrBuilder>
+ getEndpointFieldBuilder() {
+ if (endpointBuilder_ == null) {
+ endpointBuilder_ = new com.google.protobuf.SingleFieldBuilder<
+ org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint, org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint.Builder, org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpointOrBuilder>(
+ endpoint_,
+ getParentForChildren(),
+ isClean());
+ endpoint_ = null;
+ }
+ return endpointBuilder_;
}
// @@protoc_insertion_point(builder_scope:exec.shared.MinorFragmentProfile)
@@ -9805,20 +10715,6 @@ public final class UserBitShared {
org.apache.drill.exec.proto.UserBitShared.StreamProfileOrBuilder getInputProfileOrBuilder(
int index);
- // optional .exec.shared.StreamProfile output_profile = 2;
- /**
- * <code>optional .exec.shared.StreamProfile output_profile = 2;</code>
- */
- boolean hasOutputProfile();
- /**
- * <code>optional .exec.shared.StreamProfile output_profile = 2;</code>
- */
- org.apache.drill.exec.proto.UserBitShared.StreamProfile getOutputProfile();
- /**
- * <code>optional .exec.shared.StreamProfile output_profile = 2;</code>
- */
- org.apache.drill.exec.proto.UserBitShared.StreamProfileOrBuilder getOutputProfileOrBuilder();
-
// optional int32 operator_id = 3;
/**
* <code>optional int32 operator_id = 3;</code>
@@ -9953,48 +10849,35 @@ public final class UserBitShared {
inputProfile_.add(input.readMessage(org.apache.drill.exec.proto.UserBitShared.StreamProfile.PARSER, extensionRegistry));
break;
}
- case 18: {
- org.apache.drill.exec.proto.UserBitShared.StreamProfile.Builder subBuilder = null;
- if (((bitField0_ & 0x00000001) == 0x00000001)) {
- subBuilder = outputProfile_.toBuilder();
- }
- outputProfile_ = input.readMessage(org.apache.drill.exec.proto.UserBitShared.StreamProfile.PARSER, extensionRegistry);
- if (subBuilder != null) {
- subBuilder.mergeFrom(outputProfile_);
- outputProfile_ = subBuilder.buildPartial();
- }
- bitField0_ |= 0x00000001;
- break;
- }
case 24: {
- bitField0_ |= 0x00000002;
+ bitField0_ |= 0x00000001;
operatorId_ = input.readInt32();
break;
}
case 32: {
- bitField0_ |= 0x00000004;
+ bitField0_ |= 0x00000002;
operatorType_ = input.readInt32();
break;
}
case 40: {
- bitField0_ |= 0x00000008;
+ bitField0_ |= 0x00000004;
setupNanos_ = input.readInt64();
break;
}
case 48: {
- bitField0_ |= 0x00000010;
+ bitField0_ |= 0x00000008;
processNanos_ = input.readInt64();
break;
}
case 56: {
- bitField0_ |= 0x00000020;
+ bitField0_ |= 0x00000010;
localMemoryAllocated_ = input.readInt64();
break;
}
case 66: {
- if (!((mutable_bitField0_ & 0x00000080) == 0x00000080)) {
+ if (!((mutable_bitField0_ & 0x00000040) == 0x00000040)) {
metric_ = new java.util.ArrayList<org.apache.drill.exec.proto.UserBitShared.MetricValue>();
- mutable_bitField0_ |= 0x00000080;
+ mutable_bitField0_ |= 0x00000040;
}
metric_.add(input.readMessage(org.apache.drill.exec.proto.UserBitShared.MetricValue.PARSER, extensionRegistry));
break;
@@ -10010,7 +10893,7 @@ public final class UserBitShared {
if (((mutable_bitField0_ & 0x00000001) == 0x00000001)) {
inputProfile_ = java.util.Collections.unmodifiableList(inputProfile_);
}
- if (((mutable_bitField0_ & 0x00000080) == 0x00000080)) {
+ if (((mutable_bitField0_ & 0x00000040) == 0x00000040)) {
metric_ = java.util.Collections.unmodifiableList(metric_);
}
this.unknownFields = unknownFields.build();
@@ -10081,28 +10964,6 @@ public final class UserBitShared {
return inputProfile_.get(index);
}
- // optional .exec.shared.StreamProfile output_profile = 2;
- public static final int OUTPUT_PROFILE_FIELD_NUMBER = 2;
- private org.apache.drill.exec.proto.UserBitShared.StreamProfile outputProfile_;
- /**
- * <code>optional .exec.shared.StreamProfile output_profile = 2;</code>
- */
- public boolean hasOutputProfile() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
- }
- /**
- * <code>optional .exec.shared.StreamProfile output_profile = 2;</code>
- */
- public org.apache.drill.exec.proto.UserBitShared.StreamProfile getOutputProfile() {
- return outputProfile_;
- }
- /**
- * <code>optional .exec.shared.StreamProfile output_profile = 2;</code>
- */
- public org.apache.drill.exec.proto.UserBitShared.StreamProfileOrBuilder getOutputProfileOrBuilder() {
- return outputProfile_;
- }
-
// optional int32 operator_id = 3;
public static final int OPERATOR_ID_FIELD_NUMBER = 3;
private int operatorId_;
@@ -10110,7 +10971,7 @@ public final class UserBitShared {
* <code>optional int32 operator_id = 3;</code>
*/
public boolean hasOperatorId() {
- return ((bitField0_ & 0x00000002) == 0x00000002);
+ return ((bitField0_ & 0x00000001) == 0x00000001);
}
/**
* <code>optional int32 operator_id = 3;</code>
@@ -10126,7 +10987,7 @@ public final class UserBitShared {
* <code>optional int32 operator_type = 4;</code>
*/
public boolean hasOperatorType() {
- return ((bitField0_ & 0x00000004) == 0x00000004);
+ return ((bitField0_ & 0x00000002) == 0x00000002);
}
/**
* <code>optional int32 operator_type = 4;</code>
@@ -10142,7 +11003,7 @@ public final class UserBitShared {
* <code>optional int64 setup_nanos = 5;</code>
*/
public boolean hasSetupNanos() {
- return ((bitField0_ & 0x00000008) == 0x00000008);
+ return ((bitField0_ & 0x00000004) == 0x00000004);
}
/**
* <code>optional int64 setup_nanos = 5;</code>
@@ -10158,7 +11019,7 @@ public final class UserBitShared {
* <code>optional int64 process_nanos = 6;</code>
*/
public boolean hasProcessNanos() {
- return ((bitField0_ & 0x00000010) == 0x00000010);
+ return ((bitField0_ & 0x00000008) == 0x00000008);
}
/**
* <code>optional int64 process_nanos = 6;</code>
@@ -10174,7 +11035,7 @@ public final class UserBitShared {
* <code>optional int64 local_memory_allocated = 7;</code>
*/
public boolean hasLocalMemoryAllocated() {
- return ((bitField0_ & 0x00000020) == 0x00000020);
+ return ((bitField0_ & 0x00000010) == 0x00000010);
}
/**
* <code>optional int64 local_memory_allocated = 7;</code>
@@ -10221,7 +11082,6 @@ public final class UserBitShared {
private void initFields() {
inputProfile_ = java.util.Collections.emptyList();
- outputProfile_ = org.apache.drill.exec.proto.UserBitShared.StreamProfile.getDefaultInstance();
operatorId_ = 0;
operatorType_ = 0;
setupNanos_ = 0L;
@@ -10245,21 +11105,18 @@ public final class UserBitShared {
output.writeMessage(1, inputProfile_.get(i));
}
if (((bitField0_ & 0x00000001) == 0x00000001)) {
- output.writeMessage(2, outputProfile_);
- }
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
output.writeInt32(3, operatorId_);
}
- if (((bitField0_ & 0x00000004) == 0x00000004)) {
+ if (((bitField0_ & 0x00000002) == 0x00000002)) {
output.writeInt32(4, operatorType_);
}
- if (((bitField0_ & 0x00000008) == 0x00000008)) {
+ if (((bitField0_ & 0x00000004) == 0x00000004)) {
output.writeInt64(5, setupNanos_);
}
- if (((bitField0_ & 0x00000010) == 0x00000010)) {
+ if (((bitField0_ & 0x00000008) == 0x00000008)) {
output.writeInt64(6, processNanos_);
}
- if (((bitField0_ & 0x00000020) == 0x00000020)) {
+ if (((bitField0_ & 0x00000010) == 0x00000010)) {
output.writeInt64(7, localMemoryAllocated_);
}
for (int i = 0; i < metric_.size(); i++) {
@@ -10280,25 +11137,21 @@ public final class UserBitShared {
}
if (((bitField0_ & 0x00000001) == 0x00000001)) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(2, outputProfile_);
- }
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
- size += com.google.protobuf.CodedOutputStream
.computeInt32Size(3, operatorId_);
}
- if (((bitField0_ & 0x00000004) == 0x00000004)) {
+ if (((bitField0_ & 0x00000002) == 0x00000002)) {
size += com.google.protobuf.CodedOutputStream
.computeInt
<TRUNCATED>