diff options
Diffstat (limited to 'protocol/src')
3 files changed, 31 insertions, 6 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 c540c8f2a..635f972d9 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 @@ -601,6 +601,14 @@ public final class UserBitShared { * <code>SYSLOG_SUB_SCAN = 58;</code> */ SYSLOG_SUB_SCAN(58, 58), + /** + * <code>STATISTICS_AGGREGATE = 59;</code> + */ + STATISTICS_AGGREGATE(59, 59), + /** + * <code>UNPIVOT_MAPS = 60;</code> + */ + UNPIVOT_MAPS(60, 60), ; /** @@ -839,6 +847,14 @@ public final class UserBitShared { * <code>SYSLOG_SUB_SCAN = 58;</code> */ public static final int SYSLOG_SUB_SCAN_VALUE = 58; + /** + * <code>STATISTICS_AGGREGATE = 59;</code> + */ + public static final int STATISTICS_AGGREGATE_VALUE = 59; + /** + * <code>UNPIVOT_MAPS = 60;</code> + */ + public static final int UNPIVOT_MAPS_VALUE = 60; public final int getNumber() { return value; } @@ -904,6 +920,8 @@ public final class UserBitShared { case 56: return RUNTIME_FILTER; case 57: return ROWKEY_JOIN; case 58: return SYSLOG_SUB_SCAN; + case 59: return STATISTICS_AGGREGATE; + case 60: return UNPIVOT_MAPS; default: return null; } } @@ -24644,7 +24662,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*\247\t\n\020CoreOperatorType\022\021\n\rSINGLE_" + + "UESTED\020\006*\323\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" + @@ -24674,10 +24692,11 @@ public final class UserBitShared { "\025\n\021SEQUENCE_SUB_SCAN\0205\022\023\n\017PARTITION_LIMI" + "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:*g\n\nSaslStatus\022\020\n\014SASL_UNKNOWN\020\000\022\016\n\nSA" + - "SL_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.apach" + - "e.drill.exec.protoB\rUserBitSharedH\001" + "\020:\022\030\n\024STATISTICS_AGGREGATE\020;\022\020\n\014UNPIVOT_" + + "MAPS\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\014" + + "SASL_SUCCESS\020\003\022\017\n\013SASL_FAILED\020\004B.\n\033org.a" + + "pache.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 7d5041c5b..051f82f2e 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 @@ -80,7 +80,9 @@ public enum CoreOperatorType implements com.dyuproject.protostuff.EnumLite<CoreO PCAPNG_SUB_SCAN(55), RUNTIME_FILTER(56), ROWKEY_JOIN(57), - SYSLOG_SUB_SCAN(58); + SYSLOG_SUB_SCAN(58), + STATISTICS_AGGREGATE(59), + UNPIVOT_MAPS(60); public final int number; @@ -157,6 +159,8 @@ public enum CoreOperatorType implements com.dyuproject.protostuff.EnumLite<CoreO case 56: return RUNTIME_FILTER; case 57: return ROWKEY_JOIN; case 58: return SYSLOG_SUB_SCAN; + case 59: return STATISTICS_AGGREGATE; + case 60: return UNPIVOT_MAPS; default: return null; } } diff --git a/protocol/src/main/protobuf/UserBitShared.proto b/protocol/src/main/protobuf/UserBitShared.proto index a0438b7bf..ca4e27385 100644 --- a/protocol/src/main/protobuf/UserBitShared.proto +++ b/protocol/src/main/protobuf/UserBitShared.proto @@ -351,6 +351,8 @@ enum CoreOperatorType { RUNTIME_FILTER = 56; ROWKEY_JOIN = 57; SYSLOG_SUB_SCAN = 58; + STATISTICS_AGGREGATE = 59; + UNPIVOT_MAPS = 60; } /* Registry that contains list of jars, each jar contains its name and list of function signatures. |