Index: ql/if/queryplan.thrift =================================================================== --- ql/if/queryplan.thrift (revision 4355) +++ ql/if/queryplan.thrift (working copy) @@ -16,7 +16,7 @@ } #Represents a operator along with its counters -enum OperatorType { JOIN, MAPJOIN, EXTRACT, FILTER, FORWARD, GROUPBY, LIMIT, SCRIPT, SELECT, TABLESCAN, FILESINK, REDUCESINK, UNION } +enum OperatorType { JOIN, MAPJOIN, EXTRACT, FILTER, FORWARD, GROUPBY, LIMIT, SCRIPT, SELECT, TABLESCAN, FILESINK, REDUCESINK, UNION, UDTF } struct Operator { 1: string operatorId, 2: OperatorType operatorType, @@ -53,7 +53,7 @@ 7: bool started, } -# Represents a query - +# Represents a query - # The graph maintains the stage dependency.In case of conditional tasks, it is represented as if only # one of the dependencies need to be executed struct Query { Index: ql/src/gen-php/queryplan_types.php =================================================================== --- ql/src/gen-php/queryplan_types.php (revision 4355) +++ ql/src/gen-php/queryplan_types.php (working copy) @@ -49,6 +49,7 @@ 'FILESINK' => 10, 'REDUCESINK' => 11, 'UNION' => 12, + 'UDTF' => 13, ); final class OperatorType { @@ -65,6 +66,7 @@ const FILESINK = 10; const REDUCESINK = 11; const UNION = 12; + const UDTF = 13; static public $__names = array( 0 => 'JOIN', 1 => 'MAPJOIN', @@ -79,6 +81,7 @@ 10 => 'FILESINK', 11 => 'REDUCESINK', 12 => 'UNION', + 13 => 'UDTF', ); } Index: ql/src/gen-javabean/org/apache/hadoop/hive/ql/plan/api/OperatorType.java =================================================================== --- ql/src/gen-javabean/org/apache/hadoop/hive/ql/plan/api/OperatorType.java (revision 4355) +++ ql/src/gen-javabean/org/apache/hadoop/hive/ql/plan/api/OperatorType.java (working copy) @@ -27,6 +27,7 @@ public static final int FILESINK = 10; public static final int REDUCESINK = 11; public static final int UNION = 12; + public static final int UDTF = 13; public static final IntRangeSet VALID_VALUES = new IntRangeSet( JOIN, @@ -41,7 +42,8 @@ TABLESCAN, FILESINK, REDUCESINK, - UNION ); + UNION, + UDTF ); public static final Map VALUES_TO_NAMES = new HashMap() {{ put(JOIN, "JOIN"); @@ -57,5 +59,6 @@ put(FILESINK, "FILESINK"); put(REDUCESINK, "REDUCESINK"); put(UNION, "UNION"); + put(UDTF, "UDTF"); }}; } Index: ql/src/gen-py/queryplan/ttypes.py =================================================================== --- ql/src/gen-py/queryplan/ttypes.py (revision 4355) +++ ql/src/gen-py/queryplan/ttypes.py (working copy) @@ -36,6 +36,7 @@ FILESINK = 10 REDUCESINK = 11 UNION = 12 + UDTF = 13 class TaskType: MAP = 0