edu.yale.cs.hadoopdb.connector
Class DBChunk

java.lang.Object
  edu.yale.cs.hadoopdb.connector.DBChunk

All Implemented Interfaces:

java.io.Serializable

public class DBChunk
extends java.lang.Object
implements java.io.Serializable

For each relation chunk, this object stores connection and location information in a collection of DBChunkHost identified by their location or host address. This class and all included classes are serialized by DBInputSplit

See Also:

Serialized Form

Field Summary

private java.lang.String	id
private java.util.HashMap<java.lang.String,DBChunkHost>	locations
static org.apache.commons.logging.Log	LOG
private static java.util.Random	R
private static long	serialVersionUID

Constructor Summary

DBChunk(java.lang.String id)

Method Summary

void	addHost(DBChunkHost host)
DBChunkHost	getAnyHost() Randomly chooses a host from the set of hosts containing the chunk.
DBChunkHost	getAnyHost(DBChunkHost avoid_host) Randomly chooses a host from the set of hosts avoiding if possible the given host
DBChunkHost	getHost(java.lang.String host)
java.util.Collection<DBChunkHost>	getHosts()
java.lang.String	getId()
java.util.Collection<java.lang.String>	getLocations()
void	setId(java.lang.String id)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

id

private java.lang.String id

locations

private java.util.HashMap<java.lang.String,DBChunkHost> locations

LOG

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

R

private static java.util.Random R

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

Constructor Detail

DBChunk

public DBChunk(java.lang.String id)

Method Detail

addHost

public void addHost(DBChunkHost host)

getAnyHost

public DBChunkHost getAnyHost()

Randomly chooses a host from the set of hosts containing the chunk.

getAnyHost

public DBChunkHost getAnyHost(DBChunkHost avoid_host)

Randomly chooses a host from the set of hosts avoiding if possible the given host

getHost

public DBChunkHost getHost(java.lang.String host)

getHosts

public java.util.Collection<DBChunkHost> getHosts()

getId

public java.lang.String getId()

getLocations

public java.util.Collection<java.lang.String> getLocations()

setId

public void setId(java.lang.String id)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object