Class ExpandRecurringBillingEventsAction.ExpandRecurringBillingEventsReducer

  • All Implemented Interfaces:
    Enclosing class:

    public static class ExpandRecurringBillingEventsAction.ExpandRecurringBillingEventsReducer
    "Reducer" to advance the cursor after all map jobs have been completed. The NullInput into the mapper will cause the mapper to emit one timestamp pair (current cursor and execution time), and the cursor will be advanced (and the timestamps logged) at the end of a successful mapreduce.
    See Also:
    Serialized Form
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void reduce​(org.joda.time.DateTime cursorTime,<org.joda.time.DateTime> executionTimeInput)  
      • Methods inherited from class

      • Methods inherited from class

        allowSliceRetry, beginShard, beginSlice, endShard, endSlice, estimateMemoryRequirement, getContext, setContext
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • ExpandRecurringBillingEventsReducer

        public ExpandRecurringBillingEventsReducer​(boolean isDryRun,
                                                   org.joda.time.DateTime expectedPersistedCursorTime)
    • Method Detail

      • reduce

        public void reduce​(org.joda.time.DateTime cursorTime,
                 <org.joda.time.DateTime> executionTimeInput)
        Specified by:
        reduce in class<org.joda.time.DateTime,​org.joda.time.DateTime,​java.lang.Void>