edu.yale.cs.hadoopdb.connector
Class DBConfiguration

java.lang.Object
  edu.yale.cs.hadoopdb.catalog.BaseDBConfiguration
      edu.yale.cs.hadoopdb.connector.DBConfiguration

public class DBConfiguration
extends BaseDBConfiguration

Extends BaseDBConfiguration class for MapReduce jobs that connect to databases. Assumes a single SQL query which is read in from the job configuration file. This is set by the HadoopDB job. Also, specifies the value class needed to recreate the value object from the records read in.

Field Summary

private org.apache.hadoop.mapred.JobConf	jobConf
static org.apache.commons.logging.Log	LOG
private java.lang.String	sqlQuery
private java.lang.Class	valueClass

Fields inherited from class edu.yale.cs.hadoopdb.catalog.BaseDBConfiguration

chunks, relation

Constructor Summary

DBConfiguration()

DBConfiguration(org.apache.hadoop.mapred.JobConf jobConf)

Method Summary

org.apache.hadoop.mapred.JobConf	getJobConf()
java.lang.String	getSqlQuery()
java.lang.Class	getValueClass()
void	setJobConf(org.apache.hadoop.mapred.JobConf jobConf)
void	setSqlQuery(java.lang.String sqlQuery)
void	setValueClass(java.lang.Class valueClass)

Methods inherited from class edu.yale.cs.hadoopdb.catalog.BaseDBConfiguration

addChunk, getChunk, getChunks, getRelation, setRelation

Methods inherited from class java.lang.Object

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

Field Detail

jobConf

private org.apache.hadoop.mapred.JobConf jobConf

LOG

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

sqlQuery

private java.lang.String sqlQuery

valueClass

private java.lang.Class valueClass

Constructor Detail

DBConfiguration

public DBConfiguration()

DBConfiguration

public DBConfiguration(org.apache.hadoop.mapred.JobConf jobConf)

Method Detail

getJobConf

public org.apache.hadoop.mapred.JobConf getJobConf()

getSqlQuery

public java.lang.String getSqlQuery()

getValueClass

public java.lang.Class getValueClass()

setJobConf

public void setJobConf(org.apache.hadoop.mapred.JobConf jobConf)

setSqlQuery

public void setSqlQuery(java.lang.String sqlQuery)

setValueClass

public void setValueClass(java.lang.Class valueClass)