ITK  6.0.0
Insight Toolkit
SphinxExamples/src/Core/Common/StreamAPipeline/Code.py
1 #!/usr/bin/env python
2 
3 # Copyright NumFOCUS
4 #
5 # Licensed under the Apache License, Version 2.0 (the "License");
6 # you may not use this file except in compliance with the License.
7 # You may obtain a copy of the License at
8 #
9 # https://www.apache.org/licenses/LICENSE-2.0.txt
10 #
11 # Unless required by applicable law or agreed to in writing, software
12 # distributed under the License is distributed on an "AS IS" BASIS,
13 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 # See the License for the specific language governing permissions and
15 # limitations under the License.
16 
17 import sys
18 import itk
19 import argparse
20 
21 from distutils.version import StrictVersion as VS
22 
23 if VS(itk.Version.GetITKVersion()) < VS("4.10.0"):
24  print("ITK 4.10.0 is required.")
25  sys.exit(1)
26 
27 parser = argparse.ArgumentParser(description="Stream A Pipeline.")
28 parser.add_argument("number_of_splits", type=int)
29 args = parser.parse_args()
30 
31 Dimension = 2
32 PixelType = itk.UC
33 ImageType = itk.Image[PixelType, Dimension]
34 
35 source = itk.RandomImageSource[ImageType].New()
36 size = itk.Size[Dimension]()
37 size.Fill(args.number_of_splits)
38 source.SetSize(size)
39 
40 monitorFilter = itk.PipelineMonitorImageFilter[ImageType].New()
41 monitorFilter.SetInput(source.GetOutput())
42 
43 streamingFilter = itk.StreamingImageFilter[ImageType, ImageType].New()
44 streamingFilter.SetInput(monitorFilter.GetOutput())
45 streamingFilter.SetNumberOfStreamDivisions(args.number_of_splits)
46 
47 streamingFilter.Update()
48 
49 print(
50  "The output LargestPossibleRegion is: "
51  + str(streamingFilter.GetOutput().GetLargestPossibleRegion())
52 )
53 
54 print("")
55 
56 updatedRequestedRegions = monitorFilter.GetUpdatedRequestedRegions()
57 print("Updated ApplyAFilterOnlyToASpecifiedImageRegion's:")
58 for ii in range(len(updatedRequestedRegions)):
59  print(" " + str(updatedRequestedRegions[ii]))
itk::Version::GetITKVersion
static const char * GetITKVersion()
itk::Size
Represent a n-dimensional size (bounds) of a n-dimensional image.
Definition: itkSize.h:69
itk::PipelineMonitorImageFilter
Enables monitoring, recording and debugging of the pipeline execution and information exchange.
Definition: itkPipelineMonitorImageFilter.h:68
itk::RandomImageSource
Generate an n-dimensional image of random pixel values.
Definition: itkRandomImageSource.h:55
itk::Image
Templated n-dimensional image class.
Definition: itkImage.h:88
New
static Pointer New()
itk::StreamingImageFilter
Pipeline object to control data streaming for large data processing.
Definition: itkStreamingImageFilter.h:44