public class Hadoop2MR1Platform extends BaseHadoopPlatform<JobConf>
PlatformTestCase
instance
so that all *PlatformTest classes can be tested against Apache Hadoop 2.x.configuration, fileSys, logger, properties
Constructor and Description |
---|
Hadoop2MR1Platform() |
Modifier and Type | Method and Description |
---|---|
JobConf |
getConfiguration() |
cascading.flow.FlowConnector |
getFlowConnector(java.util.Map<java.lang.Object,java.lang.Object> properties) |
cascading.flow.FlowProcess |
getFlowProcess() |
java.lang.String |
getName() |
java.lang.Integer |
getNumMapTasks(java.util.Map<java.lang.Object,java.lang.Object> properties) |
java.lang.Integer |
getNumReduceTasks(java.util.Map<java.lang.Object,java.lang.Object> properties) |
void |
setNumMapTasks(java.util.Map<java.lang.Object,java.lang.Object> properties,
int numMapTasks) |
void |
setNumReduceTasks(java.util.Map<java.lang.Object,java.lang.Object> properties,
int numReduceTasks) |
void |
setUp() |
copyFromLocal, copyToLocal, getDelimitedFile, getDelimitedFile, getDelimitedFile, getHiddenTemporaryPath, getLongComparator, getPartitionTap, getProperties, getStringComparator, getTap, getTestConfigDefScheme, getTestFailScheme, getTextFile, isHDFSAvailable, isMapReduce, remoteExists, remoteRemove, safeFileName, setNumGatherPartitions, setNumMappers, setNumReducers, tearDown
getApplicationJar, getDelimitedFile, getDelimitedFile, getDelimitedFile, getDelimitedFile, getDelimitedFile, getFlowConnector, getGlobalProperties, getNumGatherPartitions, getNumGatherPartitionTasks, getNumMappers, getNumReducers, getTabDelimitedFile, getTabDelimitedFile, getTextFile, getTextFile, getTextFile, getTextFile, isDAG, isUseCluster, setNumGatherPartitionTasks, setUseCluster, supportsGroupByAfterMerge
public Hadoop2MR1Platform()
public java.lang.String getName()
getName
in class cascading.platform.TestPlatform
public cascading.flow.FlowConnector getFlowConnector(java.util.Map<java.lang.Object,java.lang.Object> properties)
getFlowConnector
in class cascading.platform.TestPlatform
public void setNumMapTasks(java.util.Map<java.lang.Object,java.lang.Object> properties, int numMapTasks)
setNumMapTasks
in class cascading.platform.TestPlatform
public void setNumReduceTasks(java.util.Map<java.lang.Object,java.lang.Object> properties, int numReduceTasks)
setNumReduceTasks
in class cascading.platform.TestPlatform
public java.lang.Integer getNumMapTasks(java.util.Map<java.lang.Object,java.lang.Object> properties)
getNumMapTasks
in class cascading.platform.TestPlatform
public java.lang.Integer getNumReduceTasks(java.util.Map<java.lang.Object,java.lang.Object> properties)
getNumReduceTasks
in class cascading.platform.TestPlatform
public JobConf getConfiguration()
getConfiguration
in class BaseHadoopPlatform<JobConf>
public cascading.flow.FlowProcess getFlowProcess()
getFlowProcess
in class cascading.platform.TestPlatform
public void setUp() throws java.io.IOException
setUp
in class cascading.platform.TestPlatform
java.io.IOException
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.