Inheritance diagram for lsst.ip.diffim.imageMapReduce.ImageMapReduceTask:

Public Member Functions
def	__init__ (self, args, *kwargs)

def	run (self, exposure, **kwargs)

def	plotBoxes (self, fullBBox, skip=3)

Public Attributes
	boxes0

	boxes1

Static Public Attributes
	ConfigClass = ImageMapReduceConfig

Detailed Description

Split an Exposure into subExposures (optionally on a grid) and
perform the same operation on each.

Perform 'simple' operations on a gridded set of subExposures of a
larger Exposure, and then (by default) have those subExposures
stitched back together into a new, full-sized image.

Contrary to the expectation given by its name, this task does not
perform these operations in parallel, although it could be updatd
to provide such functionality.

The actual operations are performed by two subTasks passed to the
config. The exposure passed to this task's `run` method will be
divided, and those subExposures will be passed to the subTasks,
along with the original exposure. The reducing operation is
performed by the second subtask.

Definition at line 488 of file imageMapReduce.py.

Constructor & Destructor Documentation

◆ init()

def lsst.ip.diffim.imageMapReduce.ImageMapReduceTask.__init__	(		self,
		*	args,
		**	kwargs
	)

Create the image map-reduce task

Parameters
----------
args :
    arguments to be passed to
    `lsst.pipe.base.task.Task.__init__`
kwargs :
    additional keyword arguments to be passed to
    `lsst.pipe.base.task.Task.__init__`

Definition at line 509 of file imageMapReduce.py.

     def __init__(self, *args, **kwargs):
         """Create the image map-reduce task
  
         Parameters
         ----------
         args :
             arguments to be passed to
             `lsst.pipe.base.task.Task.__init__`
         kwargs :
             additional keyword arguments to be passed to
             `lsst.pipe.base.task.Task.__init__`
         """
         pipeBase.Task.__init__(self, *args, **kwargs)
  
         self.boxes0 = self.boxes1 = None
         self.makeSubtask("mapper")
         self.makeSubtask("reducer")
  

Member Function Documentation

◆ plotBoxes()

def lsst.ip.diffim.imageMapReduce.ImageMapReduceTask.plotBoxes	(	self,
		fullBBox,
		skip = `3`
	)

Plot both grids of boxes using matplotlib.

Will compute the grid via `_generateGrid` if
`self.boxes0` and `self.boxes1` have not already been set.

Parameters
----------
exposure : `lsst.afw.image.Exposure`
    Exposure whose bounding box is gridded by this task.
skip : `int`
    Plot every skip-ped box (help make plots less confusing)

Definition at line 762 of file imageMapReduce.py.

     def plotBoxes(self, fullBBox, skip=3):
         """Plot both grids of boxes using matplotlib.
  
         Will compute the grid via `_generateGrid` if
         `self.boxes0` and `self.boxes1` have not already been set.
  
         Parameters
         ----------
         exposure : `lsst.afw.image.Exposure`
             Exposure whose bounding box is gridded by this task.
         skip : `int`
             Plot every skip-ped box (help make plots less confusing)
         """
         import matplotlib.pyplot as plt
  
         if self.boxes0 is None:
             raise RuntimeError('Cannot plot boxes. Run _generateGrid first.')
         self._plotBoxGrid(self.boxes0[::skip], fullBBox, ls='--')
         # reset the color cycle -- see
         # http://stackoverflow.com/questions/24193174/reset-color-cycle-in-matplotlib
         plt.gca().set_prop_cycle(None)
         self._plotBoxGrid(self.boxes1[::skip], fullBBox, ls=':')
  

◆ run()

def lsst.ip.diffim.imageMapReduce.ImageMapReduceTask.run	(		self,
			exposure,
		**	kwargs
	)

Perform a map-reduce operation on the given exposure.

Split the exposure into sub-expposures on a grid (parameters
given by `ImageMapReduceConfig`) and perform
`config.mapper.run()` on each. Reduce the resulting
sub-exposures by running `config.reducer.run()`.

Parameters
----------
exposure : `lsst.afw.image.Exposure`
    the full exposure to process
kwargs :
    additional keyword arguments to be passed to
    subtask `run` methods

Returns
-------
output of `reducer.run()`

Definition at line 528 of file imageMapReduce.py.

     def run(self, exposure, **kwargs):
         """Perform a map-reduce operation on the given exposure.
  
         Split the exposure into sub-expposures on a grid (parameters
         given by `ImageMapReduceConfig`) and perform
         `config.mapper.run()` on each. Reduce the resulting
         sub-exposures by running `config.reducer.run()`.
  
         Parameters
         ----------
         exposure : `lsst.afw.image.Exposure`
             the full exposure to process
         kwargs :
             additional keyword arguments to be passed to
             subtask `run` methods
  
         Returns
         -------
         output of `reducer.run()`
  
         """
         self.log.info("Mapper sub-task: %s", self.mapper._DefaultName)
         mapperResults = self._runMapper(exposure, **kwargs)
         self.log.info("Reducer sub-task: %s", self.reducer._DefaultName)
         result = self._reduceImage(mapperResults, exposure, **kwargs)
         return result
  

Member Data Documentation

◆ boxes0

lsst.ip.diffim.imageMapReduce.ImageMapReduceTask.boxes0

Definition at line 523 of file imageMapReduce.py.

◆ boxes1

lsst.ip.diffim.imageMapReduce.ImageMapReduceTask.boxes1

Definition at line 523 of file imageMapReduce.py.

◆ ConfigClass

lsst.ip.diffim.imageMapReduce.ImageMapReduceTask.ConfigClass = ImageMapReduceConfig

static

Definition at line 506 of file imageMapReduce.py.

The documentation for this class was generated from the following file:

/j/snowflake/release/lsstsw/stack/lsst-scipipe-0.7.0/Linux64/ip_diffim/22.0.1-24-g1ad7a390+a9625a72a8/python/lsst/ip/diffim/imageMapReduce.py

Public Member Functions

Public Attributes

Static Public Attributes