public abstract class CascadingTestCase extends junit.framework.TestCase implements java.io.Serializable
It included a few helpful utility methods for testing Cascading applications.
Modifier and Type | Field and Description |
---|---|
org.junit.rules.TestName |
name |
static java.lang.String |
ROOT_OUTPUT_PATH |
static java.lang.String |
ROOT_PLAN_PATH |
static java.lang.String |
TEST_TRACEPLAN_ENABLED |
Constructor and Description |
---|
CascadingTestCase() |
CascadingTestCase(java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
static <C extends java.util.Collection<Tuple>> |
asCollection(Flow flow,
Tap tap,
C collection) |
static <C extends java.util.Collection<Tuple>> |
asCollection(Flow flow,
Tap tap,
Fields selector,
C collection) |
static <C extends java.util.Collection<Tuple>> |
asCollection(TupleEntryIterator iterator,
C result) |
static <C extends java.util.Collection<Tuple>> |
asCollection(TupleEntryIterator iterator,
Fields selector,
C result) |
static java.util.List<Tuple> |
asList(Flow flow,
Tap tap) |
static java.util.List<Tuple> |
asList(Flow flow,
Tap tap,
Fields selector) |
static java.util.Set<Tuple> |
asSet(Flow flow,
Tap tap) |
static java.util.Set<Tuple> |
asSet(Flow flow,
Tap tap,
Fields selector) |
protected java.lang.String |
getOutputPath() |
protected java.lang.String[] |
getOutputPathElements() |
protected java.lang.String |
getPlanPath() |
protected java.lang.String[] |
getPlanPathElements() |
static java.util.List<Tuple> |
getSinkAsList(Flow flow) |
static java.util.List<Tuple> |
getSourceAsList(Flow flow) |
java.lang.String |
getTestCaseName() |
java.lang.String |
getTestName() |
protected static java.lang.String |
getTestOutputRoot() |
protected static java.lang.String |
getTestPlanRoot() |
static TupleListCollector |
invokeAggregator(Aggregator aggregator,
Tuple[] argumentsArray,
Fields resultFields) |
static TupleListCollector |
invokeAggregator(Aggregator aggregator,
Tuple[] argumentsArray,
Fields resultFields,
java.util.Map<java.lang.Object,java.lang.Object> properties) |
static TupleListCollector |
invokeAggregator(Aggregator aggregator,
TupleEntry[] argumentsArray,
Fields resultFields) |
static TupleListCollector |
invokeAggregator(Aggregator aggregator,
TupleEntry[] argumentsArray,
Fields resultFields,
java.util.Map<java.lang.Object,java.lang.Object> properties) |
static TupleListCollector |
invokeAggregator(Aggregator aggregator,
TupleEntry group,
TupleEntry[] argumentsArray,
Fields resultFields) |
static TupleListCollector |
invokeAggregator(Aggregator aggregator,
TupleEntry group,
TupleEntry[] argumentsArray,
Fields resultFields,
java.util.Map<java.lang.Object,java.lang.Object> properties) |
static TupleListCollector |
invokeBuffer(Buffer buffer,
Tuple[] argumentsArray,
Fields resultFields) |
static TupleListCollector |
invokeBuffer(Buffer buffer,
Tuple[] argumentsArray,
Fields resultFields,
java.util.Map<java.lang.Object,java.lang.Object> properties) |
static TupleListCollector |
invokeBuffer(Buffer buffer,
TupleEntry[] argumentsArray,
Fields resultFields) |
static TupleListCollector |
invokeBuffer(Buffer buffer,
TupleEntry[] argumentsArray,
Fields resultFields,
java.util.Map<java.lang.Object,java.lang.Object> properties) |
static TupleListCollector |
invokeBuffer(Buffer buffer,
TupleEntry group,
TupleEntry[] argumentsArray,
Fields resultFields) |
static TupleListCollector |
invokeBuffer(Buffer buffer,
TupleEntry group,
TupleEntry[] argumentsArray,
Fields resultFields,
java.util.Map<java.lang.Object,java.lang.Object> properties) |
static boolean |
invokeFilter(Filter filter,
Tuple arguments) |
static boolean[] |
invokeFilter(Filter filter,
Tuple[] argumentsArray) |
static boolean[] |
invokeFilter(Filter filter,
Tuple[] argumentsArray,
java.util.Map<java.lang.Object,java.lang.Object> properties) |
static boolean |
invokeFilter(Filter filter,
TupleEntry arguments) |
static boolean[] |
invokeFilter(Filter filter,
TupleEntry[] argumentsArray) |
static boolean[] |
invokeFilter(Filter filter,
TupleEntry[] argumentsArray,
java.util.Map<java.lang.Object,java.lang.Object> properties) |
static boolean |
invokeFilter(Filter filter,
TupleEntry arguments,
java.util.Map<java.lang.Object,java.lang.Object> properties) |
static boolean |
invokeFilter(Filter filter,
Tuple arguments,
java.util.Map<java.lang.Object,java.lang.Object> properties) |
static TupleListCollector |
invokeFunction(Function function,
Tuple[] argumentsArray,
Fields resultFields) |
static TupleListCollector |
invokeFunction(Function function,
Tuple[] argumentsArray,
Fields resultFields,
java.util.Map<java.lang.Object,java.lang.Object> properties) |
static TupleListCollector |
invokeFunction(Function function,
TupleEntry[] argumentsArray,
Fields resultFields) |
static TupleListCollector |
invokeFunction(Function function,
TupleEntry[] argumentsArray,
Fields resultFields,
java.util.Map<java.lang.Object,java.lang.Object> properties) |
static TupleListCollector |
invokeFunction(Function function,
TupleEntry arguments,
Fields resultFields) |
static TupleListCollector |
invokeFunction(Function function,
TupleEntry arguments,
Fields resultFields,
java.util.Map<java.lang.Object,java.lang.Object> properties) |
static TupleListCollector |
invokeFunction(Function function,
Tuple arguments,
Fields resultFields) |
static TupleListCollector |
invokeFunction(Function function,
Tuple arguments,
Fields resultFields,
java.util.Map<java.lang.Object,java.lang.Object> properties) |
void |
setUp() |
void |
tearDown() |
static void |
validateLength(Flow flow,
int numTuples) |
static void |
validateLength(Flow flow,
int numTuples,
int tupleSize) |
static void |
validateLength(Flow flow,
int numTuples,
int tupleSize,
java.util.regex.Pattern regex) |
static void |
validateLength(Flow flow,
int numTuples,
int tupleSize,
java.util.regex.Pattern regex,
java.lang.String name) |
static void |
validateLength(Flow flow,
int numTuples,
java.util.regex.Pattern regex,
java.lang.String name) |
static void |
validateLength(Flow flow,
int numTuples,
java.lang.String name) |
static void |
validateLength(TupleEntryIterator iterator,
int numTuples) |
static void |
validateLength(TupleEntryIterator iterator,
int numTuples,
int tupleSize) |
static void |
validateLength(TupleEntryIterator iterator,
int numTuples,
int tupleSize,
java.util.regex.Pattern regex) |
static void |
validateLength(TupleEntryIterator iterator,
int numTuples,
java.util.regex.Pattern regex) |
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 static final java.lang.String ROOT_OUTPUT_PATH
public static final java.lang.String ROOT_PLAN_PATH
public static final java.lang.String TEST_TRACEPLAN_ENABLED
public transient org.junit.rules.TestName name
public CascadingTestCase()
public CascadingTestCase(java.lang.String name)
public void setUp() throws java.lang.Exception
setUp
in class junit.framework.TestCase
java.lang.Exception
public void tearDown() throws java.lang.Exception
tearDown
in class junit.framework.TestCase
java.lang.Exception
protected static java.lang.String getTestOutputRoot()
protected static java.lang.String getTestPlanRoot()
protected java.lang.String[] getOutputPathElements()
protected java.lang.String[] getPlanPathElements()
protected java.lang.String getOutputPath()
protected java.lang.String getPlanPath()
public java.lang.String getTestCaseName()
public java.lang.String getTestName()
public static void validateLength(Flow flow, int numTuples) throws java.io.IOException
java.io.IOException
public static void validateLength(Flow flow, int numTuples, java.lang.String name) throws java.io.IOException
java.io.IOException
public static void validateLength(Flow flow, int numTuples, int tupleSize) throws java.io.IOException
java.io.IOException
public static void validateLength(Flow flow, int numTuples, int tupleSize, java.util.regex.Pattern regex) throws java.io.IOException
java.io.IOException
public static void validateLength(Flow flow, int numTuples, java.util.regex.Pattern regex, java.lang.String name) throws java.io.IOException
java.io.IOException
public static void validateLength(Flow flow, int numTuples, int tupleSize, java.util.regex.Pattern regex, java.lang.String name) throws java.io.IOException
java.io.IOException
public static void validateLength(TupleEntryIterator iterator, int numTuples)
public static void validateLength(TupleEntryIterator iterator, int numTuples, int tupleSize)
public static void validateLength(TupleEntryIterator iterator, int numTuples, java.util.regex.Pattern regex)
public static void validateLength(TupleEntryIterator iterator, int numTuples, int tupleSize, java.util.regex.Pattern regex)
public static TupleListCollector invokeFunction(Function function, Tuple arguments, Fields resultFields)
public static TupleListCollector invokeFunction(Function function, Tuple arguments, Fields resultFields, java.util.Map<java.lang.Object,java.lang.Object> properties)
public static TupleListCollector invokeFunction(Function function, TupleEntry arguments, Fields resultFields)
public static TupleListCollector invokeFunction(Function function, TupleEntry arguments, Fields resultFields, java.util.Map<java.lang.Object,java.lang.Object> properties)
public static TupleListCollector invokeFunction(Function function, Tuple[] argumentsArray, Fields resultFields)
public static TupleListCollector invokeFunction(Function function, Tuple[] argumentsArray, Fields resultFields, java.util.Map<java.lang.Object,java.lang.Object> properties)
public static TupleListCollector invokeFunction(Function function, TupleEntry[] argumentsArray, Fields resultFields)
public static TupleListCollector invokeFunction(Function function, TupleEntry[] argumentsArray, Fields resultFields, java.util.Map<java.lang.Object,java.lang.Object> properties)
public static boolean invokeFilter(Filter filter, Tuple arguments)
public static boolean invokeFilter(Filter filter, Tuple arguments, java.util.Map<java.lang.Object,java.lang.Object> properties)
public static boolean invokeFilter(Filter filter, TupleEntry arguments)
public static boolean invokeFilter(Filter filter, TupleEntry arguments, java.util.Map<java.lang.Object,java.lang.Object> properties)
public static boolean[] invokeFilter(Filter filter, Tuple[] argumentsArray)
public static boolean[] invokeFilter(Filter filter, Tuple[] argumentsArray, java.util.Map<java.lang.Object,java.lang.Object> properties)
public static boolean[] invokeFilter(Filter filter, TupleEntry[] argumentsArray)
public static boolean[] invokeFilter(Filter filter, TupleEntry[] argumentsArray, java.util.Map<java.lang.Object,java.lang.Object> properties)
public static TupleListCollector invokeAggregator(Aggregator aggregator, Tuple[] argumentsArray, Fields resultFields)
public static TupleListCollector invokeAggregator(Aggregator aggregator, Tuple[] argumentsArray, Fields resultFields, java.util.Map<java.lang.Object,java.lang.Object> properties)
public static TupleListCollector invokeAggregator(Aggregator aggregator, TupleEntry[] argumentsArray, Fields resultFields)
public static TupleListCollector invokeAggregator(Aggregator aggregator, TupleEntry[] argumentsArray, Fields resultFields, java.util.Map<java.lang.Object,java.lang.Object> properties)
public static TupleListCollector invokeAggregator(Aggregator aggregator, TupleEntry group, TupleEntry[] argumentsArray, Fields resultFields)
public static TupleListCollector invokeAggregator(Aggregator aggregator, TupleEntry group, TupleEntry[] argumentsArray, Fields resultFields, java.util.Map<java.lang.Object,java.lang.Object> properties)
public static TupleListCollector invokeBuffer(Buffer buffer, Tuple[] argumentsArray, Fields resultFields)
public static TupleListCollector invokeBuffer(Buffer buffer, Tuple[] argumentsArray, Fields resultFields, java.util.Map<java.lang.Object,java.lang.Object> properties)
public static TupleListCollector invokeBuffer(Buffer buffer, TupleEntry[] argumentsArray, Fields resultFields)
public static TupleListCollector invokeBuffer(Buffer buffer, TupleEntry[] argumentsArray, Fields resultFields, java.util.Map<java.lang.Object,java.lang.Object> properties)
public static TupleListCollector invokeBuffer(Buffer buffer, TupleEntry group, TupleEntry[] argumentsArray, Fields resultFields)
public static TupleListCollector invokeBuffer(Buffer buffer, TupleEntry group, TupleEntry[] argumentsArray, Fields resultFields, java.util.Map<java.lang.Object,java.lang.Object> properties)
public static java.util.List<Tuple> getSourceAsList(Flow flow) throws java.io.IOException
java.io.IOException
public static java.util.List<Tuple> getSinkAsList(Flow flow) throws java.io.IOException
java.io.IOException
public static java.util.List<Tuple> asList(Flow flow, Tap tap) throws java.io.IOException
java.io.IOException
public static java.util.List<Tuple> asList(Flow flow, Tap tap, Fields selector) throws java.io.IOException
java.io.IOException
public static java.util.Set<Tuple> asSet(Flow flow, Tap tap) throws java.io.IOException
java.io.IOException
public static java.util.Set<Tuple> asSet(Flow flow, Tap tap, Fields selector) throws java.io.IOException
java.io.IOException
public static <C extends java.util.Collection<Tuple>> C asCollection(Flow flow, Tap tap, C collection) throws java.io.IOException
java.io.IOException
public static <C extends java.util.Collection<Tuple>> C asCollection(Flow flow, Tap tap, Fields selector, C collection) throws java.io.IOException
java.io.IOException
public static <C extends java.util.Collection<Tuple>> C asCollection(TupleEntryIterator iterator, C result)
public static <C extends java.util.Collection<Tuple>> C asCollection(TupleEntryIterator iterator, Fields selector, C result)
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.