public class FieldedPipesPlatformTest extends PlatformTestCase
Modifier and Type | Class and Description |
---|---|
static class |
FieldedPipesPlatformTest.LowerComparator |
name, ROOT_OUTPUT_PATH, ROOT_PLAN_PATH, TEST_TRACEPLAN_ENABLED
Constructor and Description |
---|
FieldedPipesPlatformTest() |
Modifier and Type | Method and Description |
---|---|
void |
testChainEndingWithEach() |
void |
testConcatenation() |
void |
testCopy() |
void |
testFilter() |
void |
testFilterAll()
Intentionally filters all values out to test next mr job behaves
|
void |
testFilterComplex() |
void |
testGeneratorAggregator() |
void |
testGroupByInsensitive() |
void |
testGroupGroup()
Catches failure to properly resolve the grouping fields as incoming to the second group-by
|
void |
testLogicFilter() |
void |
testNoGroup() |
void |
testNone() |
void |
testReplace() |
void |
testSameSourceMerge() |
void |
testSameSourceMergeThreeChainGroup()
same test as MergePipesTest, but to test that chained groupby don't exhibit similar failures
|
void |
testSimpleChain() |
void |
testSimpleGroup() |
void |
testSimpleMerge() |
void |
testSimpleMergeThree()
Specifically tests GroupBy will return the correct grouping fields to the following Every
additionally tests secondary sorting during merging
|
void |
testSplit() |
void |
testSplitComplex() |
void |
testSplitMultiple() |
void |
testSplitNonSafe()
verifies non-safe rules apply in the proper place
|
void |
testSplitOut()
verifies not inserting Identity between groups works
|
void |
testSplitSameSourceMerged() |
void |
testSplitSameSourceMergedSameName()
this tests a merge on two pipes with the same source and name.
|
void |
testSwap() |
void |
testUnGroup() |
void |
testUnGroupAnon() |
void |
testUnGroupBySize() |
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 FieldedPipesPlatformTest()
public void testSimpleGroup() throws java.lang.Exception
java.lang.Exception
public void testSimpleChain() throws java.lang.Exception
java.lang.Exception
public void testChainEndingWithEach() throws java.lang.Exception
java.lang.Exception
public void testNoGroup() throws java.lang.Exception
java.lang.Exception
public void testCopy() throws java.lang.Exception
java.lang.Exception
public void testSimpleMerge() throws java.lang.Exception
java.lang.Exception
public void testSimpleMergeThree() throws java.lang.Exception
java.lang.Exception
public void testSameSourceMerge() throws java.lang.Exception
java.lang.Exception
public void testSameSourceMergeThreeChainGroup() throws java.lang.Exception
java.lang.Exception
public void testUnGroup() throws java.lang.Exception
java.lang.Exception
public void testUnGroupAnon() throws java.lang.Exception
java.lang.Exception
public void testUnGroupBySize() throws java.lang.Exception
java.lang.Exception
public void testFilter() throws java.lang.Exception
java.lang.Exception
public void testLogicFilter() throws java.lang.Exception
java.lang.Exception
public void testFilterComplex() throws java.lang.Exception
java.lang.Exception
public void testFilterAll() throws java.lang.Exception
java.lang.Exception
public void testSplit() throws java.lang.Exception
java.lang.Exception
public void testSplitNonSafe() throws java.lang.Exception
java.lang.Exception
public void testSplitSameSourceMerged() throws java.lang.Exception
java.lang.Exception
public void testSplitOut() throws java.lang.Exception
java.lang.Exception
public void testSplitComplex() throws java.lang.Exception
java.lang.Exception
public void testSplitMultiple() throws java.lang.Exception
java.lang.Exception
public void testConcatenation() throws java.lang.Exception
java.lang.Exception
public void testGeneratorAggregator() throws java.lang.Exception
java.lang.Exception
public void testReplace() throws java.lang.Exception
java.lang.Exception
public void testSwap() throws java.lang.Exception
java.lang.Exception
public void testNone() throws java.lang.Exception
java.lang.Exception
public void testSplitSameSourceMergedSameName() throws java.lang.Exception
java.lang.Exception
public void testGroupGroup() throws java.lang.Exception
java.lang.Exception
public void testGroupByInsensitive() throws java.lang.Exception
java.lang.Exception
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.