com.northconcepts.datapipeline.core

Class MultiWriter.AvailableCapacityWriteStrategy

java.lang.Object

com.northconcepts.datapipeline.core.MultiWriter.WriteStrategy

com.northconcepts.datapipeline.core.MultiWriter.AvailableCapacityWriteStrategy

Enclosing class:

MultiWriter

public static class MultiWriter.AvailableCapacityWriteStrategy
extends MultiWriter.WriteStrategy

Writes each record to a single writer by choosing the one with the highest available capacity (DataWriter.available() If all writers have identical capacities, this strategy behaves like MultiWriter.RoundRobinWriteStrategy and writes to each writer in turn.

Constructor Summary

Constructors

Constructor and Description
AvailableCapacityWriteStrategy()

Method Summary

Modifier and Type	Method and Description
protected void	write(Record record, List<DataWriter> list)

Methods inherited from class java.lang.Object

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

Constructor Detail

AvailableCapacityWriteStrategy

public AvailableCapacityWriteStrategy()

Method Detail

write

protected void write(Record record,
                     List<DataWriter> list)
              throws Throwable

Specified by:

write in class MultiWriter.WriteStrategy

Throws:

Throwable