/dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/clusterj/clusterj-tie/src/main/java/com/mysql/clusterj/tie/ |
H A D | ClusterConnectionImpl.java | 83 …private ConcurrentMap<String, NdbRecordImpl> ndbRecordImplMap = new ConcurrentHashMap<String, NdbR… 218 for (NdbRecordImpl ndbRecord: ndbRecordImplMap.values()) { in close() 254 protected NdbRecordImpl getCachedNdbRecordImpl(Table storeTable) { in getCachedNdbRecordImpl() 258 NdbRecordImpl result = ndbRecordImplMap.get(tableName); in getCachedNdbRecordImpl() 265 NdbRecordImpl newNdbRecordImpl; in getCachedNdbRecordImpl() 272 newNdbRecordImpl = new NdbRecordImpl(storeTable, dictionaryForNdbRecord); in getCachedNdbRecordImpl() 303 protected NdbRecordImpl getCachedNdbRecordImpl(Index storeIndex, Table storeTable) { in getCachedNdbRecordImpl() 307 NdbRecordImpl result = ndbRecordImplMap.get(recordName); in getCachedNdbRecordImpl() 314 NdbRecordImpl newNdbRecordImpl; in getCachedNdbRecordImpl() 349 Map.Entry<String, NdbRecordImpl> entry = iterator.next(); in unloadSchema() [all …]
|
H A D | NdbRecordOperationImpl.java | 75 protected NdbRecordImpl ndbRecordKeys = null; 78 protected NdbRecordImpl ndbRecordValues = null; 701 mask[byteOffset] |= NdbRecordImpl.BIT_IN_BYTE_MASK[bitInByte]; in columnSet() 707 byte testMask = NdbRecordImpl.BIT_IN_BYTE_MASK[bitInByte]; in isColumnSet() 711 public NdbRecordImpl getValueNdbRecord() { in getValueNdbRecord()
|
H A D | NdbRecordImpl.java | 77 public class NdbRecordImpl { class 81 .getInstance(NdbRecordImpl.class); 85 .getInstance(NdbRecordImpl.class); 165 protected NdbRecordImpl(Table storeTable, Dictionary ndbDictionary) { in NdbRecordImpl() method in NdbRecordImpl 193 protected NdbRecordImpl(Index storeIndex, Table storeTable, Dictionary ndbDictionary) { in NdbRecordImpl() method in NdbRecordImpl
|
H A D | ClusterTransactionImpl.java | 721 protected NdbRecordImpl getCachedNdbRecordImpl(Table storeTable) { in getCachedNdbRecordImpl() 731 protected NdbRecordImpl getCachedNdbRecordImpl(Index storeIndex, Table storeTable) { in getCachedNdbRecordImpl()
|
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/clusterj/clusterj-tie/src/main/java/com/mysql/clusterj/tie/ |
H A D | ClusterConnectionImpl.java | 83 …private ConcurrentMap<String, NdbRecordImpl> ndbRecordImplMap = new ConcurrentHashMap<String, NdbR… 218 for (NdbRecordImpl ndbRecord: ndbRecordImplMap.values()) { in close() 254 protected NdbRecordImpl getCachedNdbRecordImpl(Table storeTable) { in getCachedNdbRecordImpl() 258 NdbRecordImpl result = ndbRecordImplMap.get(tableName); in getCachedNdbRecordImpl() 265 NdbRecordImpl newNdbRecordImpl; in getCachedNdbRecordImpl() 272 newNdbRecordImpl = new NdbRecordImpl(storeTable, dictionaryForNdbRecord); in getCachedNdbRecordImpl() 303 protected NdbRecordImpl getCachedNdbRecordImpl(Index storeIndex, Table storeTable) { in getCachedNdbRecordImpl() 307 NdbRecordImpl result = ndbRecordImplMap.get(recordName); in getCachedNdbRecordImpl() 314 NdbRecordImpl newNdbRecordImpl; in getCachedNdbRecordImpl() 349 Map.Entry<String, NdbRecordImpl> entry = iterator.next(); in unloadSchema() [all …]
|
H A D | NdbRecordOperationImpl.java | 75 protected NdbRecordImpl ndbRecordKeys = null; 78 protected NdbRecordImpl ndbRecordValues = null; 701 mask[byteOffset] |= NdbRecordImpl.BIT_IN_BYTE_MASK[bitInByte]; in columnSet() 707 byte testMask = NdbRecordImpl.BIT_IN_BYTE_MASK[bitInByte]; in isColumnSet() 711 public NdbRecordImpl getValueNdbRecord() { in getValueNdbRecord()
|
H A D | NdbRecordImpl.java | 77 public class NdbRecordImpl { class 81 .getInstance(NdbRecordImpl.class); 85 .getInstance(NdbRecordImpl.class); 165 protected NdbRecordImpl(Table storeTable, Dictionary ndbDictionary) { in NdbRecordImpl() method in NdbRecordImpl 193 protected NdbRecordImpl(Index storeIndex, Table storeTable, Dictionary ndbDictionary) { in NdbRecordImpl() method in NdbRecordImpl
|
H A D | ClusterTransactionImpl.java | 721 protected NdbRecordImpl getCachedNdbRecordImpl(Table storeTable) { in getCachedNdbRecordImpl() 731 protected NdbRecordImpl getCachedNdbRecordImpl(Index storeIndex, Table storeTable) { in getCachedNdbRecordImpl()
|
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/clusterj/clusterj-tie/src/main/java/com/mysql/clusterj/tie/ |
H A D | ClusterConnectionImpl.java | 83 …private ConcurrentMap<String, NdbRecordImpl> ndbRecordImplMap = new ConcurrentHashMap<String, NdbR… 218 for (NdbRecordImpl ndbRecord: ndbRecordImplMap.values()) { in close() 254 protected NdbRecordImpl getCachedNdbRecordImpl(Table storeTable) { in getCachedNdbRecordImpl() 258 NdbRecordImpl result = ndbRecordImplMap.get(tableName); in getCachedNdbRecordImpl() 265 NdbRecordImpl newNdbRecordImpl; in getCachedNdbRecordImpl() 272 newNdbRecordImpl = new NdbRecordImpl(storeTable, dictionaryForNdbRecord); in getCachedNdbRecordImpl() 303 protected NdbRecordImpl getCachedNdbRecordImpl(Index storeIndex, Table storeTable) { in getCachedNdbRecordImpl() 307 NdbRecordImpl result = ndbRecordImplMap.get(recordName); in getCachedNdbRecordImpl() 314 NdbRecordImpl newNdbRecordImpl; in getCachedNdbRecordImpl() 349 Map.Entry<String, NdbRecordImpl> entry = iterator.next(); in unloadSchema() [all …]
|
H A D | NdbRecordOperationImpl.java | 75 protected NdbRecordImpl ndbRecordKeys = null; 78 protected NdbRecordImpl ndbRecordValues = null; 701 mask[byteOffset] |= NdbRecordImpl.BIT_IN_BYTE_MASK[bitInByte]; in columnSet() 707 byte testMask = NdbRecordImpl.BIT_IN_BYTE_MASK[bitInByte]; in isColumnSet() 711 public NdbRecordImpl getValueNdbRecord() { in getValueNdbRecord()
|
H A D | NdbRecordImpl.java | 77 public class NdbRecordImpl { class 81 .getInstance(NdbRecordImpl.class); 85 .getInstance(NdbRecordImpl.class); 165 protected NdbRecordImpl(Table storeTable, Dictionary ndbDictionary) { in NdbRecordImpl() method in NdbRecordImpl 193 protected NdbRecordImpl(Index storeIndex, Table storeTable, Dictionary ndbDictionary) { in NdbRecordImpl() method in NdbRecordImpl
|
H A D | ClusterTransactionImpl.java | 721 protected NdbRecordImpl getCachedNdbRecordImpl(Table storeTable) { in getCachedNdbRecordImpl() 731 protected NdbRecordImpl getCachedNdbRecordImpl(Index storeIndex, Table storeTable) { in getCachedNdbRecordImpl()
|
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/clusterj/clusterj-tie/src/main/java/com/mysql/clusterj/tie/ |
H A D | ClusterConnectionImpl.java | 83 …private ConcurrentMap<String, NdbRecordImpl> ndbRecordImplMap = new ConcurrentHashMap<String, NdbR… 218 for (NdbRecordImpl ndbRecord: ndbRecordImplMap.values()) { in close() 254 protected NdbRecordImpl getCachedNdbRecordImpl(Table storeTable) { in getCachedNdbRecordImpl() 258 NdbRecordImpl result = ndbRecordImplMap.get(tableName); in getCachedNdbRecordImpl() 265 NdbRecordImpl newNdbRecordImpl; in getCachedNdbRecordImpl() 272 newNdbRecordImpl = new NdbRecordImpl(storeTable, dictionaryForNdbRecord); in getCachedNdbRecordImpl() 303 protected NdbRecordImpl getCachedNdbRecordImpl(Index storeIndex, Table storeTable) { in getCachedNdbRecordImpl() 307 NdbRecordImpl result = ndbRecordImplMap.get(recordName); in getCachedNdbRecordImpl() 314 NdbRecordImpl newNdbRecordImpl; in getCachedNdbRecordImpl() 349 Map.Entry<String, NdbRecordImpl> entry = iterator.next(); in unloadSchema() [all …]
|
H A D | NdbRecordOperationImpl.java | 75 protected NdbRecordImpl ndbRecordKeys = null; 78 protected NdbRecordImpl ndbRecordValues = null; 701 mask[byteOffset] |= NdbRecordImpl.BIT_IN_BYTE_MASK[bitInByte]; in columnSet() 707 byte testMask = NdbRecordImpl.BIT_IN_BYTE_MASK[bitInByte]; in isColumnSet() 711 public NdbRecordImpl getValueNdbRecord() { in getValueNdbRecord()
|
H A D | NdbRecordImpl.java | 77 public class NdbRecordImpl { class 81 .getInstance(NdbRecordImpl.class); 85 .getInstance(NdbRecordImpl.class); 165 protected NdbRecordImpl(Table storeTable, Dictionary ndbDictionary) { in NdbRecordImpl() method in NdbRecordImpl 193 protected NdbRecordImpl(Index storeIndex, Table storeTable, Dictionary ndbDictionary) { in NdbRecordImpl() method in NdbRecordImpl
|
H A D | ClusterTransactionImpl.java | 721 protected NdbRecordImpl getCachedNdbRecordImpl(Table storeTable) { in getCachedNdbRecordImpl() 731 protected NdbRecordImpl getCachedNdbRecordImpl(Index storeIndex, Table storeTable) { in getCachedNdbRecordImpl()
|
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/clusterj/clusterj-tie/src/main/java/com/mysql/clusterj/tie/ |
H A D | ClusterConnectionImpl.java | 83 …private ConcurrentMap<String, NdbRecordImpl> ndbRecordImplMap = new ConcurrentHashMap<String, NdbR… 218 for (NdbRecordImpl ndbRecord: ndbRecordImplMap.values()) { in close() 254 protected NdbRecordImpl getCachedNdbRecordImpl(Table storeTable) { in getCachedNdbRecordImpl() 258 NdbRecordImpl result = ndbRecordImplMap.get(tableName); in getCachedNdbRecordImpl() 265 NdbRecordImpl newNdbRecordImpl; in getCachedNdbRecordImpl() 272 newNdbRecordImpl = new NdbRecordImpl(storeTable, dictionaryForNdbRecord); in getCachedNdbRecordImpl() 303 protected NdbRecordImpl getCachedNdbRecordImpl(Index storeIndex, Table storeTable) { in getCachedNdbRecordImpl() 307 NdbRecordImpl result = ndbRecordImplMap.get(recordName); in getCachedNdbRecordImpl() 314 NdbRecordImpl newNdbRecordImpl; in getCachedNdbRecordImpl() 349 Map.Entry<String, NdbRecordImpl> entry = iterator.next(); in unloadSchema() [all …]
|
H A D | NdbRecordOperationImpl.java | 75 protected NdbRecordImpl ndbRecordKeys = null; 78 protected NdbRecordImpl ndbRecordValues = null; 701 mask[byteOffset] |= NdbRecordImpl.BIT_IN_BYTE_MASK[bitInByte]; in columnSet() 707 byte testMask = NdbRecordImpl.BIT_IN_BYTE_MASK[bitInByte]; in isColumnSet() 711 public NdbRecordImpl getValueNdbRecord() { in getValueNdbRecord()
|
H A D | NdbRecordImpl.java | 77 public class NdbRecordImpl { class 81 .getInstance(NdbRecordImpl.class); 85 .getInstance(NdbRecordImpl.class); 165 protected NdbRecordImpl(Table storeTable, Dictionary ndbDictionary) { in NdbRecordImpl() method in NdbRecordImpl 193 protected NdbRecordImpl(Index storeIndex, Table storeTable, Dictionary ndbDictionary) { in NdbRecordImpl() method in NdbRecordImpl
|
H A D | ClusterTransactionImpl.java | 721 protected NdbRecordImpl getCachedNdbRecordImpl(Table storeTable) { in getCachedNdbRecordImpl() 731 protected NdbRecordImpl getCachedNdbRecordImpl(Index storeIndex, Table storeTable) { in getCachedNdbRecordImpl()
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/clusterj/clusterj-tie/src/main/java/com/mysql/clusterj/tie/ |
H A D | ClusterConnectionImpl.java | 86 …private ConcurrentMap<String, NdbRecordImpl> ndbRecordImplMap = new ConcurrentHashMap<String, NdbR… 264 for (NdbRecordImpl ndbRecord: ndbRecordImplMap.values()) { in close() 307 protected NdbRecordImpl getCachedNdbRecordImpl(Table storeTable) { in getCachedNdbRecordImpl() 312 NdbRecordImpl result = ndbRecordImplMap.get(tableName); in getCachedNdbRecordImpl() 319 NdbRecordImpl newNdbRecordImpl; in getCachedNdbRecordImpl() 326 newNdbRecordImpl = new NdbRecordImpl(storeTable, dictionaryForNdbRecord); in getCachedNdbRecordImpl() 357 protected NdbRecordImpl getCachedNdbRecordImpl(Index storeIndex, Table storeTable) { in getCachedNdbRecordImpl() 361 NdbRecordImpl result = ndbRecordImplMap.get(recordName); in getCachedNdbRecordImpl() 368 NdbRecordImpl newNdbRecordImpl; in getCachedNdbRecordImpl() 409 Map.Entry<String, NdbRecordImpl> entry = iterator.next(); in unloadSchema() [all …]
|
H A D | NdbRecordOperationImpl.java | 76 protected NdbRecordImpl ndbRecordKeys = null; 79 protected NdbRecordImpl ndbRecordValues = null; 718 mask[byteOffset] |= NdbRecordImpl.BIT_IN_BYTE_MASK[bitInByte]; in columnSet() 724 byte testMask = NdbRecordImpl.BIT_IN_BYTE_MASK[bitInByte]; in isColumnSet() 728 public NdbRecordImpl getValueNdbRecord() { in getValueNdbRecord()
|
H A D | NdbRecordImpl.java | 85 public class NdbRecordImpl { class 89 .getInstance(NdbRecordImpl.class); 93 .getInstance(NdbRecordImpl.class); 211 protected NdbRecordImpl(Table storeTable, Dictionary ndbDictionary) { in NdbRecordImpl() method in NdbRecordImpl 247 protected NdbRecordImpl(Index storeIndex, Table storeTable, Dictionary ndbDictionary) { in NdbRecordImpl() method in NdbRecordImpl
|
H A D | ClusterTransactionImpl.java | 729 protected NdbRecordImpl getCachedNdbRecordImpl(Table storeTable) { in getCachedNdbRecordImpl() 739 protected NdbRecordImpl getCachedNdbRecordImpl(Index storeIndex, Table storeTable) { in getCachedNdbRecordImpl()
|