Client Side Delivery

The goal of client side delivery is to provide functions that can be called from a python script to perform a parallel aggregation of data with the result obtained on the client. This goal is accomplished with a combination of new, modified, and existing filters. A wrapper filter that automates the creation and control of the necessary pipeline of proxies is under development.

Design

vtkSMGenericViewDisplayProxy

This unmodified filter orchestrates gathering results in paraview for the GUI. The filter internally uses a vtkReductionFilter to direct communications between the server nodes and a vtkClientServerModeData filter that transmits data from the server to the client. For our purposes we use vtkSMGenericViewDisplayProxy's FIRST_NODE_ONLY reduction type setting, which simply transmits data from the root node of the server to the client.

vtkReductionFilter

This modified filter does the communication needed to perform the aggregation. This filter defers all data manipulation to a user provided algorithm. The filter has been modified to run an additional user provided algorithm, which each node executes in parallel _before_ sending their data to the root node. This pregather algorithm is essential for scalability. After the root node obtains the intermediate results from all nodes it runs a user provided algorithm as before. Both pre and post gather algorithms can refer to the same object. The vtkReductionFilter was also modified to allow simple passthrough of data and to be able to pass though any one particular cluster node's data.

vtkMinMax

A new filter that performs an operation on the attribute data of its input. This filter iterates through whatever datasets it is given and calls a templated operate function on each value. The templated function is necessary to avoid double conversion and loss of precision on non double valued arrays. This filter can take one or more input datasets on its first input port and always produces a single unstructured grid output that contains exactly one point and one cell.

Example use

import paraview
#connect to a running pvserver
paraview.ActiveConnection = paraview.Connect("localhost", 11111)
#create a sample data set
sphere = paraview.CreateProxy("sources", "SphereSource")
elev = paraview.CreateProxy("filters", "ElevationFilter")
elev.SetInput(sphere)

#create the reduction pipeline
fetch = paraview.CreateProxy("displays", "GenericViewDisplay")
fetch.SetInput(elev)
fetch.SetReductionType(3) #collect from root node only
#tell fetch that its vtkReductionFilter should use the new vtkMinMax
#algorithm on each node and on the root node on the gathered results
op = paraview.CreateProxy("filters", "Operator")
op.SetOperation(0) #min as opposed to max
op.UpdateVTKObjects()
fetch.SetPreReductionHelper(op)
fetch.SetReductionHelper(op)
#uncomment the next line to get the result from node 1 instead of all
#fetch.SetPassThrough(1) 
fetch.UpdateVTKObjects()

#go!
fetch.Update()

#the result will be stored in the first (and only) tuple of each array
out = fetch.GetOutput()
arr = out.GetPointData().GetArray("Elevation")
arr.GetValue(0)