@FunctionalInterface public interface ReadEventDataWithGapsStatementBuilder
JdbcEventStorageEngine.fetchTrackedEvents(TrackingToken,
int)
Modifier and Type | Method and Description |
---|---|
PreparedStatement |
build(Connection connection,
EventSchema schema,
long globalIndex,
int batchSize,
List<Long> gaps)
Creates a statement to be used at
JdbcEventStorageEngine.fetchTrackedEvents(TrackingToken, int) |
PreparedStatement build(Connection connection, EventSchema schema, long globalIndex, int batchSize, List<Long> gaps) throws SQLException
JdbcEventStorageEngine.fetchTrackedEvents(TrackingToken, int)
connection
- The connection to the database.schema
- The EventSchema to be usedglobalIndex
- The index taken from the tracking token.batchSize
- The number of items to include in the batchgaps
- The Set of gaps taken from the tracking token.PreparedStatement
.SQLException
- when an exception occurs while creating the prepared statement.JdbcEventStorageEngine.readEventData(Connection, TrackingToken, int)
Copyright © 2010–2022. All rights reserved.