Funkcje agregujące dla spraw

Funkcje agregujące wartości ze wszystkich zdarzeń w tej samej sprawie.

Jak działają agregacje dla spraw

W process mining sprawa oznacza pojedynczą instancję procesu, na przykład zamówienie, zgłoszenie lub ścieżkę klienta. Każda sprawa składa się z wielu zdarzeń, czyli poszczególnych kroków lub działań.

Funkcje agregujące dla spraw obliczają wartości na podstawie wszystkich zdarzeń w danej sprawie i udostępniają wynik przy każdym zdarzeniu. Dzięki temu można:

• Obliczać łączne wartości dla sprawy, np. całkowitą kwotę zamówienia
• Wykrywać wzorce w sprawach, np. liczbę zdarzeń związanych z poprawkami
• Porównywać poszczególne zdarzenia ze statystykami dla całej sprawy

Typowe zastosowania

• Obliczanie sum dla sprawy:

  caseSum(ItemAmount)           // Total order value
  caseCount()                   // Number of events in case
  caseCountDistinct(Resource)   // Unique resources involved

• Wyszukiwanie wartości skrajnych:

  caseMin(Timestamp)            // First event time
  caseMax(Timestamp)            // Last event time
  caseMax(Timestamp) - caseMin(Timestamp)   // Total case duration

• Agregacje warunkowe:

  caseCountIf(Status == "Error")            // Error count
  caseSumIf(Amount, Activity == "Payment")  // Total payments
  caseAvgIf(Duration, Activity == "Review") // Avg review time

• Porównywanie zdarzenia z całą sprawą:

  Duration / caseAvg(Duration)  // Is this event faster/slower than average?

Agregacje narastające

Agregacje narastające obliczają wartości skumulowane do bieżącego zdarzenia włącznie. W miarę przechodzenia chronologicznie przez zdarzenia w sprawie wartość narastająca jest aktualizowana.

Przydaje się to do:

• Śledzenia sum narastających
• Określania pozycji zdarzenia w sekwencji
• Obliczania średnich kroczących

Przykłady agregacji narastających

• Sumy narastające: śledzenie zmian wartości w kolejnych etapach sprawy:

  caseRunningSum(ItemAmount)   // Cumulative order total at each event

  Zdarzenie	Kwota	caseRunningSum(Amount)
  1	100	100
  2	50	150
  3	75	225

• Pozycja zdarzenia: określanie miejsca zdarzenia w sekwencji sprawy:

  caseRunningCount()   // 1, 2, 3, 4...

• Średnia krocząca: obliczanie średniej do bieżącego punktu:

  caseRunningAvg(Duration)   // Average duration so far

• Logika zależna od pozycji:

  if(caseRunningCount() == 1, "First", 
     if(caseRunningCount() == caseCount(), "Last", "Middle")
  )

Funkcje statystyczne

Funkcje statystyczne służą do analizy rozkładu wartości w obrębie sprawy.

• Percentyle: określają położenie wartości względem pozostałych wartości w sprawie. Percentyl należy podać jako ułamek z zakresu od 0 do 1, więc 0.9 oznacza 90. percentyl:

  casePercentile(Duration, 0.5)   // Median duration in this case
  casePercentile(Duration, 0.9)   // 90th percentile

• Wariancja: określa rozproszenie wartości:

  caseVariance(Amount)           // Variation within this case

Powiązane tematy

• Przegląd wyrażeń: wszystkie funkcje języka wyrażeń.