Home
last modified time | relevance | path

Searched refs:Event (Results 1 – 3 of 3) sorted by relevance

/rocksdb-6.9/java/src/test/java/org/rocksdb/util/
DCapturingWriteBatchHandler.java18 private final List<Event> events = new ArrayList<>();
25 public List<Event> getEvents() { in getEvents()
32 events.add(new Event(Action.PUT, columnFamilyId, key, value)); in put()
37 events.add(new Event(Action.PUT, key, value)); in put()
48 events.add(new Event(Action.MERGE, key, value)); in merge()
58 events.add(new Event(Action.DELETE, key, (byte[])null)); in delete()
63 events.add(new Event(Action.SINGLE_DELETE, in singleDelete()
86 events.add(new Event(Action.LOG, (byte[])null, blob)); in logData()
92 events.add(new Event(Action.PUT_BLOB_INDEX, key, value)); in putBlobIndex()
122 public static class Event { class in CapturingWriteBatchHandler
[all …]
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DWriteBatchHandlerTest.java14 import org.rocksdb.util.CapturingWriteBatchHandler.Event;
28 final List<Event> testEvents = Arrays.asList( in writeBatchHandler()
29 new Event(DELETE, "k0".getBytes(), null), in writeBatchHandler()
30 new Event(PUT, "k1".getBytes(), "v1".getBytes()), in writeBatchHandler()
31 new Event(PUT, "k2".getBytes(), "v2".getBytes()), in writeBatchHandler()
32 new Event(PUT, "k3".getBytes(), "v3".getBytes()), in writeBatchHandler()
33 new Event(LOG, null, "log1".getBytes()), in writeBatchHandler()
34 new Event(MERGE, "k2".getBytes(), "v22".getBytes()), in writeBatchHandler()
35 new Event(DELETE, "k3".getBytes(), null) in writeBatchHandler()
40 for (final Event testEvent : testEvents) { in writeBatchHandler()
[all …]
DWriteBatchTest.java27 import org.rocksdb.util.CapturingWriteBatchHandler.Event;
76 assertThat(handler.getEvents().get(0)).isEqualTo(new Event(PUT, foo, bar)); in multipleBatchOperations()
77 assertThat(handler.getEvents().get(1)).isEqualTo(new Event(DELETE, box, null)); in multipleBatchOperations()
78 assertThat(handler.getEvents().get(2)).isEqualTo(new Event(PUT, baz, boo)); in multipleBatchOperations()
79 assertThat(handler.getEvents().get(3)).isEqualTo(new Event(MERGE, baz, hoo)); in multipleBatchOperations()
80 assertThat(handler.getEvents().get(4)).isEqualTo(new Event(SINGLE_DELETE, foo, null)); in multipleBatchOperations()
81 assertThat(handler.getEvents().get(5)).isEqualTo(new Event(DELETE_RANGE, baz, foo)); in multipleBatchOperations()
82 assertThat(handler.getEvents().get(6)).isEqualTo(new Event(LOG, null, hello)); in multipleBatchOperations()
261 …assertThat(handler.getEvents().get(0)).isEqualTo(new Event(PUT, "k1".getBytes(), "v1".getBytes())); in restorePoints()
262 …assertThat(handler.getEvents().get(1)).isEqualTo(new Event(PUT, "k2".getBytes(), "v2".getBytes())); in restorePoints()
[all …]