com.northconcepts.datapipeline.core.SequenceWriter.SchedulerSequenceStrategy

public static class SequenceWriter.SchedulerSequenceStrategy extends Object implements SequenceWriter.ISequenceStrategy

Ends the current sequence at each time produced by a Scheduler; checked only when the next record arrives.

Constructor Details
- SchedulerSequenceStrategy
  
  public SchedulerSequenceStrategy(Scheduler scheduler)
Method Details
- endSequence
  
  public boolean endSequence(SequenceWriter.Sequence sequence, Record record)
  
  Description copied from interface: SequenceWriter.ISequenceStrategy
  
  Returns true to end the current sequence before the given record is written, so that the record starts a new one.
  
  Specified by:
  
  endSequence in interface SequenceWriter.ISequenceStrategy

Class SequenceWriter.SchedulerSequenceStrategy

Constructor Summary