public class LocalPlatform extends cascading.platform.TestPlatform
PlatformTestCase
instance
so that all *PlatformTest classes can be tested against the Cascading local mode planner.CLUSTER_TESTING_PROPERTY, numGatherPartitions, numMappers, numReducers, PLATFORM_PREFIX
Constructor and Description |
---|
LocalPlatform() |
Modifier and Type | Method and Description |
---|---|
void |
copyFromLocal(String inputFile) |
void |
copyToLocal(String outputFile) |
Tap |
getDelimitedFile(Fields fields,
boolean skipHeader,
boolean writeHeader,
String delimiter,
String quote,
Class[] types,
String filename,
SinkMode mode) |
Tap |
getDelimitedFile(Fields fields,
boolean hasHeader,
String delimiter,
String quote,
Class[] types,
String filename,
SinkMode mode) |
Tap |
getDelimitedFile(String delimiter,
String quote,
FieldTypeResolver fieldTypeResolver,
String filename,
SinkMode mode) |
FlowConnector |
getFlowConnector(Map<Object,Object> properties) |
FlowProcess |
getFlowProcess() |
String |
getHiddenTemporaryPath() |
Comparator |
getLongComparator(boolean reverseSort) |
Tap |
getPartitionTap(Tap sink,
Partition partition,
int openThreshold) |
Map<Object,Object> |
getProperties() |
Comparator |
getStringComparator(boolean reverseSort) |
Tap |
getTap(Scheme scheme,
String filename,
SinkMode mode) |
Scheme |
getTestConfigDefScheme() |
Scheme |
getTestFailScheme() |
Tap |
getTextFile(Fields sourceFields,
Fields sinkFields,
String filename,
SinkMode mode) |
boolean |
remoteExists(String outputFile) |
boolean |
remoteRemove(String outputFile,
boolean recursive) |
void |
setUp() |
boolean |
supportsGroupByAfterMerge() |
void |
tearDown() |
getApplicationJar, getDelimitedFile, getDelimitedFile, getDelimitedFile, getDelimitedFile, getDelimitedFile, getFlowConnector, getGlobalProperties, getName, getNumGatherPartitions, getNumGatherPartitionTasks, getNumMappers, getNumMapTasks, getNumReducers, getNumReduceTasks, getTabDelimitedFile, getTabDelimitedFile, getTextFile, getTextFile, getTextFile, getTextFile, isDAG, isMapReduce, isUseCluster, setNumGatherPartitions, setNumGatherPartitionTasks, setNumMappers, setNumMapTasks, setNumReducers, setNumReduceTasks, setUseCluster
public LocalPlatform()
public void setUp() throws IOException
setUp
in class cascading.platform.TestPlatform
IOException
public Map<Object,Object> getProperties()
getProperties
in class cascading.platform.TestPlatform
public void tearDown()
tearDown
in class cascading.platform.TestPlatform
public boolean supportsGroupByAfterMerge()
supportsGroupByAfterMerge
in class cascading.platform.TestPlatform
public void copyFromLocal(String inputFile) throws IOException
copyFromLocal
in class cascading.platform.TestPlatform
IOException
public void copyToLocal(String outputFile) throws IOException
copyToLocal
in class cascading.platform.TestPlatform
IOException
public boolean remoteExists(String outputFile) throws IOException
remoteExists
in class cascading.platform.TestPlatform
IOException
public boolean remoteRemove(String outputFile, boolean recursive) throws IOException
remoteRemove
in class cascading.platform.TestPlatform
IOException
public FlowProcess getFlowProcess()
getFlowProcess
in class cascading.platform.TestPlatform
public FlowConnector getFlowConnector(Map<Object,Object> properties)
getFlowConnector
in class cascading.platform.TestPlatform
public Tap getTap(Scheme scheme, String filename, SinkMode mode)
getTap
in class cascading.platform.TestPlatform
public Tap getTextFile(Fields sourceFields, Fields sinkFields, String filename, SinkMode mode)
getTextFile
in class cascading.platform.TestPlatform
public Tap getDelimitedFile(Fields fields, boolean hasHeader, String delimiter, String quote, Class[] types, String filename, SinkMode mode)
getDelimitedFile
in class cascading.platform.TestPlatform
public Tap getDelimitedFile(Fields fields, boolean skipHeader, boolean writeHeader, String delimiter, String quote, Class[] types, String filename, SinkMode mode)
getDelimitedFile
in class cascading.platform.TestPlatform
public Tap getDelimitedFile(String delimiter, String quote, FieldTypeResolver fieldTypeResolver, String filename, SinkMode mode)
getDelimitedFile
in class cascading.platform.TestPlatform
public Tap getPartitionTap(Tap sink, Partition partition, int openThreshold)
getPartitionTap
in class cascading.platform.TestPlatform
public Scheme getTestConfigDefScheme()
getTestConfigDefScheme
in class cascading.platform.TestPlatform
public Scheme getTestFailScheme()
getTestFailScheme
in class cascading.platform.TestPlatform
public Comparator getLongComparator(boolean reverseSort)
getLongComparator
in class cascading.platform.TestPlatform
public Comparator getStringComparator(boolean reverseSort)
getStringComparator
in class cascading.platform.TestPlatform
public String getHiddenTemporaryPath()
getHiddenTemporaryPath
in class cascading.platform.TestPlatform
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.