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