lsst.pipe.tasks.postprocess Namespace Reference

Classes
class	ConsolidateObjectTableConfig
class	ConsolidateObjectTableTask
class	ConsolidateSourceTableConfig
class	ConsolidateSourceTableTask
class	PostprocessAnalysis
class	TractObjectDataIdContainer
class	TransformCatalogBaseConfig
class	TransformCatalogBaseTask
class	TransformObjectCatalogConfig
class	TransformObjectCatalogTask
class	TransformSourceTableConfig
class	TransformSourceTableTask
class	VisitDataIdContainer
class	WriteObjectTableConfig
class	WriteObjectTableTask
class	WriteSourceTableConfig
class	WriteSourceTableTask

Functions
def	flattenFilters (df, filterDict, noDupCols=['coord_ra', 'coord_dec'], camelCase=False)

Function Documentation

flattenFilters()

def lsst.pipe.tasks.postprocess.flattenFilters	(		df,
			filterDict,
			noDupCols = ['coord_ra', 'coord_dec'],
			camelCase = False
	)

Flattens a dataframe with multilevel column index

Definition at line 39 of file postprocess.py.

def flattenFilters(df, filterDict, noDupCols=['coord_ra', 'coord_dec'], camelCase=False):
    """Flattens a dataframe with multilevel column index
    """
    newDf = pd.DataFrame()
    for filt, filtShort in filterDict.items():
        subdf = df[filt]
        columnFormat = '{0}{1}' if camelCase else '{0}_{1}'
        newColumns = {c: columnFormat.format(filtShort, c)
                      for c in subdf.columns if c not in noDupCols}
        cols = list(newColumns.keys())
        newDf = pd.concat([newDf, subdf[cols].rename(columns=newColumns)], axis=1)
 
    newDf = pd.concat([subdf[noDupCols], newDf], axis=1)
    return newDf