pm4py.streaming.stream package

Submodules

pm4py.streaming.stream.live_event_stream module

class pm4py.streaming.stream.live_event_stream.LiveEventStream(parameters=None)[source]

Bases: object

append(event)[source]
async deregister(algo)[source]
register(algo)[source]
start()[source]
property state
stop()[source]
class pm4py.streaming.stream.live_event_stream.Parameters(value)[source]

Bases: enum.Enum

An enumeration.

THREAD_POOL_SIZE = 'thread_pool_size'
class pm4py.streaming.stream.live_event_stream.StreamState(value)[source]

Bases: enum.Enum

An enumeration.

ACTIVE = 2
FINISHED = 3
INACTIVE = 1

pm4py.streaming.stream.live_trace_stream module

class pm4py.streaming.stream.live_trace_stream.LiveTraceStream(parameters=None)[source]

Bases: object

append(event)[source]
async deregister(algo)[source]
register(algo)[source]
start()[source]
property state
stop()[source]
class pm4py.streaming.stream.live_trace_stream.Parameters(value)[source]

Bases: enum.Enum

An enumeration.

THREAD_POOL_SIZE = 'thread_pool_size'
class pm4py.streaming.stream.live_trace_stream.StreamState(value)[source]

Bases: enum.Enum

An enumeration.

ACTIVE = 2
FINISHED = 3
INACTIVE = 1

Module contents