http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoBinaryMultiRegion.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoBinaryMultiRegion.result b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoBinaryMultiRegion.result new file mode 100644 index 0000000..c55873a --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoBinaryMultiRegion.result @@ -0,0 +1,100 @@ +0, value0 +1, value1 +2, value2 +3, value3 +4, value4 +5, value5 +6, value6 +7, value7 +8, value8 +9, value9 +1, value10 +1, value11 +1, value12 +1, value13 +1, value14 +1, value15 +1, value16 +1, value17 +1, value18 +1, value19 +2, value20 +2, value21 +2, value22 +2, value23 +2, value24 +2, value25 +2, value26 +2, value27 +2, value28 +2, value29 +3, value30 +3, value31 +3, value32 +3, value33 +3, value34 +3, value35 +3, value36 +3, value37 +3, value38 +3, value39 +4, value40 +4, value41 +4, value42 +4, value43 +4, value44 +4, value45 +4, value46 +4, value47 +4, value48 +4, value49 +5, value50 +5, value51 +5, value52 +5, value53 +5, value54 +5, value55 +5, value56 +5, value57 +5, value58 +5, value59 +6, value60 +6, value61 +6, value62 +6, value63 +6, value64 +6, value65 +6, value66 +6, value67 +6, value68 +6, value69 +7, value70 +7, value71 +7, value72 +7, value73 +7, value74 +7, value75 +7, value76 +7, value77 +7, value78 +7, value79 +8, value80 +8, value81 +8, value82 +8, value83 +8, value84 +8, value85 +8, value86 +8, value87 +8, value88 +8, value89 +9, value90 +9, value91 +9, value92 +9, value93 +9, value94 +9, value95 +9, value96 +9, value97 +9, value98 +9, value99
http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoColumnKeyValue.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoColumnKeyValue.result b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoColumnKeyValue.result new file mode 100644 index 0000000..a37593b --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoColumnKeyValue.result @@ -0,0 +1,21 @@ +0, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-0"} +1, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-1"} +10, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-10"} +11, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-11"} +12, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-12"} +13, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-13"} +14, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-14"} +15, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-15"} +16, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-16"} +17, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-17"} +18, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-18"} +19, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-19"} +2, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-2"} +20, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-20"} +3, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-3"} +4, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-4"} +5, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-5"} +6, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-6"} +7, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-7"} +8, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-8"} +9, {"ck-0": "value-0", "ck-1": "value-1", "ck-2": "value-2"}, {"": "col3-9"} http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoMultiRegion.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoMultiRegion.result b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoMultiRegion.result new file mode 100644 index 0000000..72013f2 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoMultiRegion.result @@ -0,0 +1,100 @@ +000, value0 +001, value1 +002, value2 +003, value3 +004, value4 +005, value5 +006, value6 +007, value7 +008, value8 +009, value9 +010, value10 +011, value11 +012, value12 +013, value13 +014, value14 +015, value15 +016, value16 +017, value17 +018, value18 +019, value19 +020, value20 +021, value21 +022, value22 +023, value23 +024, value24 +025, value25 +026, value26 +027, value27 +028, value28 +029, value29 +030, value30 +031, value31 +032, value32 +033, value33 +034, value34 +035, value35 +036, value36 +037, value37 +038, value38 +039, value39 +040, value40 +041, value41 +042, value42 +043, value43 +044, value44 +045, value45 +046, value46 +047, value47 +048, value48 +049, value49 +050, value50 +051, value51 +052, value52 +053, value53 +054, value54 +055, value55 +056, value56 +057, value57 +058, value58 +059, value59 +060, value60 +061, value61 +062, value62 +063, value63 +064, value64 +065, value65 +066, value66 +067, value67 +068, value68 +069, value69 +070, value70 +071, value71 +072, value72 +073, value73 +074, value74 +075, value75 +076, value76 +077, value77 +078, value78 +079, value79 +080, value80 +081, value81 +082, value82 +083, value83 +084, value84 +085, value85 +086, value86 +087, value87 +088, value88 +089, value89 +090, value90 +091, value91 +092, value92 +093, value93 +094, value94 +095, value95 +096, value96 +097, value97 +098, value98 +099, value99 http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoMultiRegion2.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoMultiRegion2.result b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoMultiRegion2.result new file mode 100644 index 0000000..be11042 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoMultiRegion2.result @@ -0,0 +1,100 @@ +0, value0 +1, value1 +10, value10 +11, value11 +12, value12 +13, value13 +14, value14 +15, value15 +16, value16 +17, value17 +18, value18 +19, value19 +2, value2 +20, value20 +21, value21 +22, value22 +23, value23 +24, value24 +25, value25 +26, value26 +27, value27 +28, value28 +29, value29 +3, value3 +30, value30 +31, value31 +32, value32 +33, value33 +34, value34 +35, value35 +36, value36 +37, value37 +38, value38 +39, value39 +4, value4 +40, value40 +41, value41 +42, value42 +43, value43 +44, value44 +45, value45 +46, value46 +47, value47 +48, value48 +49, value49 +5, value5 +50, value50 +51, value51 +52, value52 +53, value53 +54, value54 +55, value55 +56, value56 +57, value57 +58, value58 +59, value59 +6, value6 +60, value60 +61, value61 +62, value62 +63, value63 +64, value64 +65, value65 +66, value66 +67, value67 +68, value68 +69, value69 +7, value7 +70, value70 +71, value71 +72, value72 +73, value73 +74, value74 +75, value75 +76, value76 +77, value77 +78, value78 +79, value79 +8, value8 +80, value80 +81, value81 +82, value82 +83, value83 +84, value84 +85, value85 +86, value86 +87, value87 +88, value88 +89, value89 +9, value9 +90, value90 +91, value91 +92, value92 +93, value93 +94, value94 +95, value95 +96, value96 +97, value97 +98, value98 +99, value99 http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoMultiRegionMultiRowFields.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoMultiRegionMultiRowFields.result b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoMultiRegionMultiRowFields.result new file mode 100644 index 0000000..0b740c8 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoMultiRegionMultiRowFields.result @@ -0,0 +1,100 @@ +000_100, value0 +001_101, value1 +002_102, value2 +003_103, value3 +004_104, value4 +005_105, value5 +006_106, value6 +007_107, value7 +008_108, value8 +009_109, value9 +010_110, value10 +011_111, value11 +012_112, value12 +013_113, value13 +014_114, value14 +015_115, value15 +016_116, value16 +017_117, value17 +018_118, value18 +019_119, value19 +020_120, value20 +021_121, value21 +022_122, value22 +023_123, value23 +024_124, value24 +025_125, value25 +026_126, value26 +027_127, value27 +028_128, value28 +029_129, value29 +030_130, value30 +031_131, value31 +032_132, value32 +033_133, value33 +034_134, value34 +035_135, value35 +036_136, value36 +037_137, value37 +038_138, value38 +039_139, value39 +040_140, value40 +041_141, value41 +042_142, value42 +043_143, value43 +044_144, value44 +045_145, value45 +046_146, value46 +047_147, value47 +048_148, value48 +049_149, value49 +050_150, value50 +051_151, value51 +052_152, value52 +053_153, value53 +054_154, value54 +055_155, value55 +056_156, value56 +057_157, value57 +058_158, value58 +059_159, value59 +060_160, value60 +061_161, value61 +062_162, value62 +063_163, value63 +064_164, value64 +065_165, value65 +066_166, value66 +067_167, value67 +068_168, value68 +069_169, value69 +070_170, value70 +071_171, value71 +072_172, value72 +073_173, value73 +074_174, value74 +075_175, value75 +076_176, value76 +077_177, value77 +078_178, value78 +079_179, value79 +080_180, value80 +081_181, value81 +082_182, value82 +083_183, value83 +084_184, value84 +085_185, value85 +086_186, value86 +087_187, value87 +088_188, value88 +089_189, value89 +090_190, value90 +091_191, value91 +092_192, value92 +093_193, value93 +094_194, value94 +095_195, value95 +096_196, value96 +097_197, value97 +098_198, value98 +099_199, value99 http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoMultiRegionWithSplitFile.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoMultiRegionWithSplitFile.result b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoMultiRegionWithSplitFile.result new file mode 100644 index 0000000..72013f2 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoMultiRegionWithSplitFile.result @@ -0,0 +1,100 @@ +000, value0 +001, value1 +002, value2 +003, value3 +004, value4 +005, value5 +006, value6 +007, value7 +008, value8 +009, value9 +010, value10 +011, value11 +012, value12 +013, value13 +014, value14 +015, value15 +016, value16 +017, value17 +018, value18 +019, value19 +020, value20 +021, value21 +022, value22 +023, value23 +024, value24 +025, value25 +026, value26 +027, value27 +028, value28 +029, value29 +030, value30 +031, value31 +032, value32 +033, value33 +034, value34 +035, value35 +036, value36 +037, value37 +038, value38 +039, value39 +040, value40 +041, value41 +042, value42 +043, value43 +044, value44 +045, value45 +046, value46 +047, value47 +048, value48 +049, value49 +050, value50 +051, value51 +052, value52 +053, value53 +054, value54 +055, value55 +056, value56 +057, value57 +058, value58 +059, value59 +060, value60 +061, value61 +062, value62 +063, value63 +064, value64 +065, value65 +066, value66 +067, value67 +068, value68 +069, value69 +070, value70 +071, value71 +072, value72 +073, value73 +074, value74 +075, value75 +076, value76 +077, value77 +078, value78 +079, value79 +080, value80 +081, value81 +082, value82 +083, value83 +084, value84 +085, value85 +086, value86 +087, value87 +088, value88 +089, value89 +090, value90 +091, value91 +092, value92 +093, value93 +094, value94 +095, value95 +096, value96 +097, value97 +098, value98 +099, value99 http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoRowField.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoRowField.result b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoRowField.result new file mode 100644 index 0000000..152b91b --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoRowField.result @@ -0,0 +1,4 @@ +1_1, 1996-03-13, N, 7706 +2_2, 1997-01-28, N, 1191 +3_2, 1994-02-02, R, 1798 +3_3, 1993-11-09, R, 6540 http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoUsingPut.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoUsingPut.result b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoUsingPut.result new file mode 100644 index 0000000..e0c97ef --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertIntoUsingPut.result @@ -0,0 +1,3 @@ +1, 1996-03-13, {"": "N"}, 7706 +2, 1997-01-28, {"": "N"}, 1191 +3, 1994-02-02, {"": "R"}, 1798 http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertValues1.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertValues1.result b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertValues1.result new file mode 100644 index 0000000..45d730a --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testInsertValues1.result @@ -0,0 +1,4 @@ +aaa, a12, {"": "a34"}, 1 +bbb, b12, {"": "b34"}, 2 +ccc, c12, {"": "c34"}, 3 +ddd, d12, {"": "d34"}, 4 http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestHBaseTable/testJoin.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestHBaseTable/testJoin.result b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testJoin.result new file mode 100644 index 0000000..fe4fcae --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testJoin.result @@ -0,0 +1,7 @@ +rk,col1,col2,col3,l_orderkey,l_linestatus +------------------------------- +001,a-1,{"k1":"k1-1", "k2":"k2-1"},1,1,O +001,a-1,{"k1":"k1-1", "k2":"k2-1"},1,1,O +002,a-2,{"k1":"k1-2", "k2":"k2-2"},2,2,O +003,a-3,{"k1":"k1-3", "k2":"k2-3"},3,3,F +003,a-3,{"k1":"k1-3", "k2":"k2-3"},3,3,F \ No newline at end of file http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestHBaseTable/testNonForwardQuery.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestHBaseTable/testNonForwardQuery.result b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testNonForwardQuery.result new file mode 100644 index 0000000..4f5fd8f --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testNonForwardQuery.result @@ -0,0 +1,102 @@ +rk,col1,col2,col3 +------------------------------- +000,a-0,{"k1":"k1-0", "k2":"k2-0"},0 +001,a-1,{"k1":"k1-1", "k2":"k2-1"},1 +002,a-2,{"k1":"k1-2", "k2":"k2-2"},2 +003,a-3,{"k1":"k1-3", "k2":"k2-3"},3 +004,a-4,{"k1":"k1-4", "k2":"k2-4"},4 +005,a-5,{"k1":"k1-5", "k2":"k2-5"},5 +006,a-6,{"k1":"k1-6", "k2":"k2-6"},6 +007,a-7,{"k1":"k1-7", "k2":"k2-7"},7 +008,a-8,{"k1":"k1-8", "k2":"k2-8"},8 +009,a-9,{"k1":"k1-9", "k2":"k2-9"},9 +010,a-10,{"k1":"k1-10", "k2":"k2-10"},10 +011,a-11,{"k1":"k1-11", "k2":"k2-11"},11 +012,a-12,{"k1":"k1-12", "k2":"k2-12"},12 +013,a-13,{"k1":"k1-13", "k2":"k2-13"},13 +014,a-14,{"k1":"k1-14", "k2":"k2-14"},14 +015,a-15,{"k1":"k1-15", "k2":"k2-15"},15 +016,a-16,{"k1":"k1-16", "k2":"k2-16"},16 +017,a-17,{"k1":"k1-17", "k2":"k2-17"},17 +018,a-18,{"k1":"k1-18", "k2":"k2-18"},18 +019,a-19,{"k1":"k1-19", "k2":"k2-19"},19 +020,a-20,{"k1":"k1-20", "k2":"k2-20"},20 +021,a-21,{"k1":"k1-21", "k2":"k2-21"},21 +022,a-22,{"k1":"k1-22", "k2":"k2-22"},22 +023,a-23,{"k1":"k1-23", "k2":"k2-23"},23 +024,a-24,{"k1":"k1-24", "k2":"k2-24"},24 +025,a-25,{"k1":"k1-25", "k2":"k2-25"},25 +026,a-26,{"k1":"k1-26", "k2":"k2-26"},26 +027,a-27,{"k1":"k1-27", "k2":"k2-27"},27 +028,a-28,{"k1":"k1-28", "k2":"k2-28"},28 +029,a-29,{"k1":"k1-29", "k2":"k2-29"},29 +030,a-30,{"k1":"k1-30", "k2":"k2-30"},30 +031,a-31,{"k1":"k1-31", "k2":"k2-31"},31 +032,a-32,{"k1":"k1-32", "k2":"k2-32"},32 +033,a-33,{"k1":"k1-33", "k2":"k2-33"},33 +034,a-34,{"k1":"k1-34", "k2":"k2-34"},34 +035,a-35,{"k1":"k1-35", "k2":"k2-35"},35 +036,a-36,{"k1":"k1-36", "k2":"k2-36"},36 +037,a-37,{"k1":"k1-37", "k2":"k2-37"},37 +038,a-38,{"k1":"k1-38", "k2":"k2-38"},38 +039,a-39,{"k1":"k1-39", "k2":"k2-39"},39 +040,a-40,{"k1":"k1-40", "k2":"k2-40"},40 +041,a-41,{"k1":"k1-41", "k2":"k2-41"},41 +042,a-42,{"k1":"k1-42", "k2":"k2-42"},42 +043,a-43,{"k1":"k1-43", "k2":"k2-43"},43 +044,a-44,{"k1":"k1-44", "k2":"k2-44"},44 +045,a-45,{"k1":"k1-45", "k2":"k2-45"},45 +046,a-46,{"k1":"k1-46", "k2":"k2-46"},46 +047,a-47,{"k1":"k1-47", "k2":"k2-47"},47 +048,a-48,{"k1":"k1-48", "k2":"k2-48"},48 +049,a-49,{"k1":"k1-49", "k2":"k2-49"},49 +050,a-50,{"k1":"k1-50", "k2":"k2-50"},50 +051,a-51,{"k1":"k1-51", "k2":"k2-51"},51 +052,a-52,{"k1":"k1-52", "k2":"k2-52"},52 +053,a-53,{"k1":"k1-53", "k2":"k2-53"},53 +054,a-54,{"k1":"k1-54", "k2":"k2-54"},54 +055,a-55,{"k1":"k1-55", "k2":"k2-55"},55 +056,a-56,{"k1":"k1-56", "k2":"k2-56"},56 +057,a-57,{"k1":"k1-57", "k2":"k2-57"},57 +058,a-58,{"k1":"k1-58", "k2":"k2-58"},58 +059,a-59,{"k1":"k1-59", "k2":"k2-59"},59 +060,a-60,{"k1":"k1-60", "k2":"k2-60"},60 +061,a-61,{"k1":"k1-61", "k2":"k2-61"},61 +062,a-62,{"k1":"k1-62", "k2":"k2-62"},62 +063,a-63,{"k1":"k1-63", "k2":"k2-63"},63 +064,a-64,{"k1":"k1-64", "k2":"k2-64"},64 +065,a-65,{"k1":"k1-65", "k2":"k2-65"},65 +066,a-66,{"k1":"k1-66", "k2":"k2-66"},66 +067,a-67,{"k1":"k1-67", "k2":"k2-67"},67 +068,a-68,{"k1":"k1-68", "k2":"k2-68"},68 +069,a-69,{"k1":"k1-69", "k2":"k2-69"},69 +070,a-70,{"k1":"k1-70", "k2":"k2-70"},70 +071,a-71,{"k1":"k1-71", "k2":"k2-71"},71 +072,a-72,{"k1":"k1-72", "k2":"k2-72"},72 +073,a-73,{"k1":"k1-73", "k2":"k2-73"},73 +074,a-74,{"k1":"k1-74", "k2":"k2-74"},74 +075,a-75,{"k1":"k1-75", "k2":"k2-75"},75 +076,a-76,{"k1":"k1-76", "k2":"k2-76"},76 +077,a-77,{"k1":"k1-77", "k2":"k2-77"},77 +078,a-78,{"k1":"k1-78", "k2":"k2-78"},78 +079,a-79,{"k1":"k1-79", "k2":"k2-79"},79 +080,a-80,{"k1":"k1-80", "k2":"k2-80"},80 +081,a-81,{"k1":"k1-81", "k2":"k2-81"},81 +082,a-82,{"k1":"k1-82", "k2":"k2-82"},82 +083,a-83,{"k1":"k1-83", "k2":"k2-83"},83 +084,a-84,{"k1":"k1-84", "k2":"k2-84"},84 +085,a-85,{"k1":"k1-85", "k2":"k2-85"},85 +086,a-86,{"k1":"k1-86", "k2":"k2-86"},86 +087,a-87,{"k1":"k1-87", "k2":"k2-87"},87 +088,a-88,{"k1":"k1-88", "k2":"k2-88"},88 +089,a-89,{"k1":"k1-89", "k2":"k2-89"},89 +090,a-90,{"k1":"k1-90", "k2":"k2-90"},90 +091,a-91,{"k1":"k1-91", "k2":"k2-91"},91 +092,a-92,{"k1":"k1-92", "k2":"k2-92"},92 +093,a-93,{"k1":"k1-93", "k2":"k2-93"},93 +094,a-94,{"k1":"k1-94", "k2":"k2-94"},94 +095,a-95,{"k1":"k1-95", "k2":"k2-95"},95 +096,a-96,{"k1":"k1-96", "k2":"k2-96"},96 +097,a-97,{"k1":"k1-97", "k2":"k2-97"},97 +098,a-98,{"k1":"k1-98", "k2":"k2-98"},98 +099,a-99,{"k1":"k1-99", "k2":"k2-99"},99 \ No newline at end of file http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestHBaseTable/testRowFieldSelectQuery.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestHBaseTable/testRowFieldSelectQuery.result b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testRowFieldSelectQuery.result new file mode 100644 index 0000000..34369df --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testRowFieldSelectQuery.result @@ -0,0 +1,88 @@ +rk1,rk2,col3 +------------------------------- +field1-21,field2-21,a-21 +field1-22,field2-22,a-22 +field1-23,field2-23,a-23 +field1-24,field2-24,a-24 +field1-25,field2-25,a-25 +field1-26,field2-26,a-26 +field1-27,field2-27,a-27 +field1-28,field2-28,a-28 +field1-29,field2-29,a-29 +field1-30,field2-30,a-30 +field1-31,field2-31,a-31 +field1-32,field2-32,a-32 +field1-33,field2-33,a-33 +field1-34,field2-34,a-34 +field1-35,field2-35,a-35 +field1-36,field2-36,a-36 +field1-37,field2-37,a-37 +field1-38,field2-38,a-38 +field1-39,field2-39,a-39 +field1-3,field2-3,a-3 +field1-40,field2-40,a-40 +field1-41,field2-41,a-41 +field1-42,field2-42,a-42 +field1-43,field2-43,a-43 +field1-44,field2-44,a-44 +field1-45,field2-45,a-45 +field1-46,field2-46,a-46 +field1-47,field2-47,a-47 +field1-48,field2-48,a-48 +field1-49,field2-49,a-49 +field1-4,field2-4,a-4 +field1-50,field2-50,a-50 +field1-51,field2-51,a-51 +field1-52,field2-52,a-52 +field1-53,field2-53,a-53 +field1-54,field2-54,a-54 +field1-55,field2-55,a-55 +field1-56,field2-56,a-56 +field1-57,field2-57,a-57 +field1-58,field2-58,a-58 +field1-59,field2-59,a-59 +field1-5,field2-5,a-5 +field1-60,field2-60,a-60 +field1-61,field2-61,a-61 +field1-62,field2-62,a-62 +field1-63,field2-63,a-63 +field1-64,field2-64,a-64 +field1-65,field2-65,a-65 +field1-66,field2-66,a-66 +field1-67,field2-67,a-67 +field1-68,field2-68,a-68 +field1-69,field2-69,a-69 +field1-6,field2-6,a-6 +field1-70,field2-70,a-70 +field1-71,field2-71,a-71 +field1-72,field2-72,a-72 +field1-73,field2-73,a-73 +field1-74,field2-74,a-74 +field1-75,field2-75,a-75 +field1-76,field2-76,a-76 +field1-77,field2-77,a-77 +field1-78,field2-78,a-78 +field1-79,field2-79,a-79 +field1-7,field2-7,a-7 +field1-80,field2-80,a-80 +field1-81,field2-81,a-81 +field1-82,field2-82,a-82 +field1-83,field2-83,a-83 +field1-84,field2-84,a-84 +field1-85,field2-85,a-85 +field1-86,field2-86,a-86 +field1-87,field2-87,a-87 +field1-88,field2-88,a-88 +field1-89,field2-89,a-89 +field1-8,field2-8,a-8 +field1-90,field2-90,a-90 +field1-91,field2-91,a-91 +field1-92,field2-92,a-92 +field1-93,field2-93,a-93 +field1-94,field2-94,a-94 +field1-95,field2-95,a-95 +field1-96,field2-96,a-96 +field1-97,field2-97,a-97 +field1-98,field2-98,a-98 +field1-99,field2-99,a-99 +field1-9,field2-9,a-9 \ No newline at end of file http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestHBaseTable/testSimpleSelectQuery.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestHBaseTable/testSimpleSelectQuery.result b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testSimpleSelectQuery.result new file mode 100644 index 0000000..ef2f27a --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestHBaseTable/testSimpleSelectQuery.result @@ -0,0 +1,88 @@ +rk,col1,col2,col3 +------------------------------- +21,a-21,{"k1":"k1-21", "k2":"k2-21"},b-21 +22,a-22,{"k1":"k1-22", "k2":"k2-22"},b-22 +23,a-23,{"k1":"k1-23", "k2":"k2-23"},b-23 +24,a-24,{"k1":"k1-24", "k2":"k2-24"},b-24 +25,a-25,{"k1":"k1-25", "k2":"k2-25"},b-25 +26,a-26,{"k1":"k1-26", "k2":"k2-26"},b-26 +27,a-27,{"k1":"k1-27", "k2":"k2-27"},b-27 +28,a-28,{"k1":"k1-28", "k2":"k2-28"},b-28 +29,a-29,{"k1":"k1-29", "k2":"k2-29"},b-29 +3,a-3,{"k1":"k1-3", "k2":"k2-3"},b-3 +30,a-30,{"k1":"k1-30", "k2":"k2-30"},b-30 +31,a-31,{"k1":"k1-31", "k2":"k2-31"},b-31 +32,a-32,{"k1":"k1-32", "k2":"k2-32"},b-32 +33,a-33,{"k1":"k1-33", "k2":"k2-33"},b-33 +34,a-34,{"k1":"k1-34", "k2":"k2-34"},b-34 +35,a-35,{"k1":"k1-35", "k2":"k2-35"},b-35 +36,a-36,{"k1":"k1-36", "k2":"k2-36"},b-36 +37,a-37,{"k1":"k1-37", "k2":"k2-37"},b-37 +38,a-38,{"k1":"k1-38", "k2":"k2-38"},b-38 +39,a-39,{"k1":"k1-39", "k2":"k2-39"},b-39 +4,a-4,{"k1":"k1-4", "k2":"k2-4"},b-4 +40,a-40,{"k1":"k1-40", "k2":"k2-40"},b-40 +41,a-41,{"k1":"k1-41", "k2":"k2-41"},b-41 +42,a-42,{"k1":"k1-42", "k2":"k2-42"},b-42 +43,a-43,{"k1":"k1-43", "k2":"k2-43"},b-43 +44,a-44,{"k1":"k1-44", "k2":"k2-44"},b-44 +45,a-45,{"k1":"k1-45", "k2":"k2-45"},b-45 +46,a-46,{"k1":"k1-46", "k2":"k2-46"},b-46 +47,a-47,{"k1":"k1-47", "k2":"k2-47"},b-47 +48,a-48,{"k1":"k1-48", "k2":"k2-48"},b-48 +49,a-49,{"k1":"k1-49", "k2":"k2-49"},b-49 +5,a-5,{"k1":"k1-5", "k2":"k2-5"},b-5 +50,a-50,{"k1":"k1-50", "k2":"k2-50"},b-50 +51,a-51,{"k1":"k1-51", "k2":"k2-51"},b-51 +52,a-52,{"k1":"k1-52", "k2":"k2-52"},b-52 +53,a-53,{"k1":"k1-53", "k2":"k2-53"},b-53 +54,a-54,{"k1":"k1-54", "k2":"k2-54"},b-54 +55,a-55,{"k1":"k1-55", "k2":"k2-55"},b-55 +56,a-56,{"k1":"k1-56", "k2":"k2-56"},b-56 +57,a-57,{"k1":"k1-57", "k2":"k2-57"},b-57 +58,a-58,{"k1":"k1-58", "k2":"k2-58"},b-58 +59,a-59,{"k1":"k1-59", "k2":"k2-59"},b-59 +6,a-6,{"k1":"k1-6", "k2":"k2-6"},b-6 +60,a-60,{"k1":"k1-60", "k2":"k2-60"},b-60 +61,a-61,{"k1":"k1-61", "k2":"k2-61"},b-61 +62,a-62,{"k1":"k1-62", "k2":"k2-62"},b-62 +63,a-63,{"k1":"k1-63", "k2":"k2-63"},b-63 +64,a-64,{"k1":"k1-64", "k2":"k2-64"},b-64 +65,a-65,{"k1":"k1-65", "k2":"k2-65"},b-65 +66,a-66,{"k1":"k1-66", "k2":"k2-66"},b-66 +67,a-67,{"k1":"k1-67", "k2":"k2-67"},b-67 +68,a-68,{"k1":"k1-68", "k2":"k2-68"},b-68 +69,a-69,{"k1":"k1-69", "k2":"k2-69"},b-69 +7,a-7,{"k1":"k1-7", "k2":"k2-7"},b-7 +70,a-70,{"k1":"k1-70", "k2":"k2-70"},b-70 +71,a-71,{"k1":"k1-71", "k2":"k2-71"},b-71 +72,a-72,{"k1":"k1-72", "k2":"k2-72"},b-72 +73,a-73,{"k1":"k1-73", "k2":"k2-73"},b-73 +74,a-74,{"k1":"k1-74", "k2":"k2-74"},b-74 +75,a-75,{"k1":"k1-75", "k2":"k2-75"},b-75 +76,a-76,{"k1":"k1-76", "k2":"k2-76"},b-76 +77,a-77,{"k1":"k1-77", "k2":"k2-77"},b-77 +78,a-78,{"k1":"k1-78", "k2":"k2-78"},b-78 +79,a-79,{"k1":"k1-79", "k2":"k2-79"},b-79 +8,a-8,{"k1":"k1-8", "k2":"k2-8"},b-8 +80,a-80,{"k1":"k1-80", "k2":"k2-80"},b-80 +81,a-81,{"k1":"k1-81", "k2":"k2-81"},b-81 +82,a-82,{"k1":"k1-82", "k2":"k2-82"},b-82 +83,a-83,{"k1":"k1-83", "k2":"k2-83"},b-83 +84,a-84,{"k1":"k1-84", "k2":"k2-84"},b-84 +85,a-85,{"k1":"k1-85", "k2":"k2-85"},b-85 +86,a-86,{"k1":"k1-86", "k2":"k2-86"},b-86 +87,a-87,{"k1":"k1-87", "k2":"k2-87"},b-87 +88,a-88,{"k1":"k1-88", "k2":"k2-88"},b-88 +89,a-89,{"k1":"k1-89", "k2":"k2-89"},b-89 +9,a-9,{"k1":"k1-9", "k2":"k2-9"},b-9 +90,a-90,{"k1":"k1-90", "k2":"k2-90"},b-90 +91,a-91,{"k1":"k1-91", "k2":"k2-91"},b-91 +92,a-92,{"k1":"k1-92", "k2":"k2-92"},b-92 +93,a-93,{"k1":"k1-93", "k2":"k2-93"},b-93 +94,a-94,{"k1":"k1-94", "k2":"k2-94"},b-94 +95,a-95,{"k1":"k1-95", "k2":"k2-95"},b-95 +96,a-96,{"k1":"k1-96", "k2":"k2-96"},b-96 +97,a-97,{"k1":"k1-97", "k2":"k2-97"},b-97 +98,a-98,{"k1":"k1-98", "k2":"k2-98"},b-98 +99,a-99,{"k1":"k1-99", "k2":"k2-99"},b-99 \ No newline at end of file http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInSubquery/testInAndNotInSubQuery.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInSubquery/testInAndNotInSubQuery.result b/tajo-core-tests/src/test/resources/results/TestInSubquery/testInAndNotInSubQuery.result new file mode 100644 index 0000000..1acab75 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInSubquery/testInAndNotInSubQuery.result @@ -0,0 +1,24 @@ +n_name +------------------------------- +ALGERIA +BRAZIL +CANADA +CHINA +EGYPT +FRANCE +GERMANY +INDIA +INDONESIA +IRAN +IRAQ +JAPAN +JORDAN +KENYA +MOZAMBIQUE +PERU +ROMANIA +RUSSIA +SAUDI ARABIA +UNITED KINGDOM +UNITED STATES +VIETNAM http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQuery.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQuery.result b/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQuery.result new file mode 100644 index 0000000..7644296 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQuery.result @@ -0,0 +1,27 @@ +n_name +------------------------------- +ALGERIA +ARGENTINA +BRAZIL +CANADA +CHINA +EGYPT +ETHIOPIA +FRANCE +GERMANY +INDIA +INDONESIA +IRAN +IRAQ +JAPAN +JORDAN +KENYA +MOROCCO +MOZAMBIQUE +PERU +ROMANIA +RUSSIA +SAUDI ARABIA +UNITED KINGDOM +UNITED STATES +VIETNAM http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQuery2.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQuery2.result b/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQuery2.result new file mode 100644 index 0000000..fbab93d --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQuery2.result @@ -0,0 +1,3 @@ +n_name +------------------------------- +ETHIOPIA http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQueryWithJoin.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQueryWithJoin.result b/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQueryWithJoin.result new file mode 100644 index 0000000..1deee15 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQueryWithJoin.result @@ -0,0 +1,5 @@ +n_name +------------------------------- +ARGENTINA +ETHIOPIA +MOROCCO http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQueryWithOtherConditions.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQueryWithOtherConditions.result b/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQueryWithOtherConditions.result new file mode 100644 index 0000000..8367869 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQueryWithOtherConditions.result @@ -0,0 +1,25 @@ +n_name +------------------------------- +BRAZIL +CANADA +CHINA +EGYPT +ETHIOPIA +FRANCE +GERMANY +INDIA +INDONESIA +IRAN +IRAQ +JAPAN +JORDAN +KENYA +MOROCCO +MOZAMBIQUE +PERU +ROMANIA +RUSSIA +SAUDI ARABIA +UNITED KINGDOM +UNITED STATES +VIETNAM http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQueryWithTableSubQuery.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQueryWithTableSubQuery.result b/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQueryWithTableSubQuery.result new file mode 100644 index 0000000..d386836 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInSubquery/testInSubQueryWithTableSubQuery.result @@ -0,0 +1,4 @@ +n_name +------------------------------- +INDIA +INDONESIA http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInSubquery/testMultipleInSubQuery.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInSubquery/testMultipleInSubQuery.result b/tajo-core-tests/src/test/resources/results/TestInSubquery/testMultipleInSubQuery.result new file mode 100644 index 0000000..1deee15 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInSubquery/testMultipleInSubQuery.result @@ -0,0 +1,5 @@ +n_name +------------------------------- +ARGENTINA +ETHIOPIA +MOROCCO http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInSubquery/testMultipleNotInSubQuery.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInSubquery/testMultipleNotInSubQuery.result b/tajo-core-tests/src/test/resources/results/TestInSubquery/testMultipleNotInSubQuery.result new file mode 100644 index 0000000..a1e17d5 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInSubquery/testMultipleNotInSubQuery.result @@ -0,0 +1,20 @@ +n_name +------------------------------- +CHINA +FRANCE +GERMANY +INDIA +INDONESIA +IRAN +IRAQ +JAPAN +JORDAN +KENYA +MOZAMBIQUE +PERU +ROMANIA +RUSSIA +SAUDI ARABIA +UNITED KINGDOM +UNITED STATES +VIETNAM http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInSubquery/testNestedInAndNotInSubQuery.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInSubquery/testNestedInAndNotInSubQuery.result b/tajo-core-tests/src/test/resources/results/TestInSubquery/testNestedInAndNotInSubQuery.result new file mode 100644 index 0000000..51e570a --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInSubquery/testNestedInAndNotInSubQuery.result @@ -0,0 +1,3 @@ +c_name +------------------------------- +Customer#000000005 http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInSubquery/testNestedInSubQuery.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInSubquery/testNestedInSubQuery.result b/tajo-core-tests/src/test/resources/results/TestInSubquery/testNestedInSubQuery.result new file mode 100644 index 0000000..51e570a --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInSubquery/testNestedInSubQuery.result @@ -0,0 +1,3 @@ +c_name +------------------------------- +Customer#000000005 http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInSubquery/testNestedInSubQuery2.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInSubquery/testNestedInSubQuery2.result b/tajo-core-tests/src/test/resources/results/TestInSubquery/testNestedInSubQuery2.result new file mode 100644 index 0000000..51e570a --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInSubquery/testNestedInSubQuery2.result @@ -0,0 +1,3 @@ +c_name +------------------------------- +Customer#000000005 http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInSubquery/testNestedNotInSubQuery.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInSubquery/testNestedNotInSubQuery.result b/tajo-core-tests/src/test/resources/results/TestInSubquery/testNestedNotInSubQuery.result new file mode 100644 index 0000000..e746b35 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInSubquery/testNestedNotInSubQuery.result @@ -0,0 +1,7 @@ +c_name +------------------------------- +Customer#000000001 +Customer#000000002 +Customer#000000003 +Customer#000000004 +Customer#000000005 http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInSubquery/testNotInSubQuery.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInSubquery/testNotInSubQuery.result b/tajo-core-tests/src/test/resources/results/TestInSubquery/testNotInSubQuery.result new file mode 100644 index 0000000..50b69bd --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInSubquery/testNotInSubQuery.result @@ -0,0 +1,22 @@ +n_name +------------------------------- +CHINA +ETHIOPIA +FRANCE +GERMANY +INDIA +INDONESIA +IRAN +IRAQ +JAPAN +JORDAN +KENYA +MOROCCO +MOZAMBIQUE +PERU +ROMANIA +RUSSIA +SAUDI ARABIA +UNITED KINGDOM +UNITED STATES +VIETNAM http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInSubquery/testSameKeyNameOfOuterAndInnerQueries.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInSubquery/testSameKeyNameOfOuterAndInnerQueries.result b/tajo-core-tests/src/test/resources/results/TestInSubquery/testSameKeyNameOfOuterAndInnerQueries.result new file mode 100644 index 0000000..e3d9398 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInSubquery/testSameKeyNameOfOuterAndInnerQueries.result @@ -0,0 +1,3 @@ +n_regionkey,?count +------------------------------- +1,1 http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInSubquery/testWithAsteriskAndJoin.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInSubquery/testWithAsteriskAndJoin.result b/tajo-core-tests/src/test/resources/results/TestInSubquery/testWithAsteriskAndJoin.result new file mode 100644 index 0000000..734ce36 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInSubquery/testWithAsteriskAndJoin.result @@ -0,0 +1,6 @@ +l_orderkey,l_partkey,l_suppkey,l_linenumber,l_quantity,l_extendedprice,l_discount,l_tax,l_returnflag,l_linestatus,l_shipdate,l_commitdate,l_receiptdate,l_shipinstruct,l_shipmode,l_comment,o_orderkey,o_custkey,o_orderstatus,o_totalprice,o_orderdate,o_orderpriority,o_clerk,o_shippriority,o_comment +------------------------------- +1,1,7311,2,36.0,45983.16,0.09,0.06,N,O,1996-04-12,1996-02-28,1996-04-20,TAKE BACK RETURN,MAIL,ly final dependencies: slyly bold ,1,3,O,173665.47,1996-01-02,5-LOW,Clerk#000000951,0,nstructions sleep furiously among +1,1,7706,1,17.0,21168.23,0.04,0.02,N,O,1996-03-13,1996-02-12,1996-03-22,DELIVER IN PERSON,TRUCK,egular courts above the,1,3,O,173665.47,1996-01-02,5-LOW,Clerk#000000951,0,nstructions sleep furiously among +2,2,1191,1,38.0,44694.46,0.0,0.05,N,O,1997-01-28,1997-01-14,1997-02-02,TAKE BACK RETURN,RAIL,ven requests. deposits breach a,2,4,O,46929.18,1996-12-01,1-URGENT,Clerk#000000880,0, foxes. pending accounts at the pending, silent asymptot +3,2,1798,1,45.0,54058.05,0.06,0.0,R,F,1994-02-02,1994-01-04,1994-02-23,NONE,AIR,ongside of the furiously brave acco,3,2,F,193846.25,1993-10-14,5-LOW,Clerk#000000955,0,sly final accounts boost. carefully regular ideas cajole carefully. depos http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnMultipleExprs.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnMultipleExprs.result b/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnMultipleExprs.result new file mode 100644 index 0000000..bcb645d --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnMultipleExprs.result @@ -0,0 +1,3 @@ +l_orderkey,l_linenumber +------------------------------- +3,2 \ No newline at end of file http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnMultipleKeys.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnMultipleKeys.result b/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnMultipleKeys.result new file mode 100644 index 0000000..86d468e --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnMultipleKeys.result @@ -0,0 +1,3 @@ +l_orderkey,l_shipdate,l_comment +------------------------------- +2,1997-01-28,ven requests. deposits breach a \ No newline at end of file http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnMultipleKeys2.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnMultipleKeys2.result b/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnMultipleKeys2.result new file mode 100644 index 0000000..86d468e --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnMultipleKeys2.result @@ -0,0 +1,3 @@ +l_orderkey,l_shipdate,l_comment +------------------------------- +2,1997-01-28,ven requests. deposits breach a \ No newline at end of file http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnSortedNonUniqueKeys.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnSortedNonUniqueKeys.result b/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnSortedNonUniqueKeys.result new file mode 100644 index 0000000..fb8a4c2 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnSortedNonUniqueKeys.result @@ -0,0 +1,4 @@ +l_orderkey,l_partkey,l_suppkey,l_linenumber,l_quantity,l_extendedprice,l_discount,l_tax,l_returnflag,l_linestatus,l_shipdate,l_commitdate,l_receiptdate,l_shipinstruct,l_shipmode,l_comment +------------------------------- +1,1,7706,1,17.0,21168.23,0.04,0.02,N,O,1996-03-13,1996-02-12,1996-03-22,DELIVER IN PERSON,TRUCK,egular courts above the +1,1,7311,2,36.0,45983.16,0.09,0.06,N,O,1996-04-12,1996-02-28,1996-04-20,TAKE BACK RETURN,MAIL,ly final dependencies: slyly bold \ No newline at end of file http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnUnsortedTextKeys.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnUnsortedTextKeys.result b/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnUnsortedTextKeys.result new file mode 100644 index 0000000..86d468e --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestIndexScan/testOnUnsortedTextKeys.result @@ -0,0 +1,3 @@ +l_orderkey,l_shipdate,l_comment +------------------------------- +2,1997-01-28,ven requests. deposits breach a \ No newline at end of file http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestIndexScan/testWithGroupBy.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestIndexScan/testWithGroupBy.result b/tajo-core-tests/src/test/resources/results/TestIndexScan/testWithGroupBy.result new file mode 100644 index 0000000..2d1d12e --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestIndexScan/testWithGroupBy.result @@ -0,0 +1,3 @@ +l_shipdate,?count +------------------------------- +1997-01-28,1 \ No newline at end of file http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestIndexScan/testWithJoin.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestIndexScan/testWithJoin.result b/tajo-core-tests/src/test/resources/results/TestIndexScan/testWithJoin.result new file mode 100644 index 0000000..d119969 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestIndexScan/testWithJoin.result @@ -0,0 +1,4 @@ +l_shipdate,o_orderstatus +------------------------------- +1996-03-13,O +1996-04-12,O \ No newline at end of file http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestIndexScan/testWithSort.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestIndexScan/testWithSort.result b/tajo-core-tests/src/test/resources/results/TestIndexScan/testWithSort.result new file mode 100644 index 0000000..774a411 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestIndexScan/testWithSort.result @@ -0,0 +1,4 @@ +l_shipdate +------------------------------- +1996-03-13 +1996-04-12 \ No newline at end of file http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Hash.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Hash.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Hash.plan new file mode 100644 index 0000000..bd3ba1a --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Hash.plan @@ -0,0 +1,135 @@ +explain +------------------------------- +SORT(6) + => Sort Keys: default.lineitem.l_orderkey (INT4) (asc),default.part.p_name (TEXT) (asc),default.nation.n_name (TEXT) (asc) + JOIN(16)(INNER) + => Join Cond: default.orders.o_custkey (INT4) = default.customer.c_custkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT)} + => in schema: {(5) default.customer.c_custkey (INT4), default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.orders.o_custkey (INT4), default.part.p_name (TEXT)} + JOIN(15)(INNER) + => Join Cond: default.customer.c_nationkey (INT4) = default.nation.n_nationkey (INT4) + => target list: default.customer.c_custkey (INT4), default.nation.n_name (TEXT) + => out schema: {(2) default.customer.c_custkey (INT4), default.nation.n_name (TEXT)} + => in schema: {(4) default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4), default.nation.n_name (TEXT), default.nation.n_nationkey (INT4)} + SCAN(3) on default.customer + => target list: default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4) + => out schema: {(2) default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4)} + => in schema: {(8) default.customer.c_acctbal (FLOAT8), default.customer.c_address (TEXT), default.customer.c_comment (TEXT), default.customer.c_custkey (INT4), default.customer.c_mktsegment (TEXT), default.customer.c_name (TEXT), default.customer.c_nationkey (INT4), default.customer.c_phone (TEXT)} + SCAN(4) on default.nation + => target list: default.nation.n_name (TEXT), default.nation.n_nationkey (INT4) + => out schema: {(2) default.nation.n_name (TEXT), default.nation.n_nationkey (INT4)} + => in schema: {(4) default.nation.n_comment (TEXT), default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)} + JOIN(14)(INNER) + => Join Cond: default.lineitem.l_partkey (INT4) = default.part.p_partkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT)} + => in schema: {(5) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT), default.part.p_partkey (INT4)} + SCAN(2) on default.part + => target list: default.part.p_name (TEXT), default.part.p_partkey (INT4) + => out schema: {(2) default.part.p_name (TEXT), default.part.p_partkey (INT4)} + => in schema: {(9) default.part.p_brand (TEXT), default.part.p_comment (TEXT), default.part.p_container (TEXT), default.part.p_mfgr (TEXT), default.part.p_name (TEXT), default.part.p_partkey (INT4), default.part.p_retailprice (FLOAT8), default.part.p_size (INT4), default.part.p_type (TEXT)} + JOIN(13)(INNER) + => Join Cond: default.lineitem.l_orderkey (INT4) = default.orders.o_orderkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4)} + => in schema: {(4) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4)} + SCAN(1) on default.orders + => target list: default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4) + => out schema: {(2) default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4)} + => in schema: {(9) default.orders.o_clerk (TEXT), default.orders.o_comment (TEXT), default.orders.o_custkey (INT4), default.orders.o_orderdate (TEXT), default.orders.o_orderkey (INT4), default.orders.o_orderpriority (TEXT), default.orders.o_orderstatus (TEXT), default.orders.o_shippriority (INT4), default.orders.o_totalprice (FLOAT8)} + SCAN(0) on default.lineitem + => target list: default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4) + => out schema: {(2) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4)} + => in schema: {(16) default.lineitem.l_comment (TEXT), default.lineitem.l_commitdate (TEXT), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice (FLOAT8), default.lineitem.l_linenumber (INT4), default.lineitem.l_linestatus (TEXT), default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.lineitem.l_quantity (FLOAT8), default.lineitem.l_receiptdate (TEXT), default.lineitem.l_returnflag (TEXT), default.lineitem.l_shipdate (TEXT), default.lineitem.l_shipinstruct (TEXT), default.lineitem.l_shipmode (TEXT), default.lineitem.l_suppkey (INT4), default.lineitem.l_tax (FLOAT8)} +explain +------------------------------- +------------------------------------------------------------------------------- +Execution Block Graph (TERMINAL - eb_0000000000000_0000_000011) +------------------------------------------------------------------------------- +|-eb_0000000000000_0000_000011 + |-eb_0000000000000_0000_000010 + |-eb_0000000000000_0000_000009 +------------------------------------------------------------------------------- +Order of Execution +------------------------------------------------------------------------------- +1: eb_0000000000000_0000_000009 +2: eb_0000000000000_0000_000010 +3: eb_0000000000000_0000_000011 +------------------------------------------------------------------------------- + +======================================================= +Block Id: eb_0000000000000_0000_000009 [LEAF] +======================================================= + +[Outgoing] +[q_0000000000000_0000] 9 => 10 (type=RANGE_SHUFFLE, key=default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT), num=32) + +[Enforcers] + 0: type=Broadcast, tables=default.orders + 1: type=Broadcast, tables=default.part + 2: type=Broadcast, tables=default.lineitem + 3: type=Broadcast, tables=default.customer + +SORT(26) + => Sort Keys: default.lineitem.l_orderkey (INT4) (asc),default.part.p_name (TEXT) (asc),default.nation.n_name (TEXT) (asc) + JOIN(16)(INNER) + => Join Cond: default.orders.o_custkey (INT4) = default.customer.c_custkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT)} + => in schema: {(5) default.customer.c_custkey (INT4), default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.orders.o_custkey (INT4), default.part.p_name (TEXT)} + JOIN(15)(INNER) + => Join Cond: default.customer.c_nationkey (INT4) = default.nation.n_nationkey (INT4) + => target list: default.customer.c_custkey (INT4), default.nation.n_name (TEXT) + => out schema: {(2) default.customer.c_custkey (INT4), default.nation.n_name (TEXT)} + => in schema: {(4) default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4), default.nation.n_name (TEXT), default.nation.n_nationkey (INT4)} + SCAN(3) on default.customer + => target list: default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4) + => out schema: {(2) default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4)} + => in schema: {(8) default.customer.c_acctbal (FLOAT8), default.customer.c_address (TEXT), default.customer.c_comment (TEXT), default.customer.c_custkey (INT4), default.customer.c_mktsegment (TEXT), default.customer.c_name (TEXT), default.customer.c_nationkey (INT4), default.customer.c_phone (TEXT)} + SCAN(4) on default.nation + => target list: default.nation.n_name (TEXT), default.nation.n_nationkey (INT4) + => out schema: {(2) default.nation.n_name (TEXT), default.nation.n_nationkey (INT4)} + => in schema: {(4) default.nation.n_comment (TEXT), default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)} + JOIN(14)(INNER) + => Join Cond: default.lineitem.l_partkey (INT4) = default.part.p_partkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT)} + => in schema: {(5) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT), default.part.p_partkey (INT4)} + SCAN(2) on default.part + => target list: default.part.p_name (TEXT), default.part.p_partkey (INT4) + => out schema: {(2) default.part.p_name (TEXT), default.part.p_partkey (INT4)} + => in schema: {(9) default.part.p_brand (TEXT), default.part.p_comment (TEXT), default.part.p_container (TEXT), default.part.p_mfgr (TEXT), default.part.p_name (TEXT), default.part.p_partkey (INT4), default.part.p_retailprice (FLOAT8), default.part.p_size (INT4), default.part.p_type (TEXT)} + JOIN(13)(INNER) + => Join Cond: default.lineitem.l_orderkey (INT4) = default.orders.o_orderkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4)} + => in schema: {(4) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4)} + SCAN(1) on default.orders + => target list: default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4) + => out schema: {(2) default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4)} + => in schema: {(9) default.orders.o_clerk (TEXT), default.orders.o_comment (TEXT), default.orders.o_custkey (INT4), default.orders.o_orderdate (TEXT), default.orders.o_orderkey (INT4), default.orders.o_orderpriority (TEXT), default.orders.o_orderstatus (TEXT), default.orders.o_shippriority (INT4), default.orders.o_totalprice (FLOAT8)} + SCAN(0) on default.lineitem + => target list: default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4) + => out schema: {(2) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4)} + => in schema: {(16) default.lineitem.l_comment (TEXT), default.lineitem.l_commitdate (TEXT), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice (FLOAT8), default.lineitem.l_linenumber (INT4), default.lineitem.l_linestatus (TEXT), default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.lineitem.l_quantity (FLOAT8), default.lineitem.l_receiptdate (TEXT), default.lineitem.l_returnflag (TEXT), default.lineitem.l_shipdate (TEXT), default.lineitem.l_shipinstruct (TEXT), default.lineitem.l_shipmode (TEXT), default.lineitem.l_suppkey (INT4), default.lineitem.l_tax (FLOAT8)} + +======================================================= +Block Id: eb_0000000000000_0000_000010 [ROOT] +======================================================= + +[Incoming] +[q_0000000000000_0000] 9 => 10 (type=RANGE_SHUFFLE, key=default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT), num=32) + +[Enforcers] + 0: sorted input=eb_0000000000000_0000_000009 + +SORT(6) + => Sort Keys: default.lineitem.l_orderkey (INT4) (asc),default.part.p_name (TEXT) (asc),default.nation.n_name (TEXT) (asc) + SCAN(27) on eb_0000000000000_0000_000009 + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT)} + => in schema: {(3) default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT)} + +======================================================= +Block Id: eb_0000000000000_0000_000011 [TERMINAL] +======================================================= http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Hash_NoBroadcast.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Hash_NoBroadcast.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Hash_NoBroadcast.plan new file mode 100644 index 0000000..fc5e3e3 --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Hash_NoBroadcast.plan @@ -0,0 +1,249 @@ +explain +------------------------------- +SORT(6) + => Sort Keys: default.lineitem.l_orderkey (INT4) (asc),default.part.p_name (TEXT) (asc),default.nation.n_name (TEXT) (asc) + JOIN(16)(INNER) + => Join Cond: default.orders.o_custkey (INT4) = default.customer.c_custkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT)} + => in schema: {(5) default.customer.c_custkey (INT4), default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.orders.o_custkey (INT4), default.part.p_name (TEXT)} + JOIN(15)(INNER) + => Join Cond: default.customer.c_nationkey (INT4) = default.nation.n_nationkey (INT4) + => target list: default.customer.c_custkey (INT4), default.nation.n_name (TEXT) + => out schema: {(2) default.customer.c_custkey (INT4), default.nation.n_name (TEXT)} + => in schema: {(4) default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4), default.nation.n_name (TEXT), default.nation.n_nationkey (INT4)} + SCAN(3) on default.customer + => target list: default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4) + => out schema: {(2) default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4)} + => in schema: {(8) default.customer.c_acctbal (FLOAT8), default.customer.c_address (TEXT), default.customer.c_comment (TEXT), default.customer.c_custkey (INT4), default.customer.c_mktsegment (TEXT), default.customer.c_name (TEXT), default.customer.c_nationkey (INT4), default.customer.c_phone (TEXT)} + SCAN(4) on default.nation + => target list: default.nation.n_name (TEXT), default.nation.n_nationkey (INT4) + => out schema: {(2) default.nation.n_name (TEXT), default.nation.n_nationkey (INT4)} + => in schema: {(4) default.nation.n_comment (TEXT), default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)} + JOIN(14)(INNER) + => Join Cond: default.lineitem.l_partkey (INT4) = default.part.p_partkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT)} + => in schema: {(5) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT), default.part.p_partkey (INT4)} + SCAN(2) on default.part + => target list: default.part.p_name (TEXT), default.part.p_partkey (INT4) + => out schema: {(2) default.part.p_name (TEXT), default.part.p_partkey (INT4)} + => in schema: {(9) default.part.p_brand (TEXT), default.part.p_comment (TEXT), default.part.p_container (TEXT), default.part.p_mfgr (TEXT), default.part.p_name (TEXT), default.part.p_partkey (INT4), default.part.p_retailprice (FLOAT8), default.part.p_size (INT4), default.part.p_type (TEXT)} + JOIN(13)(INNER) + => Join Cond: default.lineitem.l_orderkey (INT4) = default.orders.o_orderkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4)} + => in schema: {(4) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4)} + SCAN(1) on default.orders + => target list: default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4) + => out schema: {(2) default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4)} + => in schema: {(9) default.orders.o_clerk (TEXT), default.orders.o_comment (TEXT), default.orders.o_custkey (INT4), default.orders.o_orderdate (TEXT), default.orders.o_orderkey (INT4), default.orders.o_orderpriority (TEXT), default.orders.o_orderstatus (TEXT), default.orders.o_shippriority (INT4), default.orders.o_totalprice (FLOAT8)} + SCAN(0) on default.lineitem + => target list: default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4) + => out schema: {(2) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4)} + => in schema: {(16) default.lineitem.l_comment (TEXT), default.lineitem.l_commitdate (TEXT), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice (FLOAT8), default.lineitem.l_linenumber (INT4), default.lineitem.l_linestatus (TEXT), default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.lineitem.l_quantity (FLOAT8), default.lineitem.l_receiptdate (TEXT), default.lineitem.l_returnflag (TEXT), default.lineitem.l_shipdate (TEXT), default.lineitem.l_shipinstruct (TEXT), default.lineitem.l_shipmode (TEXT), default.lineitem.l_suppkey (INT4), default.lineitem.l_tax (FLOAT8)} +explain +------------------------------- +------------------------------------------------------------------------------- +Execution Block Graph (TERMINAL - eb_0000000000000_0000_000011) +------------------------------------------------------------------------------- +|-eb_0000000000000_0000_000011 + |-eb_0000000000000_0000_000010 + |-eb_0000000000000_0000_000009 + |-eb_0000000000000_0000_000008 + |-eb_0000000000000_0000_000007 + |-eb_0000000000000_0000_000006 + |-eb_0000000000000_0000_000005 + |-eb_0000000000000_0000_000004 + |-eb_0000000000000_0000_000003 + |-eb_0000000000000_0000_000002 + |-eb_0000000000000_0000_000001 +------------------------------------------------------------------------------- +Order of Execution +------------------------------------------------------------------------------- +1: eb_0000000000000_0000_000001 +2: eb_0000000000000_0000_000002 +3: eb_0000000000000_0000_000003 +4: eb_0000000000000_0000_000004 +5: eb_0000000000000_0000_000006 +6: eb_0000000000000_0000_000007 +7: eb_0000000000000_0000_000005 +8: eb_0000000000000_0000_000008 +9: eb_0000000000000_0000_000009 +10: eb_0000000000000_0000_000010 +11: eb_0000000000000_0000_000011 +------------------------------------------------------------------------------- + +======================================================= +Block Id: eb_0000000000000_0000_000001 [LEAF] +======================================================= + +[Outgoing] +[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, key=default.lineitem.l_orderkey (INT4), num=32) + +SCAN(0) on default.lineitem + => target list: default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4) + => out schema: {(2) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4)} + => in schema: {(16) default.lineitem.l_comment (TEXT), default.lineitem.l_commitdate (TEXT), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice (FLOAT8), default.lineitem.l_linenumber (INT4), default.lineitem.l_linestatus (TEXT), default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.lineitem.l_quantity (FLOAT8), default.lineitem.l_receiptdate (TEXT), default.lineitem.l_returnflag (TEXT), default.lineitem.l_shipdate (TEXT), default.lineitem.l_shipinstruct (TEXT), default.lineitem.l_shipmode (TEXT), default.lineitem.l_suppkey (INT4), default.lineitem.l_tax (FLOAT8)} + +======================================================= +Block Id: eb_0000000000000_0000_000002 [LEAF] +======================================================= + +[Outgoing] +[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, key=default.orders.o_orderkey (INT4), num=32) + +SCAN(1) on default.orders + => target list: default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4) + => out schema: {(2) default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4)} + => in schema: {(9) default.orders.o_clerk (TEXT), default.orders.o_comment (TEXT), default.orders.o_custkey (INT4), default.orders.o_orderdate (TEXT), default.orders.o_orderkey (INT4), default.orders.o_orderpriority (TEXT), default.orders.o_orderstatus (TEXT), default.orders.o_shippriority (INT4), default.orders.o_totalprice (FLOAT8)} + +======================================================= +Block Id: eb_0000000000000_0000_000003 [INTERMEDIATE] +======================================================= + +[Incoming] +[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, key=default.lineitem.l_orderkey (INT4), num=32) +[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, key=default.orders.o_orderkey (INT4), num=32) + +[Outgoing] +[q_0000000000000_0000] 3 => 5 (type=HASH_SHUFFLE, key=default.lineitem.l_partkey (INT4), num=32) + +JOIN(13)(INNER) + => Join Cond: default.lineitem.l_orderkey (INT4) = default.orders.o_orderkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4)} + => in schema: {(4) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4)} + SCAN(19) on eb_0000000000000_0000_000002 + => out schema: {(2) default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4)} + => in schema: {(2) default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4)} + SCAN(18) on eb_0000000000000_0000_000001 + => out schema: {(2) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4)} + => in schema: {(2) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4)} + +======================================================= +Block Id: eb_0000000000000_0000_000004 [LEAF] +======================================================= + +[Outgoing] +[q_0000000000000_0000] 4 => 5 (type=HASH_SHUFFLE, key=default.part.p_partkey (INT4), num=32) + +SCAN(2) on default.part + => target list: default.part.p_name (TEXT), default.part.p_partkey (INT4) + => out schema: {(2) default.part.p_name (TEXT), default.part.p_partkey (INT4)} + => in schema: {(9) default.part.p_brand (TEXT), default.part.p_comment (TEXT), default.part.p_container (TEXT), default.part.p_mfgr (TEXT), default.part.p_name (TEXT), default.part.p_partkey (INT4), default.part.p_retailprice (FLOAT8), default.part.p_size (INT4), default.part.p_type (TEXT)} + +======================================================= +Block Id: eb_0000000000000_0000_000006 [LEAF] +======================================================= + +[Outgoing] +[q_0000000000000_0000] 6 => 8 (type=HASH_SHUFFLE, key=default.nation.n_nationkey (INT4), num=32) + +SCAN(4) on default.nation + => target list: default.nation.n_name (TEXT), default.nation.n_nationkey (INT4) + => out schema: {(2) default.nation.n_name (TEXT), default.nation.n_nationkey (INT4)} + => in schema: {(4) default.nation.n_comment (TEXT), default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)} + +======================================================= +Block Id: eb_0000000000000_0000_000007 [LEAF] +======================================================= + +[Outgoing] +[q_0000000000000_0000] 7 => 8 (type=HASH_SHUFFLE, key=default.customer.c_nationkey (INT4), num=32) + +SCAN(3) on default.customer + => target list: default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4) + => out schema: {(2) default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4)} + => in schema: {(8) default.customer.c_acctbal (FLOAT8), default.customer.c_address (TEXT), default.customer.c_comment (TEXT), default.customer.c_custkey (INT4), default.customer.c_mktsegment (TEXT), default.customer.c_name (TEXT), default.customer.c_nationkey (INT4), default.customer.c_phone (TEXT)} + +======================================================= +Block Id: eb_0000000000000_0000_000005 [INTERMEDIATE] +======================================================= + +[Incoming] +[q_0000000000000_0000] 3 => 5 (type=HASH_SHUFFLE, key=default.lineitem.l_partkey (INT4), num=32) +[q_0000000000000_0000] 4 => 5 (type=HASH_SHUFFLE, key=default.part.p_partkey (INT4), num=32) + +[Outgoing] +[q_0000000000000_0000] 5 => 9 (type=HASH_SHUFFLE, key=default.orders.o_custkey (INT4), num=32) + +JOIN(14)(INNER) + => Join Cond: default.lineitem.l_partkey (INT4) = default.part.p_partkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT)} + => in schema: {(5) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT), default.part.p_partkey (INT4)} + SCAN(21) on eb_0000000000000_0000_000004 + => out schema: {(2) default.part.p_name (TEXT), default.part.p_partkey (INT4)} + => in schema: {(2) default.part.p_name (TEXT), default.part.p_partkey (INT4)} + SCAN(20) on eb_0000000000000_0000_000003 + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4)} + => in schema: {(3) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4)} + +======================================================= +Block Id: eb_0000000000000_0000_000008 [INTERMEDIATE] +======================================================= + +[Incoming] +[q_0000000000000_0000] 6 => 8 (type=HASH_SHUFFLE, key=default.nation.n_nationkey (INT4), num=32) +[q_0000000000000_0000] 7 => 8 (type=HASH_SHUFFLE, key=default.customer.c_nationkey (INT4), num=32) + +[Outgoing] +[q_0000000000000_0000] 8 => 9 (type=HASH_SHUFFLE, key=default.customer.c_custkey (INT4), num=32) + +JOIN(15)(INNER) + => Join Cond: default.customer.c_nationkey (INT4) = default.nation.n_nationkey (INT4) + => target list: default.customer.c_custkey (INT4), default.nation.n_name (TEXT) + => out schema: {(2) default.customer.c_custkey (INT4), default.nation.n_name (TEXT)} + => in schema: {(4) default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4), default.nation.n_name (TEXT), default.nation.n_nationkey (INT4)} + SCAN(23) on eb_0000000000000_0000_000007 + => out schema: {(2) default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4)} + => in schema: {(2) default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4)} + SCAN(22) on eb_0000000000000_0000_000006 + => out schema: {(2) default.nation.n_name (TEXT), default.nation.n_nationkey (INT4)} + => in schema: {(2) default.nation.n_name (TEXT), default.nation.n_nationkey (INT4)} + +======================================================= +Block Id: eb_0000000000000_0000_000009 [INTERMEDIATE] +======================================================= + +[Incoming] +[q_0000000000000_0000] 5 => 9 (type=HASH_SHUFFLE, key=default.orders.o_custkey (INT4), num=32) +[q_0000000000000_0000] 8 => 9 (type=HASH_SHUFFLE, key=default.customer.c_custkey (INT4), num=32) + +[Outgoing] +[q_0000000000000_0000] 9 => 10 (type=RANGE_SHUFFLE, key=default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT), num=32) + +SORT(26) + => Sort Keys: default.lineitem.l_orderkey (INT4) (asc),default.part.p_name (TEXT) (asc),default.nation.n_name (TEXT) (asc) + JOIN(16)(INNER) + => Join Cond: default.orders.o_custkey (INT4) = default.customer.c_custkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT)} + => in schema: {(5) default.customer.c_custkey (INT4), default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.orders.o_custkey (INT4), default.part.p_name (TEXT)} + SCAN(25) on eb_0000000000000_0000_000008 + => out schema: {(2) default.customer.c_custkey (INT4), default.nation.n_name (TEXT)} + => in schema: {(2) default.customer.c_custkey (INT4), default.nation.n_name (TEXT)} + SCAN(24) on eb_0000000000000_0000_000005 + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT)} + => in schema: {(3) default.lineitem.l_orderkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT)} + +======================================================= +Block Id: eb_0000000000000_0000_000010 [ROOT] +======================================================= + +[Incoming] +[q_0000000000000_0000] 9 => 10 (type=RANGE_SHUFFLE, key=default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT), num=32) + +[Enforcers] + 0: sorted input=eb_0000000000000_0000_000009 + +SORT(6) + => Sort Keys: default.lineitem.l_orderkey (INT4) (asc),default.part.p_name (TEXT) (asc),default.nation.n_name (TEXT) (asc) + SCAN(27) on eb_0000000000000_0000_000009 + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT)} + => in schema: {(3) default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT)} + +======================================================= +Block Id: eb_0000000000000_0000_000011 [TERMINAL] +======================================================= http://git-wip-us.apache.org/repos/asf/tajo/blob/a4106883/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Sort.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Sort.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Sort.plan new file mode 100644 index 0000000..bd3ba1a --- /dev/null +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Sort.plan @@ -0,0 +1,135 @@ +explain +------------------------------- +SORT(6) + => Sort Keys: default.lineitem.l_orderkey (INT4) (asc),default.part.p_name (TEXT) (asc),default.nation.n_name (TEXT) (asc) + JOIN(16)(INNER) + => Join Cond: default.orders.o_custkey (INT4) = default.customer.c_custkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT)} + => in schema: {(5) default.customer.c_custkey (INT4), default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.orders.o_custkey (INT4), default.part.p_name (TEXT)} + JOIN(15)(INNER) + => Join Cond: default.customer.c_nationkey (INT4) = default.nation.n_nationkey (INT4) + => target list: default.customer.c_custkey (INT4), default.nation.n_name (TEXT) + => out schema: {(2) default.customer.c_custkey (INT4), default.nation.n_name (TEXT)} + => in schema: {(4) default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4), default.nation.n_name (TEXT), default.nation.n_nationkey (INT4)} + SCAN(3) on default.customer + => target list: default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4) + => out schema: {(2) default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4)} + => in schema: {(8) default.customer.c_acctbal (FLOAT8), default.customer.c_address (TEXT), default.customer.c_comment (TEXT), default.customer.c_custkey (INT4), default.customer.c_mktsegment (TEXT), default.customer.c_name (TEXT), default.customer.c_nationkey (INT4), default.customer.c_phone (TEXT)} + SCAN(4) on default.nation + => target list: default.nation.n_name (TEXT), default.nation.n_nationkey (INT4) + => out schema: {(2) default.nation.n_name (TEXT), default.nation.n_nationkey (INT4)} + => in schema: {(4) default.nation.n_comment (TEXT), default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)} + JOIN(14)(INNER) + => Join Cond: default.lineitem.l_partkey (INT4) = default.part.p_partkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT)} + => in schema: {(5) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT), default.part.p_partkey (INT4)} + SCAN(2) on default.part + => target list: default.part.p_name (TEXT), default.part.p_partkey (INT4) + => out schema: {(2) default.part.p_name (TEXT), default.part.p_partkey (INT4)} + => in schema: {(9) default.part.p_brand (TEXT), default.part.p_comment (TEXT), default.part.p_container (TEXT), default.part.p_mfgr (TEXT), default.part.p_name (TEXT), default.part.p_partkey (INT4), default.part.p_retailprice (FLOAT8), default.part.p_size (INT4), default.part.p_type (TEXT)} + JOIN(13)(INNER) + => Join Cond: default.lineitem.l_orderkey (INT4) = default.orders.o_orderkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4)} + => in schema: {(4) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4)} + SCAN(1) on default.orders + => target list: default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4) + => out schema: {(2) default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4)} + => in schema: {(9) default.orders.o_clerk (TEXT), default.orders.o_comment (TEXT), default.orders.o_custkey (INT4), default.orders.o_orderdate (TEXT), default.orders.o_orderkey (INT4), default.orders.o_orderpriority (TEXT), default.orders.o_orderstatus (TEXT), default.orders.o_shippriority (INT4), default.orders.o_totalprice (FLOAT8)} + SCAN(0) on default.lineitem + => target list: default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4) + => out schema: {(2) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4)} + => in schema: {(16) default.lineitem.l_comment (TEXT), default.lineitem.l_commitdate (TEXT), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice (FLOAT8), default.lineitem.l_linenumber (INT4), default.lineitem.l_linestatus (TEXT), default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.lineitem.l_quantity (FLOAT8), default.lineitem.l_receiptdate (TEXT), default.lineitem.l_returnflag (TEXT), default.lineitem.l_shipdate (TEXT), default.lineitem.l_shipinstruct (TEXT), default.lineitem.l_shipmode (TEXT), default.lineitem.l_suppkey (INT4), default.lineitem.l_tax (FLOAT8)} +explain +------------------------------- +------------------------------------------------------------------------------- +Execution Block Graph (TERMINAL - eb_0000000000000_0000_000011) +------------------------------------------------------------------------------- +|-eb_0000000000000_0000_000011 + |-eb_0000000000000_0000_000010 + |-eb_0000000000000_0000_000009 +------------------------------------------------------------------------------- +Order of Execution +------------------------------------------------------------------------------- +1: eb_0000000000000_0000_000009 +2: eb_0000000000000_0000_000010 +3: eb_0000000000000_0000_000011 +------------------------------------------------------------------------------- + +======================================================= +Block Id: eb_0000000000000_0000_000009 [LEAF] +======================================================= + +[Outgoing] +[q_0000000000000_0000] 9 => 10 (type=RANGE_SHUFFLE, key=default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT), num=32) + +[Enforcers] + 0: type=Broadcast, tables=default.orders + 1: type=Broadcast, tables=default.part + 2: type=Broadcast, tables=default.lineitem + 3: type=Broadcast, tables=default.customer + +SORT(26) + => Sort Keys: default.lineitem.l_orderkey (INT4) (asc),default.part.p_name (TEXT) (asc),default.nation.n_name (TEXT) (asc) + JOIN(16)(INNER) + => Join Cond: default.orders.o_custkey (INT4) = default.customer.c_custkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT)} + => in schema: {(5) default.customer.c_custkey (INT4), default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.orders.o_custkey (INT4), default.part.p_name (TEXT)} + JOIN(15)(INNER) + => Join Cond: default.customer.c_nationkey (INT4) = default.nation.n_nationkey (INT4) + => target list: default.customer.c_custkey (INT4), default.nation.n_name (TEXT) + => out schema: {(2) default.customer.c_custkey (INT4), default.nation.n_name (TEXT)} + => in schema: {(4) default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4), default.nation.n_name (TEXT), default.nation.n_nationkey (INT4)} + SCAN(3) on default.customer + => target list: default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4) + => out schema: {(2) default.customer.c_custkey (INT4), default.customer.c_nationkey (INT4)} + => in schema: {(8) default.customer.c_acctbal (FLOAT8), default.customer.c_address (TEXT), default.customer.c_comment (TEXT), default.customer.c_custkey (INT4), default.customer.c_mktsegment (TEXT), default.customer.c_name (TEXT), default.customer.c_nationkey (INT4), default.customer.c_phone (TEXT)} + SCAN(4) on default.nation + => target list: default.nation.n_name (TEXT), default.nation.n_nationkey (INT4) + => out schema: {(2) default.nation.n_name (TEXT), default.nation.n_nationkey (INT4)} + => in schema: {(4) default.nation.n_comment (TEXT), default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)} + JOIN(14)(INNER) + => Join Cond: default.lineitem.l_partkey (INT4) = default.part.p_partkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT)} + => in schema: {(5) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4), default.part.p_name (TEXT), default.part.p_partkey (INT4)} + SCAN(2) on default.part + => target list: default.part.p_name (TEXT), default.part.p_partkey (INT4) + => out schema: {(2) default.part.p_name (TEXT), default.part.p_partkey (INT4)} + => in schema: {(9) default.part.p_brand (TEXT), default.part.p_comment (TEXT), default.part.p_container (TEXT), default.part.p_mfgr (TEXT), default.part.p_name (TEXT), default.part.p_partkey (INT4), default.part.p_retailprice (FLOAT8), default.part.p_size (INT4), default.part.p_type (TEXT)} + JOIN(13)(INNER) + => Join Cond: default.lineitem.l_orderkey (INT4) = default.orders.o_orderkey (INT4) + => target list: default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4) + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4)} + => in schema: {(4) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4)} + SCAN(1) on default.orders + => target list: default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4) + => out schema: {(2) default.orders.o_custkey (INT4), default.orders.o_orderkey (INT4)} + => in schema: {(9) default.orders.o_clerk (TEXT), default.orders.o_comment (TEXT), default.orders.o_custkey (INT4), default.orders.o_orderdate (TEXT), default.orders.o_orderkey (INT4), default.orders.o_orderpriority (TEXT), default.orders.o_orderstatus (TEXT), default.orders.o_shippriority (INT4), default.orders.o_totalprice (FLOAT8)} + SCAN(0) on default.lineitem + => target list: default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4) + => out schema: {(2) default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4)} + => in schema: {(16) default.lineitem.l_comment (TEXT), default.lineitem.l_commitdate (TEXT), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice (FLOAT8), default.lineitem.l_linenumber (INT4), default.lineitem.l_linestatus (TEXT), default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.lineitem.l_quantity (FLOAT8), default.lineitem.l_receiptdate (TEXT), default.lineitem.l_returnflag (TEXT), default.lineitem.l_shipdate (TEXT), default.lineitem.l_shipinstruct (TEXT), default.lineitem.l_shipmode (TEXT), default.lineitem.l_suppkey (INT4), default.lineitem.l_tax (FLOAT8)} + +======================================================= +Block Id: eb_0000000000000_0000_000010 [ROOT] +======================================================= + +[Incoming] +[q_0000000000000_0000] 9 => 10 (type=RANGE_SHUFFLE, key=default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT), num=32) + +[Enforcers] + 0: sorted input=eb_0000000000000_0000_000009 + +SORT(6) + => Sort Keys: default.lineitem.l_orderkey (INT4) (asc),default.part.p_name (TEXT) (asc),default.nation.n_name (TEXT) (asc) + SCAN(27) on eb_0000000000000_0000_000009 + => out schema: {(3) default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT)} + => in schema: {(3) default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT)} + +======================================================= +Block Id: eb_0000000000000_0000_000011 [TERMINAL] +=======================================================
