Overview
Package
Class
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes
C
D
F
G
H
I
J
M
N
P
R
S
T
C
cascading
- package cascading
cascading.platform
- package cascading.platform
CLUSTER_TESTING_PROPERTY
- Static variable in class cascading.platform.
TestPlatform
CoGroupFieldedPipesPlatformTest
- Class in
cascading
CoGroupFieldedPipesPlatformTest()
- Constructor for class cascading.
CoGroupFieldedPipesPlatformTest
compare(Comparable, Comparable)
- Method in class cascading.
FieldedPipesPlatformTest.LowerComparator
compare(Comparable, Comparable)
- Method in class cascading.
JoinFieldedPipesPlatformTest.AllComparator
ComparePlatformsTest
- Class in
cascading
ComparePlatformsTest()
- Constructor for class cascading.
ComparePlatformsTest
ComparePlatformsTest.CompareTestCase
- Class in
cascading
ComparePlatformsTest.CompareTestCase(String, File, File)
- Constructor for class cascading.
ComparePlatformsTest.CompareTestCase
copyFromLocal(String)
- Method in class cascading.platform.
TestPlatform
copyFromLocal(String)
- Method in class cascading.
PlatformTestCase
copyToLocal(String)
- Method in class cascading.platform.
TestPlatform
D
data
- package data
describeChild(Runner)
- Method in class cascading.platform.
PlatformRunner
disableDebug()
- Method in class cascading.
PlatformTestCase
F
FieldedPipesPlatformTest
- Class in
cascading
FieldedPipesPlatformTest()
- Constructor for class cascading.
FieldedPipesPlatformTest
FieldedPipesPlatformTest.LowerComparator
- Class in
cascading
FieldedPipesPlatformTest.LowerComparator()
- Constructor for class cascading.
FieldedPipesPlatformTest.LowerComparator
G
getChildren()
- Method in class cascading.platform.
PlatformRunner
getDelimitedFile(Fields, String, String)
- Method in class cascading.platform.
TestPlatform
getDelimitedFile(Fields, String, String, SinkMode)
- Method in class cascading.platform.
TestPlatform
getDelimitedFile(Fields, String, SinkMode)
- Method in class cascading.platform.
TestPlatform
Deprecated.
getDelimitedFile(Fields, boolean, String, SinkMode)
- Method in class cascading.platform.
TestPlatform
Deprecated.
getDelimitedFile(Fields, boolean, String, String, String, SinkMode)
- Method in class cascading.platform.
TestPlatform
getDelimitedFile(Fields, String, String, String, SinkMode)
- Method in class cascading.platform.
TestPlatform
getDelimitedFile(Fields, String, Class[], String, SinkMode)
- Method in class cascading.platform.
TestPlatform
getDelimitedFile(Fields, boolean, String, String, Class[], String, SinkMode)
- Method in class cascading.platform.
TestPlatform
getDelimitedFile(Fields, boolean, boolean, String, String, Class[], String, SinkMode)
- Method in class cascading.platform.
TestPlatform
getDelimitedFile(String, String, FieldTypeResolver, String, SinkMode)
- Method in class cascading.platform.
TestPlatform
getFlowConnector(Map<Object, Object>)
- Method in class cascading.platform.
TestPlatform
getFlowConnector()
- Method in class cascading.platform.
TestPlatform
getFlowProcess()
- Method in class cascading.platform.
TestPlatform
getGlobalProperties()
- Static method in class cascading.platform.
TestPlatform
Method getGlobalProperties fetches all "platform." prefixed system properties.
getHiddenTemporaryPath()
- Method in class cascading.platform.
TestPlatform
getLongComparator(boolean)
- Method in class cascading.platform.
TestPlatform
getName()
- Method in class cascading.platform.
TestPlatform
getNumMappers()
- Method in class cascading.platform.
TestPlatform
getNumMapTasks(Map<Object, Object>)
- Method in class cascading.platform.
TestPlatform
getNumReducers()
- Method in class cascading.platform.
TestPlatform
getNumReduceTasks(Map<Object, Object>)
- Method in class cascading.platform.
TestPlatform
getOutputPath(String)
- Method in class cascading.
PlatformTestCase
getPartitionTap(Tap, Partition, int)
- Method in class cascading.platform.
TestPlatform
getPathElements()
- Method in class cascading.
PlatformTestCase
getPlatform()
- Method in class cascading.
PlatformTestCase
getPlatformClassesFromClasspath(ClassLoader)
- Static method in class cascading.platform.
PlatformRunner
getPlatformName()
- Method in class cascading.
PlatformTestCase
getProperties()
- Method in class cascading.platform.
TestPlatform
getProperties()
- Method in class cascading.
PlatformTestCase
getRootPath()
- Method in class cascading.
PlatformTestCase
getStringComparator(boolean)
- Method in class cascading.platform.
TestPlatform
getTabDelimitedFile(Fields, String, SinkMode)
- Method in class cascading.platform.
TestPlatform
getTabDelimitedFile(Fields, boolean, String, SinkMode)
- Method in class cascading.platform.
TestPlatform
getTap(Scheme, String, SinkMode)
- Method in class cascading.platform.
TestPlatform
getTemplateTap(Tap, String, int)
- Method in class cascading.platform.
TestPlatform
getTemplateTap(Tap, String, Fields, int)
- Method in class cascading.platform.
TestPlatform
getTestCaseName()
- Method in class cascading.
PlatformTestCase
getTestConfigDefScheme()
- Method in class cascading.platform.
TestPlatform
getTestFailScheme()
- Method in class cascading.platform.
TestPlatform
getTestName()
- Method in class cascading.
PlatformTestCase
getTestRoot()
- Static method in class cascading.
PlatformTestCase
getTextFile(Fields, String)
- Method in class cascading.platform.
TestPlatform
getTextFile(String)
- Method in class cascading.platform.
TestPlatform
getTextFile(String, SinkMode)
- Method in class cascading.platform.
TestPlatform
getTextFile(Fields, String, SinkMode)
- Method in class cascading.platform.
TestPlatform
getTextFile(Fields, Fields, String, SinkMode)
- Method in class cascading.platform.
TestPlatform
H
hashCode(Comparable)
- Method in class cascading.
FieldedPipesPlatformTest.LowerComparator
hashCode(Comparable)
- Method in class cascading.
JoinFieldedPipesPlatformTest.AllComparator
I
InputData
- Interface in
data
inputFileApache
- Static variable in interface data.
InputData
inputFileApache200
- Static variable in interface data.
InputData
inputFileApacheClean
- Static variable in interface data.
InputData
inputFileComments
- Static variable in interface data.
InputData
inputFileCritics
- Static variable in interface data.
InputData
inputFileCross
- Static variable in interface data.
InputData
inputFileCrossRev
- Static variable in interface data.
InputData
inputFileCrossX2
- Static variable in interface data.
InputData
inputFileFirstBy
- Static variable in interface data.
InputData
inputFileIps
- Static variable in interface data.
InputData
inputFileJoined
- Static variable in interface data.
InputData
inputFileJoinedExtra
- Static variable in interface data.
InputData
inputFileLhs
- Static variable in interface data.
InputData
inputFileLhsSparse
- Static variable in interface data.
InputData
inputFileLower
- Static variable in interface data.
InputData
inputFileLowerOffset
- Static variable in interface data.
InputData
inputFileNums10
- Static variable in interface data.
InputData
inputFileNums20
- Static variable in interface data.
InputData
inputFileRhs
- Static variable in interface data.
InputData
inputFileRhsSparse
- Static variable in interface data.
InputData
inputFileUnexpectedEndOfFile
- Static variable in interface data.
InputData
inputFileUpper
- Static variable in interface data.
InputData
inputPath
- Static variable in interface data.
InputData
installPlatform(TestPlatform)
- Method in class cascading.
PlatformTestCase
isMapReduce()
- Method in class cascading.platform.
TestPlatform
isUseCluster()
- Method in class cascading.platform.
TestPlatform
J
JoinFieldedPipesPlatformTest
- Class in
cascading
JoinFieldedPipesPlatformTest()
- Constructor for class cascading.
JoinFieldedPipesPlatformTest
JoinFieldedPipesPlatformTest.AllComparator
- Class in
cascading
JoinFieldedPipesPlatformTest.AllComparator()
- Constructor for class cascading.
JoinFieldedPipesPlatformTest.AllComparator
M
makeInstance(Class<? extends TestPlatform>)
- Static method in class cascading.platform.
PlatformRunner
N
name
- Variable in class cascading.
PlatformTestCase
NONDETERMINISTIC
- Static variable in class cascading.
ComparePlatformsTest
P
PLATFORM_CLASSNAME
- Static variable in class cascading.platform.
PlatformRunner
PLATFORM_INCLUDES
- Static variable in class cascading.platform.
PlatformRunner
PLATFORM_RESOURCE
- Static variable in class cascading.platform.
PlatformRunner
PlatformRunner
- Class in
cascading.platform
Class ParentRunner is a JUnit
Runner
sub-class for injecting different platform and planners into the *PlatformTest classes.
PlatformRunner(Class<PlatformTestCase>)
- Constructor for class cascading.platform.
PlatformRunner
PlatformRunner.Platform
- Annotation Type in
cascading.platform
PlatformTestCase
- Class in
cascading
PlatformTestCase is the base class for JUnit tests that are platform agnostic.
PlatformTestCase(boolean)
- Constructor for class cascading.
PlatformTestCase
PlatformTestCase(boolean, int, int)
- Constructor for class cascading.
PlatformTestCase
PlatformTestCase()
- Constructor for class cascading.
PlatformTestCase
R
remoteExists(String)
- Method in class cascading.platform.
TestPlatform
remoteRemove(String, boolean)
- Method in class cascading.platform.
TestPlatform
ROOT_OUTPUT_PATH
- Static variable in class cascading.
PlatformTestCase
runChild(Runner, RunNotifier)
- Method in class cascading.platform.
PlatformRunner
S
setNumMappers(int)
- Method in class cascading.platform.
TestPlatform
setNumMapTasks(Map<Object, Object>, int)
- Method in class cascading.platform.
TestPlatform
setNumReducers(int)
- Method in class cascading.platform.
TestPlatform
setNumReduceTasks(Map<Object, Object>, int)
- Method in class cascading.platform.
TestPlatform
setUp()
- Method in class cascading.platform.
TestPlatform
setUp()
- Method in class cascading.
PlatformTestCase
setUseCluster(boolean)
- Method in class cascading.platform.
TestPlatform
suite()
- Static method in class cascading.
ComparePlatformsTest
T
tearDown()
- Method in class cascading.platform.
TestPlatform
tearDown()
- Method in class cascading.
PlatformTestCase
TEST_DATA_PATH
- Static variable in interface data.
InputData
testChainedTaps()
- Method in class cascading.
FieldedPipesPlatformTest
If the sinks have the same scheme as a temp tap, replace the temp tap
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
testGeneratorAggregator()
- Method in class cascading.
FieldedPipesPlatformTest
testGroupByInsensitive()
- Method in class cascading.
FieldedPipesPlatformTest
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
When run against a cluster a Merge before a GroupBy can hide the streamed/accumulated nature of a branch.
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.
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
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
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
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
testSplit()
- Method in class cascading.
FieldedPipesPlatformTest
testSplitComplex()
- 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
C
D
F
G
H
I
J
M
N
P
R
S
T
Overview
Package
Class
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.