Package google.registry.batch

Class ExpandRecurringBillingEventsAction.ExpandRecurringBillingEventsReducer

  • All Implemented Interfaces:
    java.io.Serializable
    Enclosing class:
    ExpandRecurringBillingEventsAction
    public static class ExpandRecurringBillingEventsAction.ExpandRecurringBillingEventsReducer
extends com.google.appengine.tools.mapreduce.Reducer<org.joda.time.DateTime,​org.joda.time.DateTime,​java.lang.Void>
    "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, com.google.appengine.tools.mapreduce.ReducerInput<org.joda.time.DateTime> executionTimeInput)  

      • Methods inherited from class com.google.appengine.tools.mapreduce.Reducer

        emit

      • Methods inherited from class com.google.appengine.tools.mapreduce.Worker

        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,
                   com.google.appengine.tools.mapreduce.ReducerInput<org.joda.time.DateTime> executionTimeInput)
        Specified by:
        reduce in class com.google.appengine.tools.mapreduce.Reducer<org.joda.time.DateTime,​org.joda.time.DateTime,​java.lang.Void>