videoflow.processors package

Subpackages

• videoflow.processors.vision package
  • Submodules
  • videoflow.processors.vision.annotators module
    • BoundingBoxAnnotator
      • BoundingBoxAnnotator.supported_datasets
    • ImageAnnotator
      • ImageAnnotator.process()
    • SegmenterAnnotator
      • SegmenterAnnotator.colors
      • SegmenterAnnotator.supported_datasets
    • TrackerAnnotator
  • videoflow.processors.vision.counters module
  • videoflow.processors.vision.detectors module
    • ObjectDetector
      • ObjectDetector.process()
  • videoflow.processors.vision.pose module
  • videoflow.processors.vision.segmentation module
    • Segmenter
      • Segmenter.process()
  • videoflow.processors.vision.trackers module
    • BoundingBoxTracker
      • BoundingBoxTracker.process()
  • videoflow.processors.vision.transformers module
    • CropImageTransformer
      • CropImageTransformer.process()
    • MaskImageTransformer
      • MaskImageTransformer.process()
    • ResizeImageTransformer
      • ResizeImageTransformer.process()

Submodules

videoflow.processors.aggregators module

class videoflow.processors.aggregators.CountAggregator(**kwargs)

Bases: OneTaskProcessorNode

Keeps count of all the items processed

process(inp: Any) → Any

• Arguments:

  • inp: a number

• Returns:

  • count: the cumulative count up to this point

class videoflow.processors.aggregators.MaxAggregator(**kwargs)

Bases: OneTaskProcessorNode

process(inp: Any) → Any

• Arguments:

  • inp: a number

• Returns:

  • max: the maximum seen value up to this point

class videoflow.processors.aggregators.MinAggregator(**kwargs)

Bases: OneTaskProcessorNode

process(inp: Any) → Any

• Arguments:

  • inp: a number

• Returns:

  • min: the the minimum seen value up to this point

class videoflow.processors.aggregators.MultiplicationAggregator(**kwargs)

Bases: OneTaskProcessorNode

Keeps a running multiplication of all the inputs processed

process(inp: Any) → Any

• Arguments:

  • inp: a number

• Returns:

  • mult: the cumulative multiplication up to this point, including inp in it.

class videoflow.processors.aggregators.SumAggregator(**kwargs)

Bases: OneTaskProcessorNode

Keeps a running sum of all the inputs processed

process(inp: Any) → Any

• Arguments:

  • inp: a number

• Returns:

  • sum: the cumulative sum up to this point, including inp in it.

videoflow.processors.basic module

class videoflow.processors.basic.IdentityProcessor(fps: float = -1, **kwargs)

Bases: ProcessorNode

IdentityProcessor implements the identity function: it returns the same value that it received as input. You can introduce some delay by setting fps to a value greater than 0.

• Arguments:

  • fps (int): frames per second. If value is less than or equal to zero, it is ignored, and no delay is introduced.

process(inp: Any) → Any

Method definition that needs to be implemented by subclasses.

• Arguments:

  • inp: object or list of objects being received for processing from parent nodes.

• Returns:

  • the output being consumed by child nodes.

class videoflow.processors.basic.JoinerProcessor(fps: float = -1, **kwargs)

Bases: ProcessorNode

Takes all the parameters received in the process method and makes them a tuple of items.

• Arguments:

  • fps (int): frames per second. If value is less than or equal to zero, it is ignored, and no delay is introduced.

process(*inp: Any) → Any

Method definition that needs to be implemented by subclasses.

• Arguments:

  • inp: object or list of objects being received for processing from parent nodes.

• Returns:

  • the output being consumed by child nodes.