ServerLockCleaner { public Get createGetOfWriteColumnsIndexingPrewriteTs(ColumnCoordinate columnCoordinate, long timestamp) throws IOException { Get get = new Get(columnCoordinate.getRow()); ThemisCpUtil.addWriteColumnToGet(columnCoordinate, get); get.setTimeRange(timestamp, Long.MAX_VALUE); get.setMaxVersions(); return get; } ServerLockCleaner(HConnection conn, ThemisCoprocessorClient cpClient); static PrimaryLock getPrimaryLockWithColumn(ThemisLock lock); void cleanLock(ThemisLock lock); Pair<Long, PrimaryLock> cleanPrimaryLock(ColumnCoordinate columnCoordinate,
      long prewriteTs); Long getTimestampOfWriteIndexingPrewriteTs(ColumnCoordinate columnCoordinate, long timestamp); Get createGetOfWriteColumnsIndexingPrewriteTs(ColumnCoordinate columnCoordinate, long timestamp); void cleanSecondaryLocks(PrimaryLock primaryLock, Long commitTs); void eraseLockAndData(ColumnCoordinate column, long timestamp); void eraseLockAndData(byte[] tableName, byte[] row, Collection<Column> columns, long timestamp);  }
@Test public void testCreateGetOfWriteColumnsIndexingPrewriteTs() throws IOException { Get get = lockCleaner.createGetOfWriteColumnsIndexingPrewriteTs(COLUMN, prewriteTs); TestThemisCpUtil.checkReadWithWriteColumns(get.getFamilyMap(), COLUMN); Assert.assertEquals(prewriteTs, get.getTimeRange().getMin()); Assert.assertEquals(Long.MAX_VALUE, get.getTimeRange().getMax()); Assert.assertEquals(Integer.MAX_VALUE, get.getMaxVersions()); }