org.thales.punch.api

Class CheckPointBackendQuery

java.lang.Object

org.thales.punch.api.CheckPointBackendQuery

public class CheckPointBackendQuery
extends Object

Class that regroup QUERIES that be make by each BACKEND implementation of ICheckPointConsumer interface

Author:

jonathan

Method Summary

Modifier and Type	Method and Description
static String	clickhouseLastCommittedQuery(String applicationIdKey, String applicationIdValue)
static String	elasticsearchLastCommittedQuery(String applicationIdKeyDotKeyword, String applicationIdValue) Generate a query that will be used against an ELASTIC cluster to retrieve 1 document

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

elasticsearchLastCommittedQuery

public static String elasticsearchLastCommittedQuery(String applicationIdKeyDotKeyword,
                                                     String applicationIdValue)

Generate a query that will be used against an ELASTIC cluster to retrieve 1 document

Note it is expected that the field name is a keyword

Document returned will be in the form of: ElasticCheckpointPojo class

Parameters:

applicationIdKeyDotKeyword - an id key name that will be common for all instance of your application (i.e IKeys.PLANDOTRUNTIMEDOTIDDOTKEYWORD)

applicationIdValue - a unique id that will be used to identify your application

Returns:

a valid ELASTIC query in string type

clickhouseLastCommittedQuery

public static String clickhouseLastCommittedQuery(String applicationIdKey,
                                                  String applicationIdValue)