eradiate.pipelines#

Basic pipeline infrastructure#

Pipeline([steps])

A simple data processing pipeline remotely inspired from scikit-learn's Pipeline class.

PipelineStep()

Interface for pipeline step definitions.

Gather step#

Gather([prefix, sensor_dims, var])

Gather raw kernel results (output as nested dictionaries) into an xarray dataset.

Aggregate steps#

AggregateCKDQuad(measure[, var])

Compute CKD quadrature.

AggregateSampleCount()

Aggregate sample count.

AggregateRadiosity([sector_radiosity_var, ...])

Aggregate flux density field.

Assemble steps#

AddViewingAngles(measure)

Create new vza and vaa coordinate variables mapping viewing angles to other coordinates.

AddIllumination(illumination, measure[, ...])

Add illumination data.

AddSpectralResponseFunction(measure)

Add spectral response function data.

Compute steps#

ComputeReflectance([radiance_var, ...])

Derive reflectance from radiance and irradiance values.

ComputeAlbedo([radiosity_var, ...])

Derive the albedo from radiosity and irradiance fields.

ApplySpectralResponseFunction(measure[, vars])

Apply spectral response function to specified variables.