ThemisScanner extends AbstractClientScanner { protected static void setStartTsToScan(Scan scan, long startTs) { scan.setAttribute(ThemisScanObserver.TRANSACTION_START_TS, Bytes.toBytes(startTs)); } ThemisScanner(final byte[] tableName, final Scan scan, final Transaction transaction); static Get createGetFromScan(Scan scan, byte[] rowkey); Result next(); void close(); @Override Result[] next(int nbRows);  }
@Test public void testSetStartTsToScan() { Scan scan = new Scan(); Assert.assertNull(ThemisScanObserver.getStartTsFromAttribute(scan)); ThemisScanner.setStartTsToScan(scan, PREWRITE_TS); Long actual = ThemisScanObserver.getStartTsFromAttribute(scan); Assert.assertEquals(PREWRITE_TS, actual.longValue()); }