public class CoGroupFieldedPipesPlatformTest extends PlatformTestCase
Constructor and Description |
---|
CoGroupFieldedPipesPlatformTest() |
Modifier and Type | Method and Description |
---|---|
void |
testCoGroup() |
void |
testCoGroupAfterEvery()
Method testCoGroupAfterEvery tests that a tmp tap is inserted after the Every in the cogroup join
|
void |
testCoGroupAfterEveryNoDeclared()
Tests that CoGroup properly resolves fields when following an Every
|
void |
testCoGroupAroundCoGroup() |
void |
testCoGroupAroundCoGroupWith() |
void |
testCoGroupAroundCoGroupWithout() |
void |
testCoGroupDiffFields() |
void |
testCoGroupDiffFieldsSameFile() |
void |
testCoGroupFilteredBranch()
this test intentionally filters out all values so the intermediate tap is empty.
|
void |
testCoGroupGroupBy() |
void |
testCoGroupInner()
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 |
testCoGroupInnerNull()
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
|
void |
testCoGroupInnerOuter()
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 |
testCoGroupInnerOuterNull()
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 null
|
void |
testCoGroupInnerSingleField() |
void |
testCoGroupMixed()
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 |
testCoGroupOuter()
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 |
testCoGroupOuterInner()
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 |
testCoGroupOuterInnerNull()
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 null null H1
|
void |
testCoGroupOuterNull()
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 null
null null null H1
|
void |
testCoGroupSamePipe() |
void |
testCoGroupSamePipe2() |
void |
testCoGroupSamePipe3() |
void |
testCoGroupSamePipeName() |
void |
testCoGroupSelf() |
void |
testCoGroupWithUnknowns() |
void |
testCross() |
void |
testGroupSplitToCoGroupsTriangle()
Requires rule TapBalanceGroupSplitTriangleTransformer *
|
void |
testJoinNone() |
void |
testMultiJoin() |
void |
testMultiJoinWithSplits()
This test checks that a valid node is created when adding back remainders during unique
path sub-graph partitioning.
|
void |
testSameSourceGroupSplitCoGroup() |
void |
testSplitCoGroupSelf() |
copyFromLocal, disableDebug, getOutputPath, getOutputPathElements, getPlanPathElements, getPlatform, getPlatformName, getProperties, installPlatform, makeOutputPath, setUp, tearDown
asCollection, asCollection, asCollection, asCollection, asList, asList, asSet, asSet, getOutputPath, getPlanPath, getSinkAsList, getSourceAsList, getTestCaseName, getTestName, getTestOutputRoot, getTestPlanRoot, invokeAggregator, invokeAggregator, invokeAggregator, invokeAggregator, invokeAggregator, invokeAggregator, invokeBuffer, invokeBuffer, invokeBuffer, invokeBuffer, invokeBuffer, invokeBuffer, invokeFilter, invokeFilter, invokeFilter, invokeFilter, invokeFilter, invokeFilter, invokeFilter, invokeFilter, invokeFunction, invokeFunction, invokeFunction, invokeFunction, invokeFunction, invokeFunction, invokeFunction, invokeFunction, validateLength, validateLength, validateLength, validateLength, validateLength, validateLength, validateLength, validateLength, validateLength, validateLength
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
public CoGroupFieldedPipesPlatformTest()
public void testCross() throws java.lang.Exception
java.lang.Exception
public void testCoGroup() throws java.lang.Exception
java.lang.Exception
public void testCoGroupSamePipeName() throws java.lang.Exception
java.lang.Exception
public void testCoGroupWithUnknowns() throws java.lang.Exception
java.lang.Exception
public void testCoGroupFilteredBranch() throws java.lang.Exception
java.lang.Exception
public void testCoGroupSelf() throws java.lang.Exception
java.lang.Exception
public void testSplitCoGroupSelf() throws java.lang.Exception
java.lang.Exception
public void testCoGroupAfterEvery() throws java.lang.Exception
java.lang.Exception
- whenpublic void testCoGroupAfterEveryNoDeclared() throws java.lang.Exception
java.lang.Exception
public void testCoGroupInnerSingleField() throws java.lang.Exception
java.lang.Exception
public void testCoGroupInner() throws java.lang.Exception
java.lang.Exception
public void testCoGroupInnerNull() throws java.lang.Exception
java.lang.Exception
public void testCoGroupOuter() throws java.lang.Exception
java.lang.Exception
public void testCoGroupOuterNull() throws java.lang.Exception
java.lang.Exception
public void testCoGroupInnerOuter() throws java.lang.Exception
java.lang.Exception
public void testCoGroupInnerOuterNull() throws java.lang.Exception
java.lang.Exception
public void testCoGroupOuterInner() throws java.lang.Exception
java.lang.Exception
public void testCoGroupOuterInnerNull() throws java.lang.Exception
java.lang.Exception
public void testCoGroupMixed() throws java.lang.Exception
java.lang.Exception
public void testCoGroupDiffFields() throws java.lang.Exception
java.lang.Exception
public void testCoGroupGroupBy() throws java.lang.Exception
java.lang.Exception
public void testCoGroupSamePipe() throws java.lang.Exception
java.lang.Exception
public void testCoGroupSamePipe2() throws java.lang.Exception
java.lang.Exception
public void testCoGroupSamePipe3() throws java.lang.Exception
java.lang.Exception
public void testCoGroupAroundCoGroup() throws java.lang.Exception
java.lang.Exception
public void testCoGroupAroundCoGroupWithout() throws java.lang.Exception
java.lang.Exception
public void testCoGroupAroundCoGroupWith() throws java.lang.Exception
java.lang.Exception
public void testCoGroupDiffFieldsSameFile() throws java.lang.Exception
java.lang.Exception
public void testJoinNone() throws java.lang.Exception
java.lang.Exception
public void testMultiJoin() throws java.lang.Exception
java.lang.Exception
public void testMultiJoinWithSplits() throws java.lang.Exception
java.lang.Exception
public void testSameSourceGroupSplitCoGroup() throws java.lang.Exception
java.lang.Exception
public void testGroupSplitToCoGroupsTriangle() throws java.lang.Exception
java.lang.Exception
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.