Class Pipeline

Examples/Catalyst/TemporalCacheExample/SampleScripts/timestats.py:15–29

def CreateCoProcessor():
  def _CreatePipeline(coprocessor, datadescription):
    class Pipeline:
      # KEY POINT:
      # Ask the coprocessor for a temporal producer instead of a normal one
      # data = coprocessor.CreateProducer( datadescription, "volume" )
      data = coprocessor.CreateTemporalProducer( datadescription, "volume" )

      # write out each volume like you might do normally
      imageDataWriter1 = servermanager.writers.XMLPImageDataWriter(Input=data)
      coprocessor.RegisterWriter(imageDataWriter1, filename="tcache_pyex_{time}.pvti", freq=10)

      # The fun part do something across timesteps
      # We will output a temporal statistics volume every 10 frames
      temporalStatistics1 = TemporalStatistics(Input=data)
      imageDataWriter2 = servermanager.writers.XMLPImageDataWriter(Input=temporalStatistics1)
      coprocessor.RegisterWriter(imageDataWriter2, filename="tcache_pyex_tstats_{time}.pvti", freq=10)

    return Pipeline()