Package com.northconcepts.datapipeline.group

Class Window

java.lang.Object
com.northconcepts.datapipeline.core.DataObject
com.northconcepts.datapipeline.core.Endpoint
com.northconcepts.datapipeline.core.DataEndpoint
com.northconcepts.datapipeline.group.Window
public class Window extends DataEndpoint
Windows accept detail data for aggregation while open and only yield its summary after being closed.

  • Constructor Details

    • Window

      public Window(GroupByReader groupByReader)
      Creates a window using the reader's group-by fields, operations and null-group setting.

  • Method Details

    • addExceptionProperties

      public DataException addExceptionProperties(DataException exception)
      Description copied from class: Endpoint
      Adds this endpoint's current state to a DataException. Since this method is called whenever an exception is thrown, subclasses should override it to add their specific information.
      Overrides:
      addExceptionProperties in class DataEndpoint

    • add

      public void add(Record record)
      Adds the record to the group(s) selected by its group-by field values; only allowed while this window is open.

    • open

      public void open() throws DataException
      Description copied from class: DataEndpoint
      Makes this endpoint ready for reading or writing.
      Overrides:
      open in class DataEndpoint
      Throws:
      DataException

    • close

      public void close() throws DataException
      Description copied from class: DataEndpoint
      Indicates that this endpoint has finished reading or writing.
      Overrides:
      close in class DataEndpoint
      Throws:
      DataException

    • nextRecord

      public Record nextRecord()
      Returns the next group's summary record or null after the last one; only allowed after this window is closed.