Package nz.org.riskscape.engine.output

Class BaseJdbcPipelineOutputContainer<S extends BaseJdbcOutputStore>

java.lang.Object
nz.org.riskscape.engine.output.BasePipelineOutputContainer
nz.org.riskscape.engine.output.BaseJdbcPipelineOutputContainer<S>
All Implemented Interfaces:
AutoCloseable, nz.org.riskscape.engine.output.PipelineOutputContainer
public abstract class BaseJdbcPipelineOutputContainer<S extends BaseJdbcOutputStore> extends nz.org.riskscape.engine.output.BasePipelineOutputContainer

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected final S
    backingStore
     
    static final String
    MANIFEST_TABLE
     
    static final nz.org.riskscape.engine.types.Struct
    MANIFEST_TYPE
     
    protected final List<String>
    outputTables
     

    Fields inherited from class nz.org.riskscape.engine.output.BasePipelineOutputContainer

    currentTime, fileOutputs, manifest, movedFileOutputs, options, pipeline, sinks, startedAt, store

  • Constructor Summary

    Constructors
    Constructor
    Description
    BaseJdbcPipelineOutputContainer(nz.org.riskscape.engine.output.PipelineOutputStore outputStore, S backingStore, nz.org.riskscape.engine.pipeline.RealizedPipeline pipeline, nz.org.riskscape.engine.output.PipelineOutputOptions options)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    protected nz.org.riskscape.problem.ResultOrProblems<nz.org.riskscape.engine.pipeline.sink.SaveSink>
    createSink(nz.org.riskscape.engine.output.SinkParameters parameters)
     

    Methods inherited from class nz.org.riskscape.engine.output.BasePipelineOutputContainer

    buildStatsWriter, createSinkForStep, getEngine, getExecutionContext, getPipeline, getPipelineOutputs, getPipelineSource, getProject, getResourceFactory, getSinks, getStore, registerLocalFile

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface nz.org.riskscape.engine.output.PipelineOutputContainer

    getStoredAt

  • Field Details

    • MANIFEST_TABLE

      public static final String MANIFEST_TABLE
      See Also:

    • MANIFEST_TYPE

      public static final nz.org.riskscape.engine.types.Struct MANIFEST_TYPE

    • backingStore

      protected final S extends BaseJdbcOutputStore backingStore

    • outputTables

      protected final List<String> outputTables

  • Constructor Details

    • BaseJdbcPipelineOutputContainer

      public BaseJdbcPipelineOutputContainer(nz.org.riskscape.engine.output.PipelineOutputStore outputStore, S backingStore, nz.org.riskscape.engine.pipeline.RealizedPipeline pipeline, nz.org.riskscape.engine.output.PipelineOutputOptions options)

  • Method Details

    • createSink

      protected nz.org.riskscape.problem.ResultOrProblems<nz.org.riskscape.engine.pipeline.sink.SaveSink> createSink(nz.org.riskscape.engine.output.SinkParameters parameters)
      Specified by:
      createSink in class nz.org.riskscape.engine.output.BasePipelineOutputContainer

    • close

      public void close()