com.actian.vw.connector.util

Class VwUtil

java.lang.Object

com.actian.vw.connector.util.VwUtil

public class VwUtil
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.commons.logging.Log	LOG

Constructor Summary

Constructors

Constructor and Description
VwUtil()

Method Summary

Methods

Modifier and Type	Method and Description
static IX100Connector	getConnection(VwProperties config) Fetch X100 server connection
static String	getDatabase(String url) Fetch the database from URL
static String	getHost(String url) Fetch the host from URL
static String	getIpAddress(String jdbcUrl)
static int	getParallelCommitJOBID(VwProperties props, int reducers) Fetch parallel commit job id.
static String	getPort(String url) Fetch the port from URL
static String	getSortedDirPath(String dir)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.apache.commons.logging.Log LOG

Constructor Detail

VwUtil

public VwUtil()

Method Detail

getParallelCommitJOBID

public static int getParallelCommitJOBID(VwProperties props,
                         int reducers)
                                  throws Exception

Fetch parallel commit job id. This will be passed on job context to all the Reduce jobs

Parameters:

job -

Returns:

Throws:

Exception

getHost

public static String getHost(String url)

Fetch the host from URL

Parameters:

url -

Returns:

getPort

public static String getPort(String url)

Fetch the port from URL

Parameters:

url -

Returns:

getDatabase

public static String getDatabase(String url)

Fetch the database from URL

Parameters:

url -

Returns:

getSortedDirPath

public static String getSortedDirPath(String dir)

getConnection

public static IX100Connector getConnection(VwProperties config)
                                    throws ConnectionException,
                                           GeneralSecurityException,
                                           org.apache.commons.codec.DecoderException

Fetch X100 server connection

Parameters:

config -

Returns:

Throws:

ConnectionException

GeneralSecurityException

org.apache.commons.codec.DecoderException

getIpAddress

public static String getIpAddress(String jdbcUrl)
                           throws ConnectionException

Throws:

ConnectionException