- tearDown() - Method in class cascading.platform.TestPlatform
-
- tearDown() - Method in class cascading.PlatformTestCase
-
- TEST_DATA_PATH - Static variable in interface data.InputData
-
- testChainEndingWithEach() - Method in class cascading.FieldedPipesPlatformTest
-
- testClasspathJar - Static variable in interface data.InputData
-
- testClasspathJarContents - Static variable in interface data.InputData
-
- testCoGroup() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testCoGroupAfterEvery() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
Method testCoGroupAfterEvery tests that a tmp tap is inserted after the Every in the cogroup join
- testCoGroupAfterEveryNoDeclared() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
Tests that CoGroup properly resolves fields when following an Every
- testCoGroupAroundCoGroup() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testCoGroupAroundCoGroupWith() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testCoGroupAroundCoGroupWithout() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testCoGroupDiffFields() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testCoGroupDiffFieldsSameFile() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testCoGroupFilteredBranch() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
this test intentionally filters out all values so the intermediate tap is empty.
- testCoGroupGroupBy() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testCoGroupInner() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
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
- testCoGroupInnerNull() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
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
- testCoGroupInnerOuter() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
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
- testCoGroupInnerOuterNull() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
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
- testCoGroupInnerSingleField() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testCoGroupMixed() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
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
- testCoGroupOuter() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
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
- testCoGroupOuterInner() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
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
- testCoGroupOuterInnerNull() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
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
- testCoGroupOuterNull() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
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
- testCoGroupSamePipe() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testCoGroupSamePipe2() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testCoGroupSamePipe3() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testCoGroupSamePipeName() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testCoGroupSelf() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testCoGroupWithUnknowns() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testConcatenation() - Method in class cascading.FieldedPipesPlatformTest
-
- testCopy() - Method in class cascading.FieldedPipesPlatformTest
-
- testCross() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testCross() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testDelimited - Static variable in interface data.InputData
-
- testDelimitedExtraField - Static variable in interface data.InputData
-
- testDelimitedHeader - Static variable in interface data.InputData
-
- testDelimitedProblematic - Static variable in interface data.InputData
-
- testDelimitedSpecialCharData - Static variable in interface data.InputData
-
- testFiles() - Method in class cascading.ComparePlatformsTest.CompareTestCase
-
- testFilter() - Method in class cascading.FieldedPipesPlatformTest
-
- testFilterAll() - Method in class cascading.FieldedPipesPlatformTest
-
Intentionally filters all values out to test next mr job behaves
- testFilterComplex() - Method in class cascading.FieldedPipesPlatformTest
-
- testForkCoGroupThenHashJoin() - Method in class cascading.JoinFieldedPipesPlatformTest
-
This test checks for a deadlock when the same input is forked, adapted on one edge, then hashjoined back together.
- testForkCoGroupThenHashJoinCoGroupAgain() - Method in class cascading.JoinFieldedPipesPlatformTest
-
This test checks for a deadlock when the same input is forked, adapted on one edge, cogroup with something,
then hashjoined back together.
- testForkThenJoin() - Method in class cascading.JoinFieldedPipesPlatformTest
-
This test checks for a deadlock when the same input is forked, adapted on one edge, then hashjoined back together.
- testGeneratorAggregator() - Method in class cascading.FieldedPipesPlatformTest
-
- testGroupByInsensitive() - Method in class cascading.FieldedPipesPlatformTest
-
- testGroupBySplitAroundSplitGroupByJoin() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testGroupBySplitGroupByJoin() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testGroupBySplitJoins() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testGroupBySplitSplitGroupByJoin() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testGroupGroup() - Method in class cascading.FieldedPipesPlatformTest
-
Catches failure to properly resolve the grouping fields as incoming to the second group-by
- testJoin() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testJoinAfterEvery() - Method in class cascading.JoinFieldedPipesPlatformTest
-
Method testCoGroupAfterEvery tests that a tmp tap is inserted after the Every in the cogroup join
- testJoinAroundJoinLeftMost() - Method in class cascading.JoinFieldedPipesPlatformTest
-
Same source as leftmost
- testJoinAroundJoinRightMost() - Method in class cascading.JoinFieldedPipesPlatformTest
-
Same source as rightmost
should be a single job as the same file accumulates into the joins
- testJoinAroundJoinRightMostSwapped() - Method in class cascading.JoinFieldedPipesPlatformTest
-
Upper as leftmost and rightmost forcing two jobs
- testJoinDiffFields() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testJoinFilteredBranch() - Method in class cascading.JoinFieldedPipesPlatformTest
-
this test intentionally filters out all values so the intermediate tap is empty.
- testJoinGroupBy() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testJoinGroupByJoin() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testJoinInner() - Method in class cascading.JoinFieldedPipesPlatformTest
-
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
- testJoinInnerOuter() - Method in class cascading.JoinFieldedPipesPlatformTest
-
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
- testJoinInnerSingleField() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testJoinMergeGroupBy() - Method in class cascading.JoinFieldedPipesPlatformTest
-
currently we cannot efficiently plan for this case.
- testJoinMixed() - Method in class cascading.JoinFieldedPipesPlatformTest
-
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
- testJoinNone() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testJoinNone() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testJoinOuter() - Method in class cascading.JoinFieldedPipesPlatformTest
-
/**
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
- testJoinOuterInner() - Method in class cascading.JoinFieldedPipesPlatformTest
-
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
- testJoinSamePipe() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testJoinSamePipe2() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testJoinSamePipe3() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testJoinSamePipeAroundGroupBy() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testJoinSamePipeName() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testJoinSameSourceIntoJoin() - Method in class cascading.JoinFieldedPipesPlatformTest
-
here the same file is fed into the same HashJoin.
- testJoinSameSourceIntoJoinSimple() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testJoinSameSourceOverGroupByIntoJoinSimple() - Method in class cascading.JoinFieldedPipesPlatformTest
-
Loosely tests for a deadlock when BlockingHashJoinAnnotator rule doesn't excluce the GroupBy from the blocking
annotation.
- testJoinSelf() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testJoinsIntoCoGroup() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testJoinsIntoCoGroupLhs() - Method in class cascading.JoinFieldedPipesPlatformTest
-
This test results in two MR jobs because one join feeds into the accumulated side of the second.
- testJoinsIntoCoGroupLhsSwappedJoin() - Method in class cascading.JoinFieldedPipesPlatformTest
-
This test results in one MR jobs because one join feeds into the streamed side of the second.
- testJoinsIntoCoGroupRhs() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testJoinsIntoGroupBy() - Method in class cascading.JoinFieldedPipesPlatformTest
-
Tests that two independent streamed sources with loadable tributaries properly plan into a GroupBy
without loading unused sources
- testJoinSplit() - Method in class cascading.JoinFieldedPipesPlatformTest
-
Under tez, this can result in the HashJoin being duplicated across nodes for each split after the HashJoin
BoundaryBalanceJoinSplitTransformer inserts a Boundary at the split, preventing duplication of the path
- testJoinSplitBeforeJoin() - Method in class cascading.JoinFieldedPipesPlatformTest
-
checks that a split after a HashJoin does not result in the HashJoin execution being duplicated across
multiple nodes, one for each branch in the split.
- testJoinWithHasher() - Method in class cascading.JoinFieldedPipesPlatformTest
-
Tests Hasher being honored even if default comparator is null.
- testJoinWithUnknowns() - Method in class cascading.JoinFieldedPipesPlatformTest
-
- testLogicFilter() - Method in class cascading.FieldedPipesPlatformTest
-
- testMultiJoin() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testMultiJoinWithSplits() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
This test checks that a valid node is created when adding back remainders during unique
path sub-graph partitioning.
- testNoGroup() - Method in class cascading.FieldedPipesPlatformTest
-
- testNone() - Method in class cascading.FieldedPipesPlatformTest
-
- TestPlatform - Class in cascading.platform
-
- TestPlatform() - Constructor for class cascading.platform.TestPlatform
-
- testReplace() - Method in class cascading.FieldedPipesPlatformTest
-
- testSameSourceGroupSplitCoGroup() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testSameSourceJoinSplitIntoJoin() - Method in class cascading.JoinFieldedPipesPlatformTest
-
catches a situation where BottomUpJoinedBoundariesNodePartitioner may capture an invalid HashJoin sub-graph
if the in-bound Boundary is split upon.
- testSameSourceMergeThreeChainGroup() - Method in class cascading.FieldedPipesPlatformTest
-
same test as MergePipesTest, but to test that chained groupby don't exhibit similar failures
- testSimpleChain() - Method in class cascading.FieldedPipesPlatformTest
-
- testSimpleGroup() - Method in class cascading.FieldedPipesPlatformTest
-
- testSimpleMerge() - Method in class cascading.FieldedPipesPlatformTest
-
- testSimpleMergeThree() - Method in class cascading.FieldedPipesPlatformTest
-
Specifically tests GroupBy will return the correct grouping fields to the following Every
additionally tests secondary sorting during merging
- testSplit() - Method in class cascading.FieldedPipesPlatformTest
-
- testSplitCoGroupSelf() - Method in class cascading.CoGroupFieldedPipesPlatformTest
-
- testSplitComplex() - Method in class cascading.FieldedPipesPlatformTest
-
- testSplitMultiple() - Method in class cascading.FieldedPipesPlatformTest
-
- testSplitNonSafe() - Method in class cascading.FieldedPipesPlatformTest
-
verifies non-safe rules apply in the proper place
- testSplitOut() - Method in class cascading.FieldedPipesPlatformTest
-
verifies not inserting Identity between groups works
- testSplitSameSourceMerged() - Method in class cascading.FieldedPipesPlatformTest
-
- testSplitSameSourceMergedSameName() - Method in class cascading.FieldedPipesPlatformTest
-
this tests a merge on two pipes with the same source and name.
- testSwap() - Method in class cascading.FieldedPipesPlatformTest
-
- testUnGroup() - Method in class cascading.FieldedPipesPlatformTest
-
- testUnGroupAnon() - Method in class cascading.FieldedPipesPlatformTest
-
- testUnGroupBySize() - Method in class cascading.FieldedPipesPlatformTest
-