| /rocksdb-6.9/java/src/test/java/org/rocksdb/util/ |
| D | WriteBatchGetter.java | 11 private int columnFamilyId = -1; field in WriteBatchGetter
24 public void put(final int columnFamilyId, final byte[] key, in put() argument
27 this.columnFamilyId = columnFamilyId; in put()
40 public void merge(final int columnFamilyId, final byte[] key, in merge() argument
43 this.columnFamilyId = columnFamilyId; in merge()
56 public void delete(final int columnFamilyId, final byte[] key) { in delete() argument
58 this.columnFamilyId = columnFamilyId; in delete()
71 public void singleDelete(final int columnFamilyId, final byte[] key) { in singleDelete() argument
73 this.columnFamilyId = columnFamilyId; in singleDelete()
102 public void putBlobIndex(final int columnFamilyId, final byte[] key, in putBlobIndex() argument
[all …]
|
| D | CapturingWriteBatchHandler.java | 30 public void put(final int columnFamilyId, final byte[] key, in put() argument
32 events.add(new Event(Action.PUT, columnFamilyId, key, value)); in put()
41 public void merge(final int columnFamilyId, final byte[] key, in merge() argument
43 events.add(new Event(Action.MERGE, columnFamilyId, key, value)); in merge()
52 public void delete(final int columnFamilyId, final byte[] key) { in delete() argument
64 columnFamilyId, key, (byte[])null)); in singleDelete()
90 public void putBlobIndex(final int columnFamilyId, final byte[] key, in putBlobIndex() argument
124 public final int columnFamilyId; field in CapturingWriteBatchHandler.Event
135 this.columnFamilyId = columnFamilyId; in Event()
149 return columnFamilyId == event.columnFamilyId && in equals()
[all …]
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | TransactionDB.java | 293 final long transactionID, final long columnFamilyId, in newDeadlockInfo() argument
295 return new DeadlockInfo(transactionID, columnFamilyId, in newDeadlockInfo()
301 private final long columnFamilyId; field in TransactionDB.DeadlockInfo
305 private DeadlockInfo(final long transactionID, final long columnFamilyId, in DeadlockInfo() argument
308 this.columnFamilyId = columnFamilyId; in DeadlockInfo()
328 return columnFamilyId; in getColumnFamilyId()
|
| D | WriteBatch.java | 296 public abstract void put(final int columnFamilyId, final byte[] key, in put() argument
299 public abstract void merge(final int columnFamilyId, final byte[] key, in merge() argument
302 public abstract void delete(final int columnFamilyId, final byte[] key) in delete() argument
305 public abstract void singleDelete(final int columnFamilyId, in singleDelete() argument
308 public abstract void deleteRange(final int columnFamilyId, in deleteRange() argument
313 public abstract void putBlobIndex(final int columnFamilyId, in putBlobIndex() argument
|
| D | TableProperties.java | 27 private final long columnFamilyId; field in TableProperties
52 final long columnFamilyId, final long creationTime, in TableProperties() argument
76 this.columnFamilyId = columnFamilyId; in TableProperties()
248 return columnFamilyId; in getColumnFamilyId()
|
| D | Transaction.java | 1839 final long columnFamilyId, final String key, in newWaitingTransactions() argument
1841 return new WaitingTransactions(columnFamilyId, key, transactionIds); in newWaitingTransactions()
1845 private final long columnFamilyId; field in Transaction.WaitingTransactions
1849 private WaitingTransactions(final long columnFamilyId, final String key, in WaitingTransactions() argument
1851 this.columnFamilyId = columnFamilyId; in WaitingTransactions()
1862 return columnFamilyId; in getColumnFamilyId()
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | TransactionDBTest.java | 146 final long columnFamilyId = entry.getKey(); in lockStatusData() local
147 assertThat(columnFamilyId).isEqualTo(0); in lockStatusData()
|