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

Description

AvailableCapacityWriteStrategy()
Method Summary

Modifier and Type

Method

Description

protected void

write(Record record, List<DataWriter> list)

Writes the record to one or more of the target writers; the list is never empty.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- AvailableCapacityWriteStrategy
  
  public AvailableCapacityWriteStrategy()
Method Details
- write
  
  protected void write(Record record, List<DataWriter> list) throws Throwable
  
  Description copied from class: MultiWriter.WriteStrategy
  
  Writes the record to one or more of the target writers; the list is never empty.
  
  Specified by:
  
  write in class MultiWriter.WriteStrategy
  
  Throws:
  
  Throwable

Class MultiWriter.AvailableCapacityWriteStrategy

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Details

AvailableCapacityWriteStrategy

Method Details

write