SequenceWriter.ElapsedTimeSequenceStrategy (Data Pipeline JavaDoc)

java.lang.Object

com.northconcepts.datapipeline.core.SequenceWriter.ElapsedTimeSequenceStrategy

All Implemented Interfaces:: SequenceWriter.ISequenceStrategy

Enclosing class:: SequenceWriter

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

Ends a sequence once it has been running for a given time; checked only when the next record arrives.

Constructor Summary

Constructors

Constructor

Description

ElapsedTimeSequenceStrategy(long elapsedTime)

Creates a strategy that ends each sequence after elapsedTime milliseconds.
Method Summary

Modifier and Type

Method

Description

boolean

endSequence(SequenceWriter.Sequence sequence, Record record)

Returns true to end the current sequence before the given record is written, so that the record starts a new one.

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

Constructor Details
- ElapsedTimeSequenceStrategy
  
  public ElapsedTimeSequenceStrategy(long elapsedTime)
  
  Creates a strategy that ends each sequence after elapsedTime milliseconds.
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