Package com.persequor.event

Interface IElasticEventsQuery<T extends IElasticEventsQuery<T>>

All Superinterfaces:

IEventsQuery<T>, IRepositoryEventsQuery<T>

public interface IElasticEventsQuery<T extends IElasticEventsQuery<T>>
extends IRepositoryEventsQuery<T>

Method Summary

Modifier and Type	Method	Description
T	advancedFreeTextSearch(String query)	Deprecated. We started to support operating modes where ElasticSearch is not present, but custom indexing is still functional.
T	anyFreeTextSearch(List<String> query)	Filter this query with a free text search query using OR operator See: https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-simple-query-string-query.html
T	byCustomMatching(String field, Long value)
T	byCustomMatching(String field, String value)
T	byCustomMatching(String field, ZonedDateTime value)
T	byEventTime(ZonedDateTime eventTimeFrom, ZonedDateTime eventTimeTo)	Keep only events with event time greater or equal to eventTimeFrom and strictly less than eventTimeTo: eventTimeFrom <= event time < eventTimeTo
T	byGeCustom(String field, Long value)
T	byGeCustom(String field, ZonedDateTime value)
T	byGeEventTime(ZonedDateTime eventTime)	Keep only events with event time greater or equal to eventTime
T	byGeRecordTime(ZonedDateTime recordTime)	Keep only events with record time greater or equal to recordTime
T	byGtCustom(String field, Long value)
T	byGtCustom(String field, ZonedDateTime value)
T	byIndexHashes(Set<String> indexHash)	Keep only events based on indexHash
T	byLeCustom(String field, Long value)
T	byLeCustom(String field, ZonedDateTime value)
T	byLtCustom(String field, Long value)
T	byLtCustom(String field, ZonedDateTime value)
T	byLtEventTime(ZonedDateTime eventTime)	Keep only events with event time strictly less than eventTimeTo
T	byLtRecordTime(ZonedDateTime recordTime)	Keep only events with record time strictly less than recordTime
T	byRecordTime(ZonedDateTime recordTimeFrom, ZonedDateTime recordTimeTo)	Keep only events with record time greater or equal to recordTimeFrom and strictly less than recordTimeTo: recordTimeFrom <= record time < recordTimeTo
T	filterRevertedEvents(boolean enableFilter)	Explicitly set the filter option for reverted events, to override the default set in the saga configuration
T	freeTextSearch(String query)	Filter this query with a free text search query See: https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-simple-query-string-query.html
T	freeTextSearch(List<String> query)	Filter this query with a free text search query using AND operator See: https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-simple-query-string-query.html

Methods inherited from interface com.persequor.event.IEventsQuery

byAction, byAction, byBizLocation, byBizLocation, byBizStep, byBizStep, byBizTransaction, byBizTransaction, byDestination, byDestination, byDisposition, byDisposition, byEpcisEventId, byEpcisEventId, byEventType, byEventType, byMatchAnyEPC, byMatchAnyEPC, byMatchAnyEpcClass, byMatchAnyEpcClass, byMatchBizTransaction, byMatchBizTransaction, byMatchEpc, byMatchEpc, byMatchEpcClass, byMatchEpcClass, byMatchParentID, byMatchParentID, byReadPoint, bySagaEventId, bySagaEventId, bySagaEventIdentifiers, bySource, bySource, withLimit, withOffset

Methods inherited from interface com.persequor.event.IRepositoryEventsQuery

execute, executeSingle, orderBy, withEpcExpansion

Method Details

byRecordTime

T byRecordTime(ZonedDateTime recordTimeFrom,
 ZonedDateTime recordTimeTo)

Keep only events with record time greater or equal to recordTimeFrom and strictly less than recordTimeTo: recordTimeFrom <= record time < recordTimeTo

Specified by:

byRecordTime in interface IEventsQuery<T extends IElasticEventsQuery<T>>

Parameters:

recordTimeFrom - lower inclusive bound of record time

recordTimeTo - upper exclusive bound of record time

Returns:

this query instance

byGeRecordTime

T byGeRecordTime(ZonedDateTime recordTime)

Keep only events with record time greater or equal to recordTime

Specified by:

byGeRecordTime in interface IEventsQuery<T extends IElasticEventsQuery<T>>

Parameters:

recordTime - lower inclusive bound of record time

Returns:

this query instance

byLtRecordTime

T byLtRecordTime(ZonedDateTime recordTime)

Keep only events with record time strictly less than recordTime

Specified by:

byLtRecordTime in interface IEventsQuery<T extends IElasticEventsQuery<T>>

Parameters:

recordTime - upper exclusive bound of record time

Returns:

this query instance

byEventTime

T byEventTime(ZonedDateTime eventTimeFrom,
 ZonedDateTime eventTimeTo)

Keep only events with event time greater or equal to eventTimeFrom and strictly less than eventTimeTo: eventTimeFrom <= event time < eventTimeTo

Specified by:

byEventTime in interface IEventsQuery<T extends IElasticEventsQuery<T>>

Parameters:

eventTimeFrom - lower inclusive bound of event time

eventTimeTo - upper exclusive bound of event time

Returns:

this query instance

byGeEventTime

T byGeEventTime(ZonedDateTime eventTime)

Keep only events with event time greater or equal to eventTime

Specified by:

byGeEventTime in interface IEventsQuery<T extends IElasticEventsQuery<T>>

Parameters:

eventTime - lower inclusive bound of event time

Returns:

this query instance

byLtEventTime

T byLtEventTime(ZonedDateTime eventTime)

Keep only events with event time strictly less than eventTimeTo

Specified by:

byLtEventTime in interface IEventsQuery<T extends IElasticEventsQuery<T>>

Parameters:

eventTime - upper exclusive bound of event time

Returns:

this query instance

filterRevertedEvents

T filterRevertedEvents(boolean enableFilter)

Explicitly set the filter option for reverted events, to override the default set in the saga configuration

Specified by:

filterRevertedEvents in interface IEventsQuery<T extends IElasticEventsQuery<T>>

Parameters:

enableFilter - sets whether or not to filter reverted events from the query result

Returns:

this query instance

freeTextSearch

T freeTextSearch(List<String> query)

Filter this query with a free text search query using AND operator See: https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-simple-query-string-query.html

Parameters:

query - ElasticSearch full text "simple query strings"

Returns:

this query instance

freeTextSearch

T freeTextSearch(String query)

Filter this query with a free text search query See: https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-simple-query-string-query.html

Parameters:

query - ElasticSearch full text "simple query strings"

Returns:

this query instance

anyFreeTextSearch

T anyFreeTextSearch(List<String> query)

Filter this query with a free text search query using OR operator See: https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-simple-query-string-query.html

Parameters:

query - ElasticSearch full text "simple query strings"

Returns:

this query instance

advancedFreeTextSearch

@Deprecated
T advancedFreeTextSearch(String query)

Deprecated.

We started to support operating modes where ElasticSearch is not present, but custom indexing is still functional. In those modes supporting full syntax of ElasticSearch query language doesn't make sense. For stable cross-mode functionality a new SDK will be introduced. Until then use this method with caution, because you can potentially produce code not compatible between different Saga operating modes.

Filter this query with an advanced free text search query See: https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-query-string-query.html

Parameters:

query - ElasticSearch full text "query string"

Returns:

this query instance

byIndexHashes

T byIndexHashes(Set<String> indexHash)

Keep only events based on indexHash

Parameters:

indexHash - the collection of accepted index hashes

Returns:

this query instance

byCustomMatching

T byCustomMatching(String field,
 String value)

Parameters:

field -

value -

Returns:

byCustomMatching

T byCustomMatching(String field,
 Long value)

Parameters:

field -

value -

Returns:

byCustomMatching

T byCustomMatching(String field,
 ZonedDateTime value)

Parameters:

field -

value -

Returns:

byGtCustom

T byGtCustom(String field,
 Long value)

Parameters:

field -

value -

Returns:

byGeCustom

T byGeCustom(String field,
 Long value)

Parameters:

field -

value -

Returns:

byGtCustom

T byGtCustom(String field,
 ZonedDateTime value)

Parameters:

field -

value -

Returns:

byGeCustom

T byGeCustom(String field,
 ZonedDateTime value)

Parameters:

field -

value -

Returns:

byLtCustom

T byLtCustom(String field,
 Long value)

Parameters:

field -

value -

Returns:

byLeCustom

T byLeCustom(String field,
 Long value)

Parameters:

field -

value -

Returns:

byLtCustom

T byLtCustom(String field,
 ZonedDateTime value)

Parameters:

field -

value -

Returns:

byLeCustom

T byLeCustom(String field,
 ZonedDateTime value)

Parameters:

field -

value -

Returns: