@@ -64,22 +64,12 @@ public final void execute(ExecutionParameters parameters) {
64
64
pollingValue = cts ;
65
65
}
66
66
67
- if (snapshot .containsKey (PROPERTY_SKIP_NUMBER )) {
68
- skipNumber = snapshot .getInt (PROPERTY_SKIP_NUMBER );
69
- }
70
-
71
- if (snapshot .containsKey (PROPERTY_TABLE_NAME ) && snapshot .get (PROPERTY_TABLE_NAME ) != null
72
- && !snapshot .getString (PROPERTY_TABLE_NAME )
73
- .equals (tableName )) {
74
- skipNumber = 0 ;
75
- }
76
-
77
67
LOGGER .info ("Executing row polling trigger" );
78
68
try {
79
69
connection = Utils .getConnection (configuration );
80
70
QueryFactory queryFactory = new QueryFactory ();
81
71
Query query = queryFactory .getQuery (dbEngine );
82
- query .from (tableName ).skip ( skipNumber ). orderBy (pollingField )
72
+ query .from (tableName ).orderBy (pollingField )
83
73
.rowsPolling (pollingField , pollingValue );
84
74
query .setMaxPollingValue (cts );
85
75
ArrayList <JsonObject > resultList = query .executePolling (connection );
@@ -94,7 +84,6 @@ public final void execute(ExecutionParameters parameters) {
94
84
formattedDate = new SimpleDateFormat (PROPERTY_DATETIME_FORMAT )
95
85
.format (query .getMaxPollingValue ());
96
86
snapshot = Json .createObjectBuilder ()
97
- .add (PROPERTY_SKIP_NUMBER , skipNumber + resultList .size ())
98
87
.add (PROPERTY_TABLE_NAME , tableName )
99
88
.add (PROPERTY_POLLING_FIELD , pollingField )
100
89
.add (PROPERTY_POLLING_VALUE , formattedDate ).build ();
0 commit comments