com.endeca.portal.util

Class HadoopUtil

java.lang.Object

com.endeca.portal.util.HadoopUtil

public class HadoopUtil
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
HadoopUtil()

Method Summary

Methods

Modifier and Type	Method and Description
static java.lang.String	buildUrl(java.lang.String hadoopClusterHostnameSettingKey, java.lang.String serverPortKey)
static boolean	changeFilePath(com.oracle.eid.oozie.workflow.HadoopCluster hc, java.lang.String srcPath, java.lang.String desPath)
static com.oracle.eid.oozie.workflow.HadoopCluster	createHadoopCluster()
static com.oracle.eid.oozie.hive.HiveServer	createHiveServer()
static org.apache.hadoop.fs.Path	createRemotePath(com.oracle.eid.oozie.workflow.HadoopCluster hc, java.lang.String base, boolean isDirectory, java.lang.String... subpath)
static org.apache.sqoop.client.SqoopClient	createSqoopServerClient()
static void	deleteDirectory(com.oracle.eid.oozie.workflow.HadoopCluster hc, java.lang.String path)
static java.lang.String	getHadoopSettingByKey(java.lang.String key)
static java.lang.String	getSandboxPath()
static java.lang.String	getSqoopJobOutputFilePath()

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopUtil

public HadoopUtil()

Method Detail

createHadoopCluster

public static com.oracle.eid.oozie.workflow.HadoopCluster createHadoopCluster()
                                                                       throws MetadataException

Throws:

MetadataException

createHiveServer

public static com.oracle.eid.oozie.hive.HiveServer createHiveServer()

createSqoopServerClient

public static org.apache.sqoop.client.SqoopClient createSqoopServerClient()

buildUrl

public static java.lang.String buildUrl(java.lang.String hadoopClusterHostnameSettingKey,
                        java.lang.String serverPortKey)

getSqoopJobOutputFilePath

public static java.lang.String getSqoopJobOutputFilePath()

createRemotePath

public static org.apache.hadoop.fs.Path createRemotePath(com.oracle.eid.oozie.workflow.HadoopCluster hc,
                                         java.lang.String base,
                                         boolean isDirectory,
                                         java.lang.String... subpath)
                                                  throws java.io.IOException

Throws:

java.io.IOException

deleteDirectory

public static void deleteDirectory(com.oracle.eid.oozie.workflow.HadoopCluster hc,
                   java.lang.String path)
                            throws java.lang.IllegalArgumentException,
                                   java.io.IOException

Throws:

java.lang.IllegalArgumentException

java.io.IOException

getHadoopSettingByKey

public static java.lang.String getHadoopSettingByKey(java.lang.String key)

changeFilePath

public static boolean changeFilePath(com.oracle.eid.oozie.workflow.HadoopCluster hc,
                     java.lang.String srcPath,
                     java.lang.String desPath)
                              throws java.io.IOException

Throws:

java.io.IOException

getSandboxPath

public static java.lang.String getSandboxPath()