|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object junit.framework.Assert junit.framework.TestCase cascading.CascadingTestCase cascading.PlatformTestCase cascading.JoinFieldedPipesPlatformTest
public class JoinFieldedPipesPlatformTest
Nested Class Summary | |
---|---|
static class |
JoinFieldedPipesPlatformTest.AllComparator
|
Field Summary |
---|
Fields inherited from class cascading.PlatformTestCase |
---|
name, ROOT_OUTPUT_PATH |
Constructor Summary | |
---|---|
JoinFieldedPipesPlatformTest()
|
Method Summary | |
---|---|
void |
testCross()
|
void |
testJoin()
|
void |
testJoinAfterEvery()
Method testCoGroupAfterEvery tests that a tmp tap is inserted after the Every in the cogroup join |
void |
testJoinAroundJoinLeftMost()
Same source as leftmost |
void |
testJoinAroundJoinRightMost()
Same source as rightmost should be a single job as the same file accumulates into the joins |
void |
testJoinAroundJoinRightMostSwapped()
Upper as leftmost and rightmost forcing two jobs |
void |
testJoinDiffFields()
|
void |
testJoinFilteredBranch()
this test intentionally filters out all values so the intermediate tap is empty. |
void |
testJoinGroupBy()
|
void |
testJoinGroupByJoin()
|
void |
testJoinInner()
1 a1 1 a2 1 a3 2 b1 3 c1 4 d1 4 d2 4 d3 5 e1 5 e2 5 e3 7 g1 7 g2 7 g3 7 g4 7 g5 null h1 1 A1 1 A2 1 A3 2 B1 2 B2 2 B3 4 D1 6 F1 6 F2 null H1 1 a1 1 A1 1 a1 1 A2 1 a1 1 A3 1 a2 1 A1 1 a2 1 A2 1 a2 1 A3 1 a3 1 A1 1 a3 1 A2 1 a3 1 A3 2 b1 2 B1 2 b1 2 B2 2 b1 2 B3 4 d1 4 D1 4 d2 4 D1 4 d3 4 D1 null h1 null H1 |
void |
testJoinInnerOuter()
1 a1 1 a2 1 a3 2 b1 3 c1 4 d1 4 d2 4 d3 5 e1 5 e2 5 e3 7 g1 7 g2 7 g3 7 g4 7 g5 null h1 1 A1 1 A2 1 A3 2 B1 2 B2 2 B3 4 D1 6 F1 6 F2 null H1 1 a1 1 A1 1 a1 1 A2 1 a1 1 A3 1 a2 1 A1 1 a2 1 A2 1 a2 1 A3 1 a3 1 A1 1 a3 1 A2 1 a3 1 A3 2 b1 2 B1 2 b1 2 B2 2 b1 2 B3 3 c1 null null 4 d1 4 D1 4 d2 4 D1 4 d3 4 D1 5 e1 null null 5 e2 null null 5 e3 null null 7 g1 null null 7 g2 null null 7 g3 null null 7 g4 null null 7 g5 null null null h1 null H1 |
void |
testJoinInnerSingleField()
|
void |
testJoinMergeGroupBy()
When run against a cluster a Merge before a GroupBy can hide the streamed/accumulated nature of a branch. |
void |
testJoinMixed()
1 a 5 b 6 c 5 b 5 e 1 A 2 B 3 C 4 D 5 E 1 a 2 b 3 c 4 d 5 e 1 a 1 A 1 a - - 2 B 2 b - - 3 C 3 c - - 4 D 4 d 5 b 5 E 5 e 5 e 5 E 5 e |
void |
testJoinNone()
|
void |
testJoinOuter()
/** 1 a1 1 a2 1 a3 2 b1 3 c1 4 d1 4 d2 4 d3 5 e1 5 e2 5 e3 7 g1 7 g2 7 g3 7 g4 7 g5 null h1 1 A1 1 A2 1 A3 2 B1 2 B2 2 B3 4 D1 6 F1 6 F2 null H1 1 a1 1 A1 1 a1 1 A2 1 a1 1 A3 1 a2 1 A1 1 a2 1 A2 1 a2 1 A3 1 a3 1 A1 1 a3 1 A2 1 a3 1 A3 2 b1 2 B1 2 b1 2 B2 2 b1 2 B3 3 c1 null null 4 d1 4 D1 4 d2 4 D1 4 d3 4 D1 5 e1 null null 5 e2 null null 5 e3 null null null null 6 F1 null null 6 F2 7 g1 null null 7 g2 null null 7 g3 null null 7 g4 null null 7 g5 null null null h1 null H1 |
void |
testJoinOuterInner()
1 a1 1 a2 1 a3 2 b1 3 c1 4 d1 4 d2 4 d3 5 e1 5 e2 5 e3 7 g1 7 g2 7 g3 7 g4 7 g5 null h1 1 A1 1 A2 1 A3 2 B1 2 B2 2 B3 4 D1 6 F1 6 F2 null H1 1 a1 1 A1 1 a1 1 A2 1 a1 1 A3 1 a2 1 A1 1 a2 1 A2 1 a2 1 A3 1 a3 1 A1 1 a3 1 A2 1 a3 1 A3 2 b1 2 B1 2 b1 2 B2 2 b1 2 B3 4 d1 4 D1 4 d2 4 D1 4 d3 4 D1 null null 6 F1 null null 6 F2 null h1 null H1 |
void |
testJoinSamePipe()
|
void |
testJoinSamePipe2()
|
void |
testJoinSamePipe3()
|
void |
testJoinSamePipeAroundGroupBy()
|
void |
testJoinSamePipeName()
|
void |
testJoinSameSourceIntoJoin()
here the same file is fed into the same HashJoin. |
void |
testJoinSelf()
|
void |
testJoinsIntoCoGroup()
|
void |
testJoinsIntoCoGroupLhs()
This test results in two MR jobs because one join feeds into the accumulated side of the second. |
void |
testJoinsIntoCoGroupLhsSwappedJoin()
This test results in one MR jobs because one join feeds into the streamed side of the second. |
void |
testJoinsIntoCoGroupRhs()
|
void |
testJoinsIntoGroupBy()
Tests that two independent streamed sources with loadable tributaries properly plan into a GroupBy without loading unused sources |
void |
testJoinWithHasher()
Tests Hasher being honored even if default comparator is null. |
void |
testJoinWithUnknowns()
|
Methods inherited from class cascading.PlatformTestCase |
---|
copyFromLocal, disableDebug, getOutputPath, getPathElements, getPlatform, getPlatformName, getProperties, getRootPath, getTestCaseName, getTestName, getTestRoot, installPlatform, setUp, tearDown |
Methods inherited from class junit.framework.TestCase |
---|
assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertFalse, assertFalse, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertTrue, assertTrue, countTestCases, createResult, fail, fail, failNotEquals, failNotSame, failSame, format, getName, run, run, runBare, runTest, setName, toString |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public JoinFieldedPipesPlatformTest()
Method Detail |
---|
public void testCross() throws Exception
Exception
public void testJoin() throws Exception
Exception
public void testJoinSamePipeName() throws Exception
Exception
public void testJoinWithUnknowns() throws Exception
Exception
public void testJoinFilteredBranch() throws Exception
Exception
public void testJoinSelf() throws Exception
Exception
public void testJoinAfterEvery() throws Exception
Exception
- whenpublic void testJoinInnerSingleField() throws Exception
Exception
public void testJoinInner() throws Exception
Exception
public void testJoinOuter() throws Exception
Exception
public void testJoinInnerOuter() throws Exception
Exception
public void testJoinOuterInner() throws Exception
Exception
public void testJoinMixed() throws Exception
Exception
public void testJoinDiffFields() throws Exception
Exception
public void testJoinGroupBy() throws Exception
Exception
public void testJoinSamePipe() throws Exception
Exception
public void testJoinSamePipe2() throws Exception
Exception
public void testJoinSamePipe3() throws Exception
Exception
public void testJoinAroundJoinRightMost() throws Exception
Exception
public void testJoinAroundJoinLeftMost() throws Exception
Exception
public void testJoinAroundJoinRightMostSwapped() throws Exception
Exception
public void testJoinGroupByJoin() throws Exception
Exception
public void testJoinSameSourceIntoJoin() throws Exception
Exception
public void testJoinsIntoGroupBy() throws Exception
Exception
public void testJoinSamePipeAroundGroupBy() throws Exception
Exception
public void testJoinsIntoCoGroupLhs() throws Exception
Exception
public void testJoinsIntoCoGroupLhsSwappedJoin() throws Exception
Exception
public void testJoinsIntoCoGroupRhs() throws Exception
Exception
public void testJoinsIntoCoGroup() throws Exception
Exception
public void testJoinWithHasher() throws Exception
Exception
public void testJoinNone() throws Exception
Exception
public void testJoinMergeGroupBy() throws Exception
Exception
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |