diff options
Diffstat (limited to 'protocol')
3 files changed, 19 insertions, 7 deletions
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 b1ba64373..1e63aca6e 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 @@ -643,6 +643,10 @@ public final class UserBitShared { * <code>STATISTICS_MERGE = 61;</code> */ STATISTICS_MERGE(61), + /** + * <code>LTSV_SUB_SCAN = 62;</code> + */ + LTSV_SUB_SCAN(62), ; /** @@ -893,6 +897,10 @@ public final class UserBitShared { * <code>STATISTICS_MERGE = 61;</code> */ public static final int STATISTICS_MERGE_VALUE = 61; + /** + * <code>LTSV_SUB_SCAN = 62;</code> + */ + public static final int LTSV_SUB_SCAN_VALUE = 62; public final int getNumber() { @@ -971,6 +979,7 @@ public final class UserBitShared { case 59: return STATISTICS_AGGREGATE; case 60: return UNPIVOT_MAPS; case 61: return STATISTICS_MERGE; + case 62: return LTSV_SUB_SCAN; default: return null; } } @@ -27783,7 +27792,7 @@ public final class UserBitShared { "entState\022\013\n\007SENDING\020\000\022\027\n\023AWAITING_ALLOCA" + "TION\020\001\022\013\n\007RUNNING\020\002\022\014\n\010FINISHED\020\003\022\r\n\tCAN" + "CELLED\020\004\022\n\n\006FAILED\020\005\022\032\n\026CANCELLATION_REQ" + - "UESTED\020\006*\351\t\n\020CoreOperatorType\022\021\n\rSINGLE_" + + "UESTED\020\006*\374\t\n\020CoreOperatorType\022\021\n\rSINGLE_" + "SENDER\020\000\022\024\n\020BROADCAST_SENDER\020\001\022\n\n\006FILTER" + "\020\002\022\022\n\016HASH_AGGREGATE\020\003\022\r\n\tHASH_JOIN\020\004\022\016\n" + "\nMERGE_JOIN\020\005\022\031\n\025HASH_PARTITION_SENDER\020\006" + @@ -27814,11 +27823,11 @@ public final class UserBitShared { "T\0206\022\023\n\017PCAPNG_SUB_SCAN\0207\022\022\n\016RUNTIME_FILT" + "ER\0208\022\017\n\013ROWKEY_JOIN\0209\022\023\n\017SYSLOG_SUB_SCAN" + "\020:\022\030\n\024STATISTICS_AGGREGATE\020;\022\020\n\014UNPIVOT_" + - "MAPS\020<\022\024\n\020STATISTICS_MERGE\020=*g\n\nSaslStat" + - "us\022\020\n\014SASL_UNKNOWN\020\000\022\016\n\nSASL_START\020\001\022\024\n\020" + - "SASL_IN_PROGRESS\020\002\022\020\n\014SASL_SUCCESS\020\003\022\017\n\013" + - "SASL_FAILED\020\004B.\n\033org.apache.drill.exec.p" + - "rotoB\rUserBitSharedH\001" + "MAPS\020<\022\024\n\020STATISTICS_MERGE\020=\022\021\n\rLTSV_SUB" + + "_SCAN\020>*g\n\nSaslStatus\022\020\n\014SASL_UNKNOWN\020\000\022" + + "\016\n\nSASL_START\020\001\022\024\n\020SASL_IN_PROGRESS\020\002\022\020\n" + + "\014SASL_SUCCESS\020\003\022\017\n\013SASL_FAILED\020\004B.\n\033org." + + "apache.drill.exec.protoB\rUserBitSharedH\001" }; com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() { diff --git a/protocol/src/main/java/org/apache/drill/exec/proto/beans/CoreOperatorType.java b/protocol/src/main/java/org/apache/drill/exec/proto/beans/CoreOperatorType.java index 6b277b4ac..eea96ca39 100644 --- a/protocol/src/main/java/org/apache/drill/exec/proto/beans/CoreOperatorType.java +++ b/protocol/src/main/java/org/apache/drill/exec/proto/beans/CoreOperatorType.java @@ -83,7 +83,8 @@ public enum CoreOperatorType implements com.dyuproject.protostuff.EnumLite<CoreO SYSLOG_SUB_SCAN(58), STATISTICS_AGGREGATE(59), UNPIVOT_MAPS(60), - STATISTICS_MERGE(61); + STATISTICS_MERGE(61), + LTSV_SUB_SCAN(62); public final int number; @@ -163,6 +164,7 @@ public enum CoreOperatorType implements com.dyuproject.protostuff.EnumLite<CoreO case 59: return STATISTICS_AGGREGATE; case 60: return UNPIVOT_MAPS; case 61: return STATISTICS_MERGE; + case 62: return LTSV_SUB_SCAN; default: return null; } } diff --git a/protocol/src/main/protobuf/UserBitShared.proto b/protocol/src/main/protobuf/UserBitShared.proto index 30c612ca3..37453feb8 100644 --- a/protocol/src/main/protobuf/UserBitShared.proto +++ b/protocol/src/main/protobuf/UserBitShared.proto @@ -354,6 +354,7 @@ enum CoreOperatorType { STATISTICS_AGGREGATE = 59; UNPIVOT_MAPS = 60; STATISTICS_MERGE = 61; + LTSV_SUB_SCAN = 62; } /* Registry that contains list of jars, each jar contains its name and list of function signatures. |