ql/src/test/results/clientpositive/spark/mapjoin1.q.out

   1 PREHOOK: query: SELECT  /*+ MAPJOIN(b) */ sum(a.key) as sum_a
   2     FROM srcpart a
   3     JOIN src b ON a.key = b.key where a.ds is not null
   4 PREHOOK: type: QUERY
   5 PREHOOK: Input: default@src
   6 PREHOOK: Input: default@srcpart
   7 PREHOOK: Input: default@srcpart@ds=2008-04-08/hr=11
   8 PREHOOK: Input: default@srcpart@ds=2008-04-08/hr=12
   9 PREHOOK: Input: default@srcpart@ds=2008-04-09/hr=11
  10 PREHOOK: Input: default@srcpart@ds=2008-04-09/hr=12
  11 #### A masked pattern was here ####
  12 POSTHOOK: query: SELECT  /*+ MAPJOIN(b) */ sum(a.key) as sum_a
  13     FROM srcpart a
  14     JOIN src b ON a.key = b.key where a.ds is not null
  15 POSTHOOK: type: QUERY
  16 POSTHOOK: Input: default@src
  17 POSTHOOK: Input: default@srcpart
  18 POSTHOOK: Input: default@srcpart@ds=2008-04-08/hr=11
  19 POSTHOOK: Input: default@srcpart@ds=2008-04-08/hr=12
  20 POSTHOOK: Input: default@srcpart@ds=2008-04-09/hr=11
  21 POSTHOOK: Input: default@srcpart@ds=2008-04-09/hr=12
  22 #### A masked pattern was here ####
  23 1114788.0
  24 PREHOOK: query: EXPLAIN
  25 SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN src b on a.key=b.key AND true limit 10
  26 PREHOOK: type: QUERY
  27 POSTHOOK: query: EXPLAIN
  28 SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN src b on a.key=b.key AND true limit 10
  29 POSTHOOK: type: QUERY
  30 STAGE DEPENDENCIES:
  31   Stage-2 is a root stage
  32   Stage-1 depends on stages: Stage-2
  33   Stage-0 depends on stages: Stage-1
  34
  35 STAGE PLANS:
  36   Stage: Stage-2
  37     Spark
  38 #### A masked pattern was here ####
  39       Vertices:
  40         Map 1
  41             Map Operator Tree:
  42                 TableScan
  43                   alias: a
  44                   Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
  45                   Select Operator
  46                     expressions: key (type: string), value (type: string)
  47                     outputColumnNames: _col0, _col1
  48                     Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
  49                     Spark HashTable Sink Operator
  50                       keys:
  51                         0 _col0 (type: string)
  52                         1 _col0 (type: string)
  53             Local Work:
  54               Map Reduce Local Work
  55
  56   Stage: Stage-1
  57     Spark
  58 #### A masked pattern was here ####
  59       Vertices:
  60         Map 2
  61             Map Operator Tree:
  62                 TableScan
  63                   alias: b
  64                   Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
  65                   Select Operator
  66                     expressions: key (type: string), value (type: string)
  67                     outputColumnNames: _col0, _col1
  68                     Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
  69                     Map Join Operator
  70                       condition map:
  71                            Right Outer Join 0 to 1
  72                       keys:
  73                         0 _col0 (type: string)
  74                         1 _col0 (type: string)
  75                       outputColumnNames: _col0, _col1, _col2, _col3
  76                       input vertices:
  77                         0 Map 1
  78                       Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE
  79                       Limit
  80                         Number of rows: 10
  81                         Statistics: Num rows: 10 Data size: 100 Basic stats: COMPLETE Column stats: NONE
  82                         File Output Operator
  83                           compressed: false
  84                           Statistics: Num rows: 10 Data size: 100 Basic stats: COMPLETE Column stats: NONE
  85                           table:
  86                               input format: org.apache.hadoop.mapred.SequenceFileInputFormat
  87                               output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
  88                               serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
  89             Local Work:
  90               Map Reduce Local Work
  91
  92   Stage: Stage-0
  93     Fetch Operator
  94       limit: 10
  95       Processor Tree:
  96         ListSink
  97
  98 PREHOOK: query: SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN src b on a.key=b.key AND true limit 10
  99 PREHOOK: type: QUERY
 100 PREHOOK: Input: default@src
 101 #### A masked pattern was here ####
 102 POSTHOOK: query: SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN src b on a.key=b.key AND true limit 10
 103 POSTHOOK: type: QUERY
 104 POSTHOOK: Input: default@src
 105 #### A masked pattern was here ####
 106 238     val_238 238     val_238
 107 238     val_238 238     val_238
 108 86      val_86  86      val_86
 109 311     val_311 311     val_311
 110 311     val_311 311     val_311
 111 311     val_311 311     val_311
 112 27      val_27  27      val_27
 113 165     val_165 165     val_165
 114 165     val_165 165     val_165
 115 409     val_409 409     val_409
 116 PREHOOK: query: EXPLAIN
 117 SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN src b on a.key=b.key AND b.key * 10 < '1000' limit 10
 118 PREHOOK: type: QUERY
 119 POSTHOOK: query: EXPLAIN
 120 SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN src b on a.key=b.key AND b.key * 10 < '1000' limit 10
 121 POSTHOOK: type: QUERY
 122 STAGE DEPENDENCIES:
 123   Stage-2 is a root stage
 124   Stage-1 depends on stages: Stage-2
 125   Stage-0 depends on stages: Stage-1
 126
 127 STAGE PLANS:
 128   Stage: Stage-2
 129     Spark
 130 #### A masked pattern was here ####
 131       Vertices:
 132         Map 1
 133             Map Operator Tree:
 134                 TableScan
 135                   alias: a
 136                   Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 137                   Select Operator
 138                     expressions: key (type: string), value (type: string)
 139                     outputColumnNames: _col0, _col1
 140                     Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 141                     Spark HashTable Sink Operator
 142                       filter predicates:
 143                         0
 144                         1 {((UDFToDouble(_col0) * 10.0D) < 1000.0D)}
 145                       keys:
 146                         0 _col0 (type: string)
 147                         1 _col0 (type: string)
 148             Local Work:
 149               Map Reduce Local Work
 150
 151   Stage: Stage-1
 152     Spark
 153 #### A masked pattern was here ####
 154       Vertices:
 155         Map 2
 156             Map Operator Tree:
 157                 TableScan
 158                   alias: b
 159                   Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 160                   Select Operator
 161                     expressions: key (type: string), value (type: string)
 162                     outputColumnNames: _col0, _col1
 163                     Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 164                     Map Join Operator
 165                       condition map:
 166                            Right Outer Join 0 to 1
 167                       filter predicates:
 168                         0
 169                         1 {((UDFToDouble(_col0) * 10.0D) < 1000.0D)}
 170                       keys:
 171                         0 _col0 (type: string)
 172                         1 _col0 (type: string)
 173                       outputColumnNames: _col0, _col1, _col2, _col3
 174                       input vertices:
 175                         0 Map 1
 176                       Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE
 177                       Limit
 178                         Number of rows: 10
 179                         Statistics: Num rows: 10 Data size: 100 Basic stats: COMPLETE Column stats: NONE
 180                         File Output Operator
 181                           compressed: false
 182                           Statistics: Num rows: 10 Data size: 100 Basic stats: COMPLETE Column stats: NONE
 183                           table:
 184                               input format: org.apache.hadoop.mapred.SequenceFileInputFormat
 185                               output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
 186                               serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
 187             Local Work:
 188               Map Reduce Local Work
 189
 190   Stage: Stage-0
 191     Fetch Operator
 192       limit: 10
 193       Processor Tree:
 194         ListSink
 195
 196 PREHOOK: query: SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN src b on a.key=b.key AND b.key * 10 < '1000' limit 10
 197 PREHOOK: type: QUERY
 198 PREHOOK: Input: default@src
 199 #### A masked pattern was here ####
 200 POSTHOOK: query: SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN src b on a.key=b.key AND b.key * 10 < '1000' limit 10
 201 POSTHOOK: type: QUERY
 202 POSTHOOK: Input: default@src
 203 #### A masked pattern was here ####
 204 NULL    NULL    238     val_238
 205 86      val_86  86      val_86
 206 NULL    NULL    311     val_311
 207 27      val_27  27      val_27
 208 NULL    NULL    165     val_165
 209 NULL    NULL    409     val_409
 210 NULL    NULL    255     val_255
 211 NULL    NULL    278     val_278
 212 98      val_98  98      val_98
 213 98      val_98  98      val_98
 214 PREHOOK: query: EXPLAIN
 215 SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN
 216     (select key, named_struct('key', key, 'value', value) as kv from src) b on a.key=b.key AND b.kv.key > 200 limit 10
 217 PREHOOK: type: QUERY
 218 POSTHOOK: query: EXPLAIN
 219 SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN
 220     (select key, named_struct('key', key, 'value', value) as kv from src) b on a.key=b.key AND b.kv.key > 200 limit 10
 221 POSTHOOK: type: QUERY
 222 STAGE DEPENDENCIES:
 223   Stage-2 is a root stage
 224   Stage-1 depends on stages: Stage-2
 225   Stage-0 depends on stages: Stage-1
 226
 227 STAGE PLANS:
 228   Stage: Stage-2
 229     Spark
 230 #### A masked pattern was here ####
 231       Vertices:
 232         Map 1
 233             Map Operator Tree:
 234                 TableScan
 235                   alias: a
 236                   Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 237                   Select Operator
 238                     expressions: key (type: string), value (type: string)
 239                     outputColumnNames: _col0, _col1
 240                     Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 241                     Spark HashTable Sink Operator
 242                       filter predicates:
 243                         0
 244                         1 {(UDFToDouble(_col1.key) > 200.0D)}
 245                       keys:
 246                         0 _col0 (type: string)
 247                         1 _col0 (type: string)
 248             Local Work:
 249               Map Reduce Local Work
 250
 251   Stage: Stage-1
 252     Spark
 253 #### A masked pattern was here ####
 254       Vertices:
 255         Map 2
 256             Map Operator Tree:
 257                 TableScan
 258                   alias: src
 259                   Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 260                   Select Operator
 261                     expressions: key (type: string), named_struct('key',key,'value',value) (type: struct<key:string,value:string>)
 262                     outputColumnNames: _col0, _col1
 263                     Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 264                     Map Join Operator
 265                       condition map:
 266                            Right Outer Join 0 to 1
 267                       filter predicates:
 268                         0
 269                         1 {(UDFToDouble(_col1.key) > 200.0D)}
 270                       keys:
 271                         0 _col0 (type: string)
 272                         1 _col0 (type: string)
 273                       outputColumnNames: _col0, _col1, _col2, _col3
 274                       input vertices:
 275                         0 Map 1
 276                       Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE
 277                       Limit
 278                         Number of rows: 10
 279                         Statistics: Num rows: 10 Data size: 100 Basic stats: COMPLETE Column stats: NONE
 280                         File Output Operator
 281                           compressed: false
 282                           Statistics: Num rows: 10 Data size: 100 Basic stats: COMPLETE Column stats: NONE
 283                           table:
 284                               input format: org.apache.hadoop.mapred.SequenceFileInputFormat
 285                               output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
 286                               serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
 287             Local Work:
 288               Map Reduce Local Work
 289
 290   Stage: Stage-0
 291     Fetch Operator
 292       limit: 10
 293       Processor Tree:
 294         ListSink
 295
 296 PREHOOK: query: SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN
 297     (select key, named_struct('key', key, 'value', value) as kv from src) b on a.key=b.key AND b.kv.key > 200 limit 10
 298 PREHOOK: type: QUERY
 299 PREHOOK: Input: default@src
 300 #### A masked pattern was here ####
 301 POSTHOOK: query: SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN
 302     (select key, named_struct('key', key, 'value', value) as kv from src) b on a.key=b.key AND b.kv.key > 200 limit 10
 303 POSTHOOK: type: QUERY
 304 POSTHOOK: Input: default@src
 305 #### A masked pattern was here ####
 306 238     val_238 238     {"key":"238","value":"val_238"}
 307 238     val_238 238     {"key":"238","value":"val_238"}
 308 NULL    NULL    86      {"key":"86","value":"val_86"}
 309 311     val_311 311     {"key":"311","value":"val_311"}
 310 311     val_311 311     {"key":"311","value":"val_311"}
 311 311     val_311 311     {"key":"311","value":"val_311"}
 312 NULL    NULL    27      {"key":"27","value":"val_27"}
 313 NULL    NULL    165     {"key":"165","value":"val_165"}
 314 409     val_409 409     {"key":"409","value":"val_409"}
 315 409     val_409 409     {"key":"409","value":"val_409"}
 316 PREHOOK: query: EXPLAIN
 317 SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN src b on a.key=b.key AND true limit 10
 318 PREHOOK: type: QUERY
 319 POSTHOOK: query: EXPLAIN
 320 SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN src b on a.key=b.key AND true limit 10
 321 POSTHOOK: type: QUERY
 322 STAGE DEPENDENCIES:
 323   Stage-2 is a root stage
 324   Stage-1 depends on stages: Stage-2
 325   Stage-0 depends on stages: Stage-1
 326
 327 STAGE PLANS:
 328   Stage: Stage-2
 329     Spark
 330 #### A masked pattern was here ####
 331       Vertices:
 332         Map 1
 333             Map Operator Tree:
 334                 TableScan
 335                   alias: a
 336                   Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 337                   Select Operator
 338                     expressions: key (type: string), value (type: string)
 339                     outputColumnNames: _col0, _col1
 340                     Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 341                     Spark HashTable Sink Operator
 342                       keys:
 343                         0 _col0 (type: string)
 344                         1 _col0 (type: string)
 345             Local Work:
 346               Map Reduce Local Work
 347
 348   Stage: Stage-1
 349     Spark
 350 #### A masked pattern was here ####
 351       Vertices:
 352         Map 2
 353             Map Operator Tree:
 354                 TableScan
 355                   alias: b
 356                   Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 357                   Select Operator
 358                     expressions: key (type: string), value (type: string)
 359                     outputColumnNames: _col0, _col1
 360                     Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 361                     Map Join Operator
 362                       condition map:
 363                            Right Outer Join 0 to 1
 364                       keys:
 365                         0 _col0 (type: string)
 366                         1 _col0 (type: string)
 367                       outputColumnNames: _col0, _col1, _col2, _col3
 368                       input vertices:
 369                         0 Map 1
 370                       Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE
 371                       Limit
 372                         Number of rows: 10
 373                         Statistics: Num rows: 10 Data size: 100 Basic stats: COMPLETE Column stats: NONE
 374                         File Output Operator
 375                           compressed: false
 376                           Statistics: Num rows: 10 Data size: 100 Basic stats: COMPLETE Column stats: NONE
 377                           table:
 378                               input format: org.apache.hadoop.mapred.SequenceFileInputFormat
 379                               output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
 380                               serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
 381             Local Work:
 382               Map Reduce Local Work
 383
 384   Stage: Stage-0
 385     Fetch Operator
 386       limit: 10
 387       Processor Tree:
 388         ListSink
 389
 390 PREHOOK: query: SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN src b on a.key=b.key AND true limit 10
 391 PREHOOK: type: QUERY
 392 PREHOOK: Input: default@src
 393 #### A masked pattern was here ####
 394 POSTHOOK: query: SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN src b on a.key=b.key AND true limit 10
 395 POSTHOOK: type: QUERY
 396 POSTHOOK: Input: default@src
 397 #### A masked pattern was here ####
 398 238     val_238 238     val_238
 399 238     val_238 238     val_238
 400 86      val_86  86      val_86
 401 311     val_311 311     val_311
 402 311     val_311 311     val_311
 403 311     val_311 311     val_311
 404 27      val_27  27      val_27
 405 165     val_165 165     val_165
 406 165     val_165 165     val_165
 407 409     val_409 409     val_409
 408 PREHOOK: query: EXPLAIN
 409 SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN src b on a.key=b.key AND b.key * 10 < '1000' limit 10
 410 PREHOOK: type: QUERY
 411 POSTHOOK: query: EXPLAIN
 412 SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN src b on a.key=b.key AND b.key * 10 < '1000' limit 10
 413 POSTHOOK: type: QUERY
 414 STAGE DEPENDENCIES:
 415   Stage-2 is a root stage
 416   Stage-1 depends on stages: Stage-2
 417   Stage-0 depends on stages: Stage-1
 418
 419 STAGE PLANS:
 420   Stage: Stage-2
 421     Spark
 422 #### A masked pattern was here ####
 423       Vertices:
 424         Map 1
 425             Map Operator Tree:
 426                 TableScan
 427                   alias: a
 428                   Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 429                   Select Operator
 430                     expressions: key (type: string), value (type: string)
 431                     outputColumnNames: _col0, _col1
 432                     Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 433                     Spark HashTable Sink Operator
 434                       filter predicates:
 435                         0
 436                         1 {((UDFToDouble(_col0) * 10.0D) < 1000.0D)}
 437                       keys:
 438                         0 _col0 (type: string)
 439                         1 _col0 (type: string)
 440             Local Work:
 441               Map Reduce Local Work
 442
 443   Stage: Stage-1
 444     Spark
 445 #### A masked pattern was here ####
 446       Vertices:
 447         Map 2
 448             Map Operator Tree:
 449                 TableScan
 450                   alias: b
 451                   Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 452                   Select Operator
 453                     expressions: key (type: string), value (type: string)
 454                     outputColumnNames: _col0, _col1
 455                     Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 456                     Map Join Operator
 457                       condition map:
 458                            Right Outer Join 0 to 1
 459                       filter predicates:
 460                         0
 461                         1 {((UDFToDouble(_col0) * 10.0D) < 1000.0D)}
 462                       keys:
 463                         0 _col0 (type: string)
 464                         1 _col0 (type: string)
 465                       outputColumnNames: _col0, _col1, _col2, _col3
 466                       input vertices:
 467                         0 Map 1
 468                       Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE
 469                       Limit
 470                         Number of rows: 10
 471                         Statistics: Num rows: 10 Data size: 100 Basic stats: COMPLETE Column stats: NONE
 472                         File Output Operator
 473                           compressed: false
 474                           Statistics: Num rows: 10 Data size: 100 Basic stats: COMPLETE Column stats: NONE
 475                           table:
 476                               input format: org.apache.hadoop.mapred.SequenceFileInputFormat
 477                               output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
 478                               serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
 479             Local Work:
 480               Map Reduce Local Work
 481
 482   Stage: Stage-0
 483     Fetch Operator
 484       limit: 10
 485       Processor Tree:
 486         ListSink
 487
 488 PREHOOK: query: SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN src b on a.key=b.key AND b.key * 10 < '1000' limit 10
 489 PREHOOK: type: QUERY
 490 PREHOOK: Input: default@src
 491 #### A masked pattern was here ####
 492 POSTHOOK: query: SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN src b on a.key=b.key AND b.key * 10 < '1000' limit 10
 493 POSTHOOK: type: QUERY
 494 POSTHOOK: Input: default@src
 495 #### A masked pattern was here ####
 496 NULL    NULL    238     val_238
 497 86      val_86  86      val_86
 498 NULL    NULL    311     val_311
 499 27      val_27  27      val_27
 500 NULL    NULL    165     val_165
 501 NULL    NULL    409     val_409
 502 NULL    NULL    255     val_255
 503 NULL    NULL    278     val_278
 504 98      val_98  98      val_98
 505 98      val_98  98      val_98
 506 PREHOOK: query: EXPLAIN
 507 SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN
 508     (select key, named_struct('key', key, 'value', value) as kv from src) b on a.key=b.key AND b.kv.key > 200 limit 10
 509 PREHOOK: type: QUERY
 510 POSTHOOK: query: EXPLAIN
 511 SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN
 512     (select key, named_struct('key', key, 'value', value) as kv from src) b on a.key=b.key AND b.kv.key > 200 limit 10
 513 POSTHOOK: type: QUERY
 514 STAGE DEPENDENCIES:
 515   Stage-2 is a root stage
 516   Stage-1 depends on stages: Stage-2
 517   Stage-0 depends on stages: Stage-1
 518
 519 STAGE PLANS:
 520   Stage: Stage-2
 521     Spark
 522 #### A masked pattern was here ####
 523       Vertices:
 524         Map 1
 525             Map Operator Tree:
 526                 TableScan
 527                   alias: a
 528                   Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 529                   Select Operator
 530                     expressions: key (type: string), value (type: string)
 531                     outputColumnNames: _col0, _col1
 532                     Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 533                     Spark HashTable Sink Operator
 534                       filter predicates:
 535                         0
 536                         1 {(UDFToDouble(_col1.key) > 200.0D)}
 537                       keys:
 538                         0 _col0 (type: string)
 539                         1 _col0 (type: string)
 540             Local Work:
 541               Map Reduce Local Work
 542
 543   Stage: Stage-1
 544     Spark
 545 #### A masked pattern was here ####
 546       Vertices:
 547         Map 2
 548             Map Operator Tree:
 549                 TableScan
 550                   alias: src
 551                   Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 552                   Select Operator
 553                     expressions: key (type: string), named_struct('key',key,'value',value) (type: struct<key:string,value:string>)
 554                     outputColumnNames: _col0, _col1
 555                     Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
 556                     Map Join Operator
 557                       condition map:
 558                            Right Outer Join 0 to 1
 559                       filter predicates:
 560                         0
 561                         1 {(UDFToDouble(_col1.key) > 200.0D)}
 562                       keys:
 563                         0 _col0 (type: string)
 564                         1 _col0 (type: string)
 565                       outputColumnNames: _col0, _col1, _col2, _col3
 566                       input vertices:
 567                         0 Map 1
 568                       Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE
 569                       Limit
 570                         Number of rows: 10
 571                         Statistics: Num rows: 10 Data size: 100 Basic stats: COMPLETE Column stats: NONE
 572                         File Output Operator
 573                           compressed: false
 574                           Statistics: Num rows: 10 Data size: 100 Basic stats: COMPLETE Column stats: NONE
 575                           table:
 576                               input format: org.apache.hadoop.mapred.SequenceFileInputFormat
 577                               output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
 578                               serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
 579             Local Work:
 580               Map Reduce Local Work
 581
 582   Stage: Stage-0
 583     Fetch Operator
 584       limit: 10
 585       Processor Tree:
 586         ListSink
 587
 588 PREHOOK: query: SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN
 589     (select key, named_struct('key', key, 'value', value) as kv from src) b on a.key=b.key AND b.kv.key > 200 limit 10
 590 PREHOOK: type: QUERY
 591 PREHOOK: Input: default@src
 592 #### A masked pattern was here ####
 593 POSTHOOK: query: SELECT /*+ MAPJOIN(a) */ * FROM src a RIGHT OUTER JOIN
 594     (select key, named_struct('key', key, 'value', value) as kv from src) b on a.key=b.key AND b.kv.key > 200 limit 10
 595 POSTHOOK: type: QUERY
 596 POSTHOOK: Input: default@src
 597 #### A masked pattern was here ####
 598 238     val_238 238     {"key":"238","value":"val_238"}
 599 238     val_238 238     {"key":"238","value":"val_238"}
 600 NULL    NULL    86      {"key":"86","value":"val_86"}
 601 311     val_311 311     {"key":"311","value":"val_311"}
 602 311     val_311 311     {"key":"311","value":"val_311"}
 603 311     val_311 311     {"key":"311","value":"val_311"}
 604 NULL    NULL    27      {"key":"27","value":"val_27"}
 605 NULL    NULL    165     {"key":"165","value":"val_165"}
 606 409     val_409 409     {"key":"409","value":"val_409"}
 607 409     val_409 409     {"key":"409","value":"val_409"}