org.apache.hadoop.hive.shims

Class Hadoop23Shims.MiniSparkShim

java.lang.Object

org.apache.hadoop.hive.shims.Hadoop23Shims.MiniMrShim

org.apache.hadoop.hive.shims.Hadoop23Shims.MiniSparkShim

All Implemented Interfaces:

HadoopShims.MiniMrShim

Enclosing class:

Hadoop23Shims

public class Hadoop23Shims.MiniSparkShim
extends Hadoop23Shims.MiniMrShim

Shim for MiniSparkOnYARNCluster

Constructor Summary

Constructors

Constructor and Description
MiniSparkShim(org.apache.hadoop.conf.Configuration conf, int numberOfTaskTrackers, String nameNode, int numDir)

Method Summary

Modifier and Type	Method and Description
int	getJobTrackerPort()
void	setupConfiguration(org.apache.hadoop.conf.Configuration conf)
void	shutdown()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MiniSparkShim

public MiniSparkShim(org.apache.hadoop.conf.Configuration conf,
                     int numberOfTaskTrackers,
                     String nameNode,
                     int numDir)
              throws IOException

Throws:

IOException

Method Detail

getJobTrackerPort

public int getJobTrackerPort()
                      throws UnsupportedOperationException

Specified by:

getJobTrackerPort in interface HadoopShims.MiniMrShim

Overrides:

getJobTrackerPort in class Hadoop23Shims.MiniMrShim

Throws:

UnsupportedOperationException

shutdown

public void shutdown()
              throws IOException

Specified by:

shutdown in interface HadoopShims.MiniMrShim

Overrides:

shutdown in class Hadoop23Shims.MiniMrShim

Throws:

IOException

setupConfiguration

public void setupConfiguration(org.apache.hadoop.conf.Configuration conf)

Specified by:

setupConfiguration in interface HadoopShims.MiniMrShim

Overrides:

setupConfiguration in class Hadoop23Shims.MiniMrShim