edu.yale.cs.hadoopdb.catalog
Class BaseDBConfiguration

java.lang.Object
  extended by edu.yale.cs.hadoopdb.catalog.BaseDBConfiguration
Direct Known Subclasses:
DBConfiguration, SMSConfiguration

public class BaseDBConfiguration
extends java.lang.Object

BaseDBConfiguration re-maps the Catalog object created by ConfigurationMapping: Instead of mapping nodes to relations to chunks (partitions), it maps chunks to hosts (nodes) for a given relation.


Field Summary
protected  java.util.HashMap<java.lang.String,DBChunk> chunks
           
protected  java.lang.String relation
           
 
Constructor Summary
BaseDBConfiguration()
           
 
Method Summary
 void addChunk(DBChunk chunk)
          Maps DBChunk Object to its partition id
 DBChunk getChunk(java.lang.String id)
          Returns a DBChunk Object for a given chunk id
 java.util.Collection<DBChunk> getChunks()
          Returns a list of DBChunk Objects for a given relation
 java.lang.String getRelation()
          Get relation (Relation maintained for bookkeeping, not used internally)
 void setRelation(java.lang.String relation)
          Set relation for bookkeeping purpose, not used internally
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

chunks

protected java.util.HashMap<java.lang.String,DBChunk> chunks

relation

protected java.lang.String relation
Constructor Detail

BaseDBConfiguration

public BaseDBConfiguration()
Method Detail

addChunk

public void addChunk(DBChunk chunk)
Maps DBChunk Object to its partition id

Parameters:
chunk -

getChunk

public DBChunk getChunk(java.lang.String id)
Returns a DBChunk Object for a given chunk id

Parameters:
id - a chunk of a particular relation
Returns:
DBChunk chunk for a given id

getChunks

public java.util.Collection<DBChunk> getChunks()
Returns a list of DBChunk Objects for a given relation

Returns:
Collection chunks

getRelation

public java.lang.String getRelation()
Get relation (Relation maintained for bookkeeping, not used internally)

Returns:
relation the relation's identifier

setRelation

public void setRelation(java.lang.String relation)
Set relation for bookkeeping purpose, not used internally

Parameters:
relation - the relation's identifier