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 |
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 Exception
Exception
public void testSimpleChain() throws Exception
Exception
public void testChainEndingWithEach() throws Exception
Exception
public void testNoGroup() throws Exception
Exception
public void testSimpleMerge() throws Exception
Exception
public void testSimpleMergeThree() throws Exception
Exception
public void testSameSourceMergeThreeChainGroup() throws Exception
Exception
public void testUnGroup() throws Exception
Exception
public void testUnGroupAnon() throws Exception
Exception
public void testUnGroupBySize() throws Exception
Exception
public void testFilter() throws Exception
Exception
public void testLogicFilter() throws Exception
Exception
public void testFilterComplex() throws Exception
Exception
public void testFilterAll() throws Exception
Exception
public void testSplitNonSafe() throws Exception
Exception
public void testSplitSameSourceMerged() throws Exception
Exception
public void testSplitOut() throws Exception
Exception
public void testSplitComplex() throws Exception
Exception
public void testSplitMultiple() throws Exception
Exception
public void testConcatenation() throws Exception
Exception
public void testGeneratorAggregator() throws Exception
Exception
public void testReplace() throws Exception
Exception
public void testSplitSameSourceMergedSameName() throws Exception
Exception
public void testGroupGroup() throws Exception
Exception
public void testGroupByInsensitive() throws Exception
Exception
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.