diff --git ql/if/queryplan.thrift ql/if/queryplan.thrift index dfc611f375..d7d7cdcf3c 100644 --- ql/if/queryplan.thrift +++ ql/if/queryplan.thrift @@ -107,6 +107,9 @@ enum StageType { REPL_TXN, REPL_INCREMENTAL_LOAD, SCHEDULED_QUERY_MAINT, + ACK, + RANGER_DUMP, + RANGER_LOAD } struct Stage { diff --git ql/src/gen/thrift/gen-cpp/queryplan_types.cpp ql/src/gen/thrift/gen-cpp/queryplan_types.cpp index e31bb5a7f5..00847d539c 100644 --- ql/src/gen/thrift/gen-cpp/queryplan_types.cpp +++ ql/src/gen/thrift/gen-cpp/queryplan_types.cpp @@ -123,7 +123,10 @@ int _kStageTypeValues[] = { StageType::REPL_STATE_LOG, StageType::REPL_TXN, StageType::REPL_INCREMENTAL_LOAD, - StageType::SCHEDULED_QUERY_MAINT + StageType::SCHEDULED_QUERY_MAINT, + StageType::ACK, + StageType::RANGER_DUMP, + StageType::RANGER_LOAD }; const char* _kStageTypeNames[] = { "CONDITIONAL", @@ -143,9 +146,12 @@ const char* _kStageTypeNames[] = { "REPL_STATE_LOG", "REPL_TXN", "REPL_INCREMENTAL_LOAD", - "SCHEDULED_QUERY_MAINT" + "SCHEDULED_QUERY_MAINT", + "ACK", + "RANGER_DUMP", + "RANGER_LOAD" }; -const std::map _StageType_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(18, _kStageTypeValues, _kStageTypeNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); +const std::map _StageType_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(21, _kStageTypeValues, _kStageTypeNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); Adjacency::~Adjacency() throw() { diff --git ql/src/gen/thrift/gen-cpp/queryplan_types.h ql/src/gen/thrift/gen-cpp/queryplan_types.h index b3f6a87be7..b3d9cf79d2 100644 --- ql/src/gen/thrift/gen-cpp/queryplan_types.h +++ ql/src/gen/thrift/gen-cpp/queryplan_types.h @@ -100,7 +100,10 @@ struct StageType { REPL_STATE_LOG = 14, REPL_TXN = 15, REPL_INCREMENTAL_LOAD = 16, - SCHEDULED_QUERY_MAINT = 17 + SCHEDULED_QUERY_MAINT = 17, + ACK = 18, + RANGER_DUMP = 19, + RANGER_LOAD = 20 }; }; diff --git ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/StageType.java ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/StageType.java index 57b028b711..31c3429038 100644 --- ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/StageType.java +++ ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/StageType.java @@ -7,6 +7,10 @@ package org.apache.hadoop.hive.ql.plan.api; +import java.util.Map; +import java.util.HashMap; +import org.apache.thrift.TEnum; + public enum StageType implements org.apache.thrift.TEnum { CONDITIONAL(0), COPY(1), @@ -32,7 +36,7 @@ private final int value; - StageType(int value) { + private StageType(int value) { this.value = value; } diff --git ql/src/gen/thrift/gen-php/Types.php ql/src/gen/thrift/gen-php/Types.php index d25c7964e9..d805d218f3 100644 --- ql/src/gen/thrift/gen-php/Types.php +++ ql/src/gen/thrift/gen-php/Types.php @@ -122,6 +122,9 @@ final class StageType { const REPL_TXN = 15; const REPL_INCREMENTAL_LOAD = 16; const SCHEDULED_QUERY_MAINT = 17; + const ACK = 18; + const RANGER_DUMP = 19; + const RANGER_LOAD = 20; static public $__names = array( 0 => 'CONDITIONAL', 1 => 'COPY', @@ -141,6 +144,9 @@ final class StageType { 15 => 'REPL_TXN', 16 => 'REPL_INCREMENTAL_LOAD', 17 => 'SCHEDULED_QUERY_MAINT', + 18 => 'ACK', + 19 => 'RANGER_DUMP', + 20 => 'RANGER_LOAD', ); } diff --git ql/src/gen/thrift/gen-py/queryplan/ttypes.py ql/src/gen/thrift/gen-py/queryplan/ttypes.py index b7313cf30f..33a53ce91f 100644 --- ql/src/gen/thrift/gen-py/queryplan/ttypes.py +++ ql/src/gen/thrift/gen-py/queryplan/ttypes.py @@ -169,6 +169,9 @@ class StageType: REPL_TXN = 15 REPL_INCREMENTAL_LOAD = 16 SCHEDULED_QUERY_MAINT = 17 + ACK = 18 + RANGER_DUMP = 19 + RANGER_LOAD = 20 _VALUES_TO_NAMES = { 0: "CONDITIONAL", @@ -189,6 +192,9 @@ class StageType: 15: "REPL_TXN", 16: "REPL_INCREMENTAL_LOAD", 17: "SCHEDULED_QUERY_MAINT", + 18: "ACK", + 19: "RANGER_DUMP", + 20: "RANGER_LOAD", } _NAMES_TO_VALUES = { @@ -210,6 +216,9 @@ class StageType: "REPL_TXN": 15, "REPL_INCREMENTAL_LOAD": 16, "SCHEDULED_QUERY_MAINT": 17, + "ACK": 18, + "RANGER_DUMP": 19, + "RANGER_LOAD": 20, } diff --git ql/src/gen/thrift/gen-rb/queryplan_types.rb ql/src/gen/thrift/gen-rb/queryplan_types.rb index e0d350a592..d31ba3c7a3 100644 --- ql/src/gen/thrift/gen-rb/queryplan_types.rb +++ ql/src/gen/thrift/gen-rb/queryplan_types.rb @@ -79,8 +79,11 @@ module StageType REPL_TXN = 15 REPL_INCREMENTAL_LOAD = 16 SCHEDULED_QUERY_MAINT = 17 - VALUE_MAP = {0 => "CONDITIONAL", 1 => "COPY", 2 => "DDL", 3 => "MAPRED", 4 => "EXPLAIN", 5 => "FETCH", 6 => "FUNC", 7 => "MAPREDLOCAL", 8 => "MOVE", 9 => "STATS", 10 => "DEPENDENCY_COLLECTION", 11 => "COLUMNSTATS", 12 => "REPL_DUMP", 13 => "REPL_BOOTSTRAP_LOAD", 14 => "REPL_STATE_LOG", 15 => "REPL_TXN", 16 => "REPL_INCREMENTAL_LOAD", 17 => "SCHEDULED_QUERY_MAINT"} - VALID_VALUES = Set.new([CONDITIONAL, COPY, DDL, MAPRED, EXPLAIN, FETCH, FUNC, MAPREDLOCAL, MOVE, STATS, DEPENDENCY_COLLECTION, COLUMNSTATS, REPL_DUMP, REPL_BOOTSTRAP_LOAD, REPL_STATE_LOG, REPL_TXN, REPL_INCREMENTAL_LOAD, SCHEDULED_QUERY_MAINT]).freeze + ACK = 18 + RANGER_DUMP = 19 + RANGER_LOAD = 20 + VALUE_MAP = {0 => "CONDITIONAL", 1 => "COPY", 2 => "DDL", 3 => "MAPRED", 4 => "EXPLAIN", 5 => "FETCH", 6 => "FUNC", 7 => "MAPREDLOCAL", 8 => "MOVE", 9 => "STATS", 10 => "DEPENDENCY_COLLECTION", 11 => "COLUMNSTATS", 12 => "REPL_DUMP", 13 => "REPL_BOOTSTRAP_LOAD", 14 => "REPL_STATE_LOG", 15 => "REPL_TXN", 16 => "REPL_INCREMENTAL_LOAD", 17 => "SCHEDULED_QUERY_MAINT", 18 => "ACK", 19 => "RANGER_DUMP", 20 => "RANGER_LOAD"} + VALID_VALUES = Set.new([CONDITIONAL, COPY, DDL, MAPRED, EXPLAIN, FETCH, FUNC, MAPREDLOCAL, MOVE, STATS, DEPENDENCY_COLLECTION, COLUMNSTATS, REPL_DUMP, REPL_BOOTSTRAP_LOAD, REPL_STATE_LOG, REPL_TXN, REPL_INCREMENTAL_LOAD, SCHEDULED_QUERY_MAINT, ACK, RANGER_DUMP, RANGER_LOAD]).freeze end class Adjacency