diff options
Diffstat (limited to 'protocol/src/main/java/org/apache/drill/exec/proto/ExecProtos.java')
| -rw-r--r-- | protocol/src/main/java/org/apache/drill/exec/proto/ExecProtos.java | 502 |
1 files changed, 500 insertions, 2 deletions
diff --git a/protocol/src/main/java/org/apache/drill/exec/proto/ExecProtos.java b/protocol/src/main/java/org/apache/drill/exec/proto/ExecProtos.java index 5b986cf52..acfdcb73b 100644 --- a/protocol/src/main/java/org/apache/drill/exec/proto/ExecProtos.java +++ b/protocol/src/main/java/org/apache/drill/exec/proto/ExecProtos.java @@ -886,11 +886,501 @@ public final class ExecProtos { // @@protoc_insertion_point(class_scope:exec.bit.FragmentHandle) } + public interface ServerPreparedStatementStateOrBuilder + extends com.google.protobuf.MessageOrBuilder { + + // optional string sql_query = 1; + /** + * <code>optional string sql_query = 1;</code> + */ + boolean hasSqlQuery(); + /** + * <code>optional string sql_query = 1;</code> + */ + java.lang.String getSqlQuery(); + /** + * <code>optional string sql_query = 1;</code> + */ + com.google.protobuf.ByteString + getSqlQueryBytes(); + } + /** + * Protobuf type {@code exec.bit.ServerPreparedStatementState} + * + * <pre> + * + * Prepared statement state on server side. Clients do not + * need to know the contents. They just need to submit it back to + * server when executing the prepared statement. + * </pre> + */ + public static final class ServerPreparedStatementState extends + com.google.protobuf.GeneratedMessage + implements ServerPreparedStatementStateOrBuilder { + // Use ServerPreparedStatementState.newBuilder() to construct. + private ServerPreparedStatementState(com.google.protobuf.GeneratedMessage.Builder<?> builder) { + super(builder); + this.unknownFields = builder.getUnknownFields(); + } + private ServerPreparedStatementState(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } + + private static final ServerPreparedStatementState defaultInstance; + public static ServerPreparedStatementState getDefaultInstance() { + return defaultInstance; + } + + public ServerPreparedStatementState getDefaultInstanceForType() { + return defaultInstance; + } + + private final com.google.protobuf.UnknownFieldSet unknownFields; + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private ServerPreparedStatementState( + 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 10: { + bitField0_ |= 0x00000001; + sqlQuery_ = input.readBytes(); + 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.ExecProtos.internal_static_exec_bit_ServerPreparedStatementState_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.drill.exec.proto.ExecProtos.internal_static_exec_bit_ServerPreparedStatementState_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState.class, org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState.Builder.class); + } + + public static com.google.protobuf.Parser<ServerPreparedStatementState> PARSER = + new com.google.protobuf.AbstractParser<ServerPreparedStatementState>() { + public ServerPreparedStatementState parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new ServerPreparedStatementState(input, extensionRegistry); + } + }; + + @java.lang.Override + public com.google.protobuf.Parser<ServerPreparedStatementState> getParserForType() { + return PARSER; + } + + private int bitField0_; + // optional string sql_query = 1; + public static final int SQL_QUERY_FIELD_NUMBER = 1; + private java.lang.Object sqlQuery_; + /** + * <code>optional string sql_query = 1;</code> + */ + public boolean hasSqlQuery() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>optional string sql_query = 1;</code> + */ + public java.lang.String getSqlQuery() { + java.lang.Object ref = sqlQuery_; + 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()) { + sqlQuery_ = s; + } + return s; + } + } + /** + * <code>optional string sql_query = 1;</code> + */ + public com.google.protobuf.ByteString + getSqlQueryBytes() { + java.lang.Object ref = sqlQuery_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + sqlQuery_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private void initFields() { + sqlQuery_ = ""; + } + 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.writeBytes(1, getSqlQueryBytes()); + } + 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 + .computeBytesSize(1, getSqlQueryBytes()); + } + 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.ExecProtos.ServerPreparedStatementState parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState 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.ExecProtos.ServerPreparedStatementState parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState 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.ExecProtos.ServerPreparedStatementState parseFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState 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.ExecProtos.ServerPreparedStatementState parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input); + } + public static org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState 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.ExecProtos.ServerPreparedStatementState parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState 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.ExecProtos.ServerPreparedStatementState 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.bit.ServerPreparedStatementState} + * + * <pre> + * + * Prepared statement state on server side. Clients do not + * need to know the contents. They just need to submit it back to + * server when executing the prepared statement. + * </pre> + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessage.Builder<Builder> + implements org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementStateOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.drill.exec.proto.ExecProtos.internal_static_exec_bit_ServerPreparedStatementState_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.drill.exec.proto.ExecProtos.internal_static_exec_bit_ServerPreparedStatementState_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState.class, org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState.Builder.class); + } + + // Construct using org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState.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(); + sqlQuery_ = ""; + bitField0_ = (bitField0_ & ~0x00000001); + return this; + } + + public Builder clone() { + return create().mergeFrom(buildPartial()); + } + + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return org.apache.drill.exec.proto.ExecProtos.internal_static_exec_bit_ServerPreparedStatementState_descriptor; + } + + public org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState getDefaultInstanceForType() { + return org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState.getDefaultInstance(); + } + + public org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState build() { + org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + public org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState buildPartial() { + org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState result = new org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState(this); + int from_bitField0_ = bitField0_; + int to_bitField0_ = 0; + if (((from_bitField0_ & 0x00000001) == 0x00000001)) { + to_bitField0_ |= 0x00000001; + } + result.sqlQuery_ = sqlQuery_; + result.bitField0_ = to_bitField0_; + onBuilt(); + return result; + } + + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState) { + return mergeFrom((org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState other) { + if (other == org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState.getDefaultInstance()) return this; + if (other.hasSqlQuery()) { + bitField0_ |= 0x00000001; + sqlQuery_ = other.sqlQuery_; + onChanged(); + } + 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.ExecProtos.ServerPreparedStatementState parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (org.apache.drill.exec.proto.ExecProtos.ServerPreparedStatementState) e.getUnfinishedMessage(); + throw e; + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + private int bitField0_; + + // optional string sql_query = 1; + private java.lang.Object sqlQuery_ = ""; + /** + * <code>optional string sql_query = 1;</code> + */ + public boolean hasSqlQuery() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>optional string sql_query = 1;</code> + */ + public java.lang.String getSqlQuery() { + java.lang.Object ref = sqlQuery_; + if (!(ref instanceof java.lang.String)) { + java.lang.String s = ((com.google.protobuf.ByteString) ref) + .toStringUtf8(); + sqlQuery_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>optional string sql_query = 1;</code> + */ + public com.google.protobuf.ByteString + getSqlQueryBytes() { + java.lang.Object ref = sqlQuery_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + sqlQuery_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>optional string sql_query = 1;</code> + */ + public Builder setSqlQuery( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000001; + sqlQuery_ = value; + onChanged(); + return this; + } + /** + * <code>optional string sql_query = 1;</code> + */ + public Builder clearSqlQuery() { + bitField0_ = (bitField0_ & ~0x00000001); + sqlQuery_ = getDefaultInstance().getSqlQuery(); + onChanged(); + return this; + } + /** + * <code>optional string sql_query = 1;</code> + */ + public Builder setSqlQueryBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000001; + sqlQuery_ = value; + onChanged(); + return this; + } + + // @@protoc_insertion_point(builder_scope:exec.bit.ServerPreparedStatementState) + } + + static { + defaultInstance = new ServerPreparedStatementState(true); + defaultInstance.initFields(); + } + + // @@protoc_insertion_point(class_scope:exec.bit.ServerPreparedStatementState) + } + private static com.google.protobuf.Descriptors.Descriptor internal_static_exec_bit_FragmentHandle_descriptor; private static com.google.protobuf.GeneratedMessage.FieldAccessorTable internal_static_exec_bit_FragmentHandle_fieldAccessorTable; + private static com.google.protobuf.Descriptors.Descriptor + internal_static_exec_bit_ServerPreparedStatementState_descriptor; + private static + com.google.protobuf.GeneratedMessage.FieldAccessorTable + internal_static_exec_bit_ServerPreparedStatementState_fieldAccessorTable; public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { @@ -905,8 +1395,10 @@ public final class ExecProtos { "ragmentHandle\022&\n\010query_id\030\001 \001(\0132\024.exec.s" + "hared.QueryId\022\031\n\021major_fragment_id\030\002 \001(\005" + "\022\031\n\021minor_fragment_id\030\003 \001(\005\022-\n\017parent_qu" + - "ery_id\030\004 \001(\0132\024.exec.shared.QueryIdB+\n\033or" + - "g.apache.drill.exec.protoB\nExecProtosH\001" + "ery_id\030\004 \001(\0132\024.exec.shared.QueryId\"1\n\034Se" + + "rverPreparedStatementState\022\021\n\tsql_query\030" + + "\001 \001(\tB+\n\033org.apache.drill.exec.protoB\nEx" + + "ecProtosH\001" }; com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { @@ -919,6 +1411,12 @@ public final class ExecProtos { com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_exec_bit_FragmentHandle_descriptor, new java.lang.String[] { "QueryId", "MajorFragmentId", "MinorFragmentId", "ParentQueryId", }); + internal_static_exec_bit_ServerPreparedStatementState_descriptor = + getDescriptor().getMessageTypes().get(1); + internal_static_exec_bit_ServerPreparedStatementState_fieldAccessorTable = new + com.google.protobuf.GeneratedMessage.FieldAccessorTable( + internal_static_exec_bit_ServerPreparedStatementState_descriptor, + new java.lang.String[] { "SqlQuery", }); return null; } }; |