Function execute

IO/ParallelXML/Testing/Python/testParallelXMLWriters.py:52–66

()

pf = vtkProgrammableFilter()

def execute():
    info = pf.GetOutputInformation(0)
    et = vtkExtentTranslator()

    if pf.GetInput().IsA("vtkDataSet"):
        et.SetWholeExtent(info.Get(vtkStreamingDemandDrivenPipeline.WHOLE_EXTENT()))
        et.SetPiece(info.Get(vtkStreamingDemandDrivenPipeline.UPDATE_PIECE_NUMBER()))
        et.SetNumberOfPieces(info.Get(vtkStreamingDemandDrivenPipeline.UPDATE_NUMBER_OF_PIECES()))
        et.PieceToExtent()

    output = pf.GetOutput()
    input = pf.GetInput()
    output.ShallowCopy(input)
    if pf.GetInput().IsA("vtkDataSet"):
        output.Crop(et.GetExtent())

pf.SetExecuteMethod(execute)