public abstract class CascadingTestCase extends junit.framework.TestCase implements java.io.Serializable
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 length) |
static void |
validateLength(Flow flow,
int length,
int size) |
static void |
validateLength(Flow flow,
int length,
int size,
java.util.regex.Pattern regex) |
static void |
validateLength(Flow flow,
int length,
int size,
java.util.regex.Pattern regex,
java.lang.String name) |
static void |
validateLength(Flow flow,
int length,
java.util.regex.Pattern regex,
java.lang.String name) |
static void |
validateLength(Flow flow,
int length,
java.lang.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,
java.util.regex.Pattern regex) |
static void |
validateLength(TupleEntryIterator iterator,
int length,
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 length) throws java.io.IOException
java.io.IOException
public static void validateLength(Flow flow, int length, java.lang.String name) throws java.io.IOException
java.io.IOException
public static void validateLength(Flow flow, int length, int size) throws java.io.IOException
java.io.IOException
public static void validateLength(Flow flow, int length, int size, java.util.regex.Pattern regex) throws java.io.IOException
java.io.IOException
public static void validateLength(Flow flow, int length, java.util.regex.Pattern regex, java.lang.String name) throws java.io.IOException
java.io.IOException
public static void validateLength(Flow flow, int length, int size, java.util.regex.Pattern regex, java.lang.String name) throws java.io.IOException
java.io.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, java.util.regex.Pattern regex)
public static void validateLength(TupleEntryIterator iterator, int length, int size, 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-2015 Xplenty, Inc. All Rights Reserved.