Pattern operator

This generic operator allows the definition of different kinds of pattern (e.g. all, any). For sequence based patterns see SASE operator (below). In the following the implemented pattern types are desribed.

Parameter

type: What kind of pattern should be detected. See below for all supported types and examples
eventTypes: Describes the types of the input ports
time: If there should be a temporal context (window) this states the time and
timeUnit is the unit of this time
size: For element based windows, this is the count of elements that are treated together, size and time can be used together
assertions: Predicate over the input data that must be fullfilled to create an output
outputmode: states, what the operator should deliver:
- EXPRESSION: use the return parameter to create the output
- INPUT: Deliver events from input port 0, can be changed with parameter inputPort
- TUPLE_CONTAINER: Deliver all events that are related to this matching
- SIMPLE
return: see outputmode/EXPRESSION
inputPort: see outputmode/INPUT

Logical

ALL

Beschreibung

Die Anfrage wählt zu einem Gebot, mit einemWert höher als 200, und zu der Person, die das Gebot abgegeben hat, die ID und den Namen der Person und den Preis des Gebots aus. Berücksichtigt werden nur Personen und Gebote, die nicht älter als 10 min sind. Zusammenfassend könnte man also sagen, dass die Anfrage die Personen auswählt, die innerhalb von 10 min nach ihrem Erscheinen bereits ein Gebot mit einem Wert über 200 abgeben.

Possible Parameter

assertions, time, timeUnit, size, outputMode, return, inputPort

Besonderheiten

time und size legen fest, wie lange bzw. wie viele Events zwischengespeichert werden

PATTERN({type = 'ALL', eventTypes = ['person', 'bid'],
time = 10, timeUnit = 'MINUTES',
assertions = ['person.id = bid.bidder && bid.price > 200'],
outputmode = 'EXPRESSIONS',
return = ['person.id', 'person.name', 'bid.price']},
person, bid)

ANY

Beschreibung

Die Anfrage wählt jedes Gebot mit einem Wert höher als 200 aus.

Mögliche Parameter

assertions, outputMode, return, inputPort

Besonderheiten

Die i-te Assertion gilt jeweils nur für Events des Typs, der an i-ter Stelle der relevanten Event-Typ-Liste steht.

PATTERN({type = 'ANY', eventTypes = ['bid'],
assertions = ['bid.price > 220'],
outputMode = 'INPUT'}, bid)

ABSENCE

Beschreibung

Die Anfrage erkennt, wenn 400 Millisekunden kein Gebot abgegeben wurde.

Mögliche Parameter

assertions, time, timeUnit, outputMode

Besonderheiten

Erfolg und Genauigkeit ist abhängig von den Heartbeats. Als Ausgabemodus ist nur SIMPLE möglich.

PATTERN({type = 'ABSENCE', eventTypes = ['bid'],
outputMode = 'SIMPLE', time = 400}, bid)

Threshold

COUNT

Beschreibung

Die Anfrage ist erfüllt, sobald mehr als 20 Gebote abgegeben wurden.

Mögliche Parameter

assertions, outputMode, return, inputPort

Besonderheiten

Beruht momentan auf dem Any-Pattern, das als Eingabe eine Aggregation von außen bekommt.

PATTERN({type = 'FUNCTOR', eventTypes = ['aggr'],
assertions = ['count_price > 20']},
AGGREGATE({aggregations = [['COUNT', 'price',
'count_price', 'double']]}, bid))

VALUE-MAX

Beschreibung

Die Anfrage ist erfüllt, sobald der maximale Wert eines Gebots 300 übersteigt.

Mögliche Parameter

assertions, outputMode, return, inputPort

Besonderheiten

Beruht momentan auf dem Any-Pattern, das als Eingabe eine Aggregation von außen bekommt.

PATTERN({type = 'FUNCTOR', eventTypes = ['bid'],
assertions = ['max_price > 300']},
AGGREGATE({aggregations=[['MAX', 'price', 'max_price',
'double']]}, bid))

VALUE-MIN

Beschreibung

Die Anfrage ist erfüllt, solange der minimale Wert eines Gebots größer als 50 und kleiner als 100 ist.

Mögliche Parameter

assertions, outputMode, return, inputPort

Besonderheiten

Beruht momentan auf dem Any-Pattern, das als Eingabe eine Aggregation von außen bekommt.

PATTERN({type = 'FUNCTOR', eventTypes = ['bid'],
assertions = ['min_price > 50 && min_price < 100']},
AGGREGATE({aggregations=[['MIN', 'price', 'min_price',
'double']]}, bid))

VALUE-AVERAGE

Beschreibung

Die Anfrage ist erfüllt, wenn das arithmetische Mittel eines Gebotes kleiner als 140 ist.

Mögliche Parameter

assertions, outputMode, return, inputPort

Besonderheiten

Beruht momentan auf dem Any-Pattern, das als Eingabe eine Aggregation von außen bekommt.

PATTERN({type = 'FUNCTOR', eventTypes = ['bid'],
assertions = ['avg_price < 140']},
AGGREGATE({aggregations=[['AVG', 'price', 'avg_price',
'double']]}, bid))

Subset Selection

RELATIVE-N-HIGHEST

Beschreibung

Die Anfrage wählt alle sechs Sekunden die drei höchsten Gebote aus.

Benötigte Parameter

attribute, count, time oder size

Mögliche Parameter

assertions, outputMode, return, inputPort, timeUnit

Besonderheiten

Der Ausgabemodus SIMPLE ist zwar möglich, macht aber nicht soviel Sinn.

PATTERN({type = 'RELATIVE_N_HIGHEST', eventTypes = ['bid'],
attribute = 'price', count = 3,
time = 6, timeUnit = 'SECONDS',
outputmode = 'expressions',
return = ['bid.timestamp', 'bid.bidder',
'bid.price']}, bid)

RELATIVE-N-LOWEST

Beschreibung

Die Anfrage wählt alle sechs Sekunden aus den Geboten, die höher als 80 sind, die drei niedrigsten Gebote aus.

Benötigte Parameter

attribute, count, time oder size

Mögliche Parameter

assertions, outputMode, return, inputPort, timeUnit

Besonderheiten

Der Ausgabemodus SIMPLE ist zwar möglich, macht aber in diesem Kontext normalerweise keinen Sinn.

PATTERN({type = 'RELATIVE_N_LOWEST', eventTypes = ['bid'],
assertions = ['price > 80'],
attribute = 'price', count = 3,
time = 10, timeUnit = 'SECONDS',
outputmode = 'TUPLE_CONTAINER'}, bid)

Modale

ALWAYS

Beschreibung

Wenn innerhalb dem festen Intervall von drei Sekunden alle Gebote größer als 140 sind, werden diese von dem Pattern ausgegeben.

Benötigte Parameter

time oder size

Mögliche Parameter

assertions, outputMode, return, inputPort, timeUnit

Besonderheiten

Ist der Ausgabemodus nicht SIMPLE, werden bei der Erfüllung des Patterns alle relevanten Events ausgegeben, die die Assertions erfüllen.

PATTERN({type = 'ALWAYS', eventTypes = ['bid'],
time = 3, timeUnit = 'SECONDS',
assertions = ['bid.price > 140'],
outputMode = 'INPUT'}, bid)

SOMETIMES

Beschreibung

Das Pattern ist erfüllt, wenn innerhalb dem festen Intervall von zehn Sekunden mindestens ein Gebot größer als 280 ist.

Benötigte Parameter

time oder size

Mögliche Parameter

assertions, outputMode, return, inputPort, timeUnit

Besonderheiten

Ist der Ausgabemodus nicht SIMPLE, werden bei der Erfüllung des Patterns alle relevanten Events ausgegeben, die die Assertions erfüllen.

PATTERN({type = 'SOMETIMES', eventTypes = ['bid'],
time = 10, timeUnit = 'SECONDS',
assertions = ['bid.price > 280']}, bid)

Temporal Order

SEQUENCE

Beschreibung

Die Anfrage wählt Attribute von Personen und den Geboten der jeweiligen Personen aus, bei denen die Person vor den Gebot auftritt und sein Gebot größer als 200 ist.

Besonderheiten

Die Anfrage basiert auf dem SASE-Operator. Der Parameter query erwartet eine Anfrage, die in der SASE-Anfragesprache formuliert ist. Vgl. SASE

SASE({query = 'PATTERN SEQ(person p, bid b)
WHERE skip_till_next_match(p,b)
{p.id = b.bidder, b.price > 200}
RETURN p.id, p.name, b.price', schema=[['id','Integer'],'name','String'], type='PersonEvent1'} , person, bid)

FIRST-N

Beschreibung

Die Anfrage wählt alle zehn Sekunden die ersten drei Gebote aus, die größer als 100 sind und gibt die angegebenen Attribute aus.

Benötigte Parameter

count, time oder size

Mögliche Parameter

assertions, outputMode, return, inputPort, timeUnit

Besonderheiten

Der Ausgabemodus SIMPLE ist zwar möglich, macht aber in diesem Kontext normalerweise keinen Sinn.

PATTERN({type = 'FIRST_N', eventTypes = ['bid'],
time = 10, timeUnit = 'SECONDS',
count = 3,
assertions = ['bid.price > 100'],
outputmode = 'EXPRESSIONS',
return = ['bid.timestamp', 'bid.bidder',
'bid.price']}, bid)

LAST-N

Beschreibung

Die Anfrage wählt alle zehn Sekunden die letzten drei relevanten Events aus. Dies können Gebote und Auktionen sein.

Benötigte Parameter

count, time oder size

Mögliche Parameter

assertions, outputMode, return, inputPort, timeUnit

Besonderheiten

Der Ausgabemodus SIMPLE ist zwar möglich, macht aber in diesem Kontext normalerweise keinen Sinn. Beinhaltet die Ausgabe verschiedene Event-Typen macht der Ausgabemodus TUPLE_CONTAINER Sinn, da bei dort das Schema der Daten keine Rolle spielt. Bei anderen Ausgabemodi entstehen unter Umständen null-Werte oder ähnliches.

PATTERN({type = 'LAST_N', eventTypes = ['person',
'auction'],
time = 10, timeUnit = 'SECONDS',
count = 3,
outputmode = 'TUPLE_CONTAINER'}, auction, person)

Trend

INCREASING

Beschreibung

Das Pattern ist erfüllt, wenn die Werte der Gebote innerhalb des festen Zeitintervalls von 2 Sekunden streng monoton steigen.

Benötigte Parameter

attribute, time oder size

Mögliche Parameter

assertions, outputMode, return, inputPort, timeUnit

Besonderheiten

Ist der Ausgabemodus nicht SIMPLE, werden bei der Erfüllung des Patterns alle relevanten Events ausgegeben, die die Assertions erfüllen.

PATTERN({type = 'INCREASING', eventTypes = ['bid'],
attribute = 'price',
time = 2, timeUnit = 'SECONDS'}, bid)

DECREASING

Beschreibung

Das Pattern ist erfüllt, wenn die Werte der Gebote innerhalb des festen Zeitintervalls von 2 Sekunden streng monoton fallen.

Benötigte Parameter

attribute, time oder size

Mögliche Parameter

assertions, outputMode, return, inputPort, timeUnit

Besonderheiten

Ist der Ausgabemodus nicht SIMPLE, werden bei der Erfüllung des Patterns alle relevanten Events ausgegeben, die die Assertions erfüllen.

PATTERN({type = 'DECREASING', eventTypes = ['bid'],
attribute = 'price',
time = 2, timeUnit = 'SECONDS'}, bid)

STABLE

Beschreibung

Das Pattern ist erfüllt, wenn sich die Werte der Gebote innerhalb des festen Zeitintervalls von 2 Sekunden nicht ändern.

Benötigte Parameter

attribute, time oder size

Mögliche Parameter

assertions, outputMode, return, inputPort, timeUnit

Besonderheiten

Ist der Ausgabemodus nicht SIMPLE, werden bei der Erfüllung des Patterns alle relevanten Events ausgegeben, die die Assertions erfüllen.

PATTERN({type = 'STABLE', eventTypes = ['bid'],
attribute = 'price',
time = 2, timeUnit = 'SECONDS'}, bid)

NON-INCREASING

Beschreibung

Das Pattern ist erfüllt, wenn die Werte der Gebote innerhalb des festen Zeitintervalls von 2 Sekunden monoton fallen.

Benötigte Parameter

attribute, time oder size

Mögliche Parameter

assertions, outputMode, return, inputPort, timeUnit

Besonderheiten

Ist der Ausgabemodus nicht SIMPLE, werden bei der Erfüllung des Patterns alle relevanten Events ausgegeben, die die Assertions erfüllen.

PATTERN({type = 'NON_INCREASING', eventTypes = ['bid'],
attribute = 'price',
time = 2, timeUnit = 'SECONDS'}, bid)

NON-DECREASING

Beschreibung

Das Pattern ist erfüllt, wenn die Werte der Gebote innerhalb des festen Zeitintervalls von 2 Sekunden monoton steigen.

Benötigte Parameter

attribute, time oder size

Mögliche Parameter

assertions, outputMode, return, inputPort, timeUnit

Besonderheiten

Ist der Ausgabemodus nicht SIMPLE, werden bei der Erfüllung des Patterns alle relevanten Events ausgegeben, die die Assertions erfüllen.

PATTERN({type = 'NON_DECREASING', eventTypes = ['bid'],
attribute = 'price',
time = 2, timeUnit = 'SECONDS'}, bid)

NON-STABLE

Beschreibung

Das Pattern ist das Gegenstück zum Stable-Pattern. Es ist erfüllt, wenn sich die Werte von drei aufeinanderfolgenden Gebote ändern.

Benötigte Parameter

attribute, time oder size

Mögliche Parameter

assertions, outputMode, return, inputPort, timeUnit

Besonderheiten

Ist der Ausgabemodus nicht SIMPLE, werden bei der Erfüllung des Patterns alle relevanten Events ausgegeben, die die Assertions erfüllen.

PATTERN({type = 'NON_STABLE', eventTypes = ['bid'],
attribute = 'price', size = 3}, bid)

MIXED

Beschreibung

Das Pattern ist erfüllt, wenn die Werte der Gebote innerhalb des festen Zeitintervalls von 2 Sekunden mindestens einmal streng monoton steigen und mindestens einmal streng monoton fallen.

Benötigte Parameter

attribute, time oder size

Mögliche Parameter

assertions, outputMode, return, inputPort, timeUnit

Besonderheiten

Ist der Ausgabemodus nicht SIMPLE, werden bei der Erfüllung des Patterns alle relevanten Events ausgegeben, die die Assertions erfüllen.

PATTERN({type = 'MIXED', eventTypes = ['bid'],
attribute = 'price',
time = 2, timeUnit = 'SECONDS'}, bid)

Space shortcuts

Page tree

Pattern operator

Parameter

Logical

ALL

Beschreibung

Possible Parameter

Besonderheiten

ANY

Beschreibung

Mögliche Parameter

Besonderheiten

ABSENCE

Beschreibung

Mögliche Parameter

Besonderheiten

Threshold

COUNT

Beschreibung

Mögliche Parameter

Besonderheiten

VALUE-MAX

Beschreibung

Mögliche Parameter

Besonderheiten

VALUE-MIN

Beschreibung

Mögliche Parameter

Besonderheiten

VALUE-AVERAGE

Beschreibung

Mögliche Parameter

Besonderheiten

Subset Selection

RELATIVE-N-HIGHEST

Beschreibung

Benötigte Parameter

Mögliche Parameter

Besonderheiten

RELATIVE-N-LOWEST

Beschreibung

Benötigte Parameter

Mögliche Parameter

Besonderheiten

Modale

ALWAYS

Beschreibung

Benötigte Parameter

Mögliche Parameter

Besonderheiten

SOMETIMES

Beschreibung

Benötigte Parameter

Mögliche Parameter

Besonderheiten

Temporal Order

SEQUENCE

Beschreibung

Besonderheiten

FIRST-N

Beschreibung

Benötigte Parameter

Mögliche Parameter

Besonderheiten

LAST-N

Beschreibung

Benötigte Parameter

Mögliche Parameter

Besonderheiten

Trend

INCREASING

Beschreibung

Benötigte Parameter

Mögliche Parameter

Besonderheiten

DECREASING

Beschreibung

Benötigte Parameter

Mögliche Parameter