Skip to content

Logpickr components

Logpickr Sink

A Sink connector transfers data from Kafka to another system (in our case Logpickr public API).

The connector retrieves AVRO formatted data from a Kafka topic and forwards them to Logpickr API.

The data type is known via Kafka Registry and is mapped to Logpickr project Column Mapping. Data is aggregated to the project and displayed by Process Explorer 360.

The connector can also create a new Column Mapping for the projet, if none exists on a new project for example.

More details

Logpickr Aggregator

This connector aims to aggregate together multiple records coming from a same partition.

It allows decoupling the continuous flow of kafka topics into point-in-time emission of an aggregation of data, according to various user policies.

For instance, if the incoming data is composed of two columns having for types :

LINE1 VARCHAR, LINE2 VARCHAR

The result of the aggregation will be sent to a kafka topic with the type :

LINEAG ARRAY<STRUCT<LINE1 VARCHAR, LINE2 VARCHAR>>

More details

User Defined Functions (UDF)

UDF are functions useable in KSQLDB transformations.

Transposition

name in ksqlDB : logpickr_transposition

UDTF transposing a line which contains multiple column dates associated to activities, into multiple lines with one date (or period) linked to its activity

More details

Case Events

name in ksqlDB : logpickr_case_events

UDF allowing to obtain caseId related information

More details

Sessions (Task Mining)

name in ksqlDB : logpickr_sessions

UDTF distributing a collection of lines into different sessions.

Used in Task Mining, it generates a caseId based on user specifications.

More details

Prediction

name in ksqlDB : logpickr_prediction

UDF allowing retrieving prediction information on given caseIds belonging to a Logpickr project

More details