Interface SelectionPredicate


public interface SelectionPredicate
Differentiating factor between the first and the last aggregator. Specifies the
  • Field Details

  • Method Details

    • initValue

      long initValue()
      Returns:
      Time value to initialize the aggregation with
    • apply

      boolean apply(long currentTime, long selectedTime)
      Parameters:
      currentTime - Time of the current row
      selectedTime - Aggregated time value
      Returns:
      true if the current row should be selected over the aggregated value, else false