stream.io.multi

Class RandomMultiStream

java.lang.Object

stream.io.AbstractStream

stream.io.multi.AbstractMultiStream

stream.io.multi.RandomMultiStream

All Implemented Interfaces:

MultiStream, Source, Stream

public class RandomMultiStream
extends AbstractMultiStream

Author:

chris, hendrik

Field Summary

Fields

Modifier and Type	Field and Description
(package private) Double[]	weights

Fields inherited from class stream.io.multi.AbstractMultiStream

activate, activeWrapper, additionOrder, log, pool, streams

Fields inherited from class stream.io.AbstractStream

count, id, in, limit, prefix, seqId, sequenceKey, url

Constructor Summary

Constructors

Constructor and Description
RandomMultiStream()

Method Summary

Methods

Modifier and Type	Method and Description
Double[]	getWeights()
void	init()
Data	readNext()
protected String	selectNextStream()
void	setWeights(Double[] weights)

Methods inherited from class stream.io.multi.AbstractMultiStream

addStream, close, getActivate, getStreams, setActivate

Methods inherited from class stream.io.AbstractStream

getId, getInputStream, getLimit, getPrefix, getSequenceKey, getUrl, read, setId, setLimit, setPrefix, setSequenceKey, setUrl

Methods inherited from class java.lang.Object

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

Methods inherited from interface stream.io.Stream

getLimit, setLimit

Methods inherited from interface stream.io.Source

getId, read, setId

Field Detail

weights

Double[] weights

Constructor Detail

RandomMultiStream

public RandomMultiStream()

Method Detail

getWeights

public Double[] getWeights()

setWeights

public void setWeights(Double[] weights)

init

public void init()
          throws Exception

Specified by:

init in interface Source

Overrides:

init in class AbstractMultiStream

Throws:

Exception

See Also:

Source.init()

selectNextStream

protected String selectNextStream()

readNext

public Data readNext()
              throws Exception

Specified by:

readNext in class AbstractStream

Throws:

Exception