image_rsexecute_map_workflow
- image_rsexecute_map_workflow(im, imfunction, facets=1, overlap=0, taper=None, **kwargs)[source]
Apply a function across an image: scattering to subimages, applying the function, and then gathering
- Parameters:
im – Image to be processed
imfunction – Function to be applied
facets – See image_scatter_facets
overlap – image_scatter_facets
taper – image_scatter_facets
kwargs – kwargs for imfunction
- Returns:
graph for output image
For example:
rsexecute.set_client(use_dask=True) model = create_test_image(frequency=frequency, phasecentre=phasecentre, cellsize=0.001, polarisation_frame=PolarisationFrame('stokesI')) def imagerooter(im, **kwargs): im["pixels"].data = numpy.sqrt(numpy.abs(im["pixels"].data)) return im root_graph = image_rsexecute_map_workflow(model, imagerooter, facets=16) root_image = rsexecute.compute(root_graph, sync=True)