public class Hadoop23Shims.MiniSparkShim extends Hadoop23Shims.MiniMrShim
Constructor and Description |
---|
MiniSparkShim(org.apache.hadoop.conf.Configuration conf,
int numberOfTaskTrackers,
String nameNode,
int numDir) |
Modifier and Type | Method and Description |
---|---|
int |
getJobTrackerPort() |
void |
setupConfiguration(org.apache.hadoop.conf.Configuration conf) |
void |
shutdown() |
public MiniSparkShim(org.apache.hadoop.conf.Configuration conf, int numberOfTaskTrackers, String nameNode, int numDir) throws IOException
IOException
public int getJobTrackerPort() throws UnsupportedOperationException
getJobTrackerPort
in interface HadoopShims.MiniMrShim
getJobTrackerPort
in class Hadoop23Shims.MiniMrShim
UnsupportedOperationException
public void shutdown() throws IOException
shutdown
in interface HadoopShims.MiniMrShim
shutdown
in class Hadoop23Shims.MiniMrShim
IOException
public void setupConfiguration(org.apache.hadoop.conf.Configuration conf)
setupConfiguration
in interface HadoopShims.MiniMrShim
setupConfiguration
in class Hadoop23Shims.MiniMrShim
Copyright © 2016 The Apache Software Foundation. All rights reserved.