Inheritance diagram for lsst.pipe.tasks.multiBand.MergeMeasurementsTask:

Public Member Functions
def	__init__

def	mergeCatalogs

Public Member Functions inherited from lsst.pipe.tasks.multiBand.MergeSourcesTask
def	getInputSchema

def	__init__

def	run

def	readCatalog

def	mergeCatalogs

def	write

def	writeMetadata

Public Attributes
	schemaMapper

	flagKeys

	schema

Static Public Attributes
string	inputDataset = "meas"

string	outputDataset = "ref"

tuple	getSchemaCatalogs = _makeGetSchemaCatalogs("ref")

Static Public Attributes inherited from lsst.pipe.tasks.multiBand.MergeSourcesTask
	ConfigClass = MergeSourcesConfig

	RunnerClass = MergeSourcesRunner

	inputDataset = None

	outputDataset = None

	getSchemaCatalogs = None

Static Private Attributes
string	_DefaultName = "mergeCoaddMeasurements"

Detailed Description

Measure measurements from multiple bands

Definition at line 651 of file multiBand.py.

Constructor & Destructor Documentation

def lsst.pipe.tasks.multiBand.MergeMeasurementsTask.__init__	(	self,
		butler = `None`,
		schema = `None`,
		kwargs
	)

Initialize the task.

Additional keyword arguments (forwarded to MergeSourcesTask.__init__):
 - schema: the schema of the detection catalogs used as input to this one
 - butler: a butler used to read the input schema from disk, if schema is None

The task will set its own self.schema attribute to the schema of the output merged catalog.

Definition at line 658 of file multiBand.py.

 
     def __init__(self, butler=None, schema=None, **kwargs):
         """Initialize the task.
 
         Additional keyword arguments (forwarded to MergeSourcesTask.__init__):
          - schema: the schema of the detection catalogs used as input to this one
          - butler: a butler used to read the input schema from disk, if schema is None
 
         The task will set its own self.schema attribute to the schema of the output merged catalog.
         """
         MergeSourcesTask.__init__(self, butler=butler, schema=schema, **kwargs)
         inputSchema = self.getInputSchema(butler=butler, schema=schema)
         self.schemaMapper = afwTable.SchemaMapper(inputSchema, True)
         self.schemaMapper.addMinimalSchema(inputSchema, True)
         self.flagKeys = {}
         for band in self.config.priorityList:
             short = getShortFilterName(band)
             outputKey = self.schemaMapper.editOutputSchema().addField(
                 "merge_measurement_%s" % short,
                 type="Flag",
                 doc="Flag field set if the measurements here are from the %s filter" % band
             )
             peakKey = inputSchema.find("merge_peak_%s" % short).key
             footprintKey = inputSchema.find("merge_footprint_%s" % short).key
             self.flagKeys[band] = Struct(peak=peakKey, footprint=footprintKey, output=outputKey)
         self.schema = self.schemaMapper.getOutputSchema()