Class CreateSyntheticHistoryEntriesPipeline

  • All Implemented Interfaces:
    java.io.Serializable

    public class CreateSyntheticHistoryEntriesPipeline
    extends java.lang.Object
    implements java.io.Serializable
    Pipeline that creates a synthetic history entry for every EppResource in SQL at the current time.

    The history entries in Datastore does not have the EPP resource embedded in them. Therefore after InitSqlPipeline runs, these fields will all be empty. This pipeline loads all EPP resources and for each of them creates a synthetic history entry that contains the resource and saves them back to SQL, so that they can be used in the RDE pipeline.

    Note that this pipeline should only be run in a test environment right after the init SQL pipeline finishes, and no EPP update is being made to the system, otherwise there is no garuantee that the latest history entry for a given EPP resource does not already have the resource embedded within it.

    To run the pipeline:

    $ ./nom_build :core:cSHE --args="--region=us-central1 --runner=DataflowRunner --registryEnvironment=CRASH --project={project-id} --workerMachineType=n2-standard-4"

    See Also:
    CreateSyntheticHistoryEntriesAction, Serialized Form
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static void main​(java.lang.String[] args)  
      • Methods inherited from class java.lang.Object

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

      • CreateSyntheticHistoryEntriesPipeline

        public CreateSyntheticHistoryEntriesPipeline()
    • Method Detail

      • main

        public static void main​(java.lang.String[] args)