pulsar.functions.function.Function

Modules Classes Names

Class Function

Methods

process

Module function

Classes

Function

class documentation

class Function(object): (source)

View In Hierarchy

Interface for Pulsar Function

Method process Process input message

@abstractmethod
def process(self, input, context): (source) ¶

Process input message