videoflow.processors package

Submodules

videoflow.processors.aggregators module

class videoflow.processors.aggregators.CountAggregator

Bases: videoflow.core.node.OneTaskProcessorNode

Keeps count of all the items processed

process(inp)
  • Arguments:

    • inp: a number

  • Returns:

    • count: the cumulative count up to this point

class videoflow.processors.aggregators.MaxAggregator

Bases: videoflow.core.node.OneTaskProcessorNode

process(inp)
  • Arguments:

    • inp: a number

  • Returns:

    • max: the maximum seen value up to this point

class videoflow.processors.aggregators.MinAggregator

Bases: videoflow.core.node.OneTaskProcessorNode

process(inp)
  • Arguments:

    • inp: a number

  • Returns:

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

class videoflow.processors.aggregators.MultiplicationAggregator

Bases: videoflow.core.node.OneTaskProcessorNode

Keeps a running multiplication of all the inputs processed

process(inp)
  • Arguments:

    • inp: a number

  • Returns:

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

class videoflow.processors.aggregators.SumAggregator

Bases: videoflow.core.node.OneTaskProcessorNode

Keeps a running sum of all the inputs processed

process(inp)
  • 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=-1, *args, **kargs)

Bases: videoflow.core.node.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)

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=-1, *args, **kargs)

Bases: videoflow.core.node.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)

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.