Home
last modified time | relevance | path

Searched refs:tableHash (Results 1 – 25 of 43) sorted by relevance

12

/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/
H A DHashTable.java77 TableHash tableHash = new TableHash(); field in HashTable
102 TableHash tableHash = new TableHash(); in read() local
104 tableHash.hashDir = hashDir; in read()
107 return tableHash; in read()
438 TableMapReduceUtil.initTableMapperJob(tableHash.tableName, tableHash.initScan(), in createSubmittableJob()
445 job.setNumReduceTasks(tableHash.numHashFiles); in createSubmittableJob()
460 tableHash.selectPartitions(regionKeys); in generatePartitions()
640 tableHash.tableName = args[args.length-2]; in doCommandLine()
707 if ((tableHash.startTime != 0 || tableHash.endTime != 0) in doCommandLine()
708 && (tableHash.startTime >= tableHash.endTime)) { in doCommandLine()
[all …]
H A DSyncTable.java87 HashTable.TableHash tableHash = HashTable.TableHash.read(getConf(), sourceHashDir); in createSubmittableJob() local
88 LOG.info("Read source hash manifest: " + tableHash); in createSubmittableJob()
89 LOG.info("Read " + tableHash.partitions.size() + " partition keys"); in createSubmittableJob()
90 if (!tableHash.tableName.equals(sourceTableName)) { in createSubmittableJob()
92 + tableHash.tableName + " but job is reading from: " + sourceTableName); in createSubmittableJob()
94 if (tableHash.numHashFiles != tableHash.partitions.size() + 1) { in createSubmittableJob()
97 + " says numHashFiles=" + tableHash.numHashFiles + " but the number of partition keys" in createSubmittableJob()
98 + " found in the partitions file is " + tableHash.partitions.size()); in createSubmittableJob()
109 if (dataSubdirCount != tableHash.numHashFiles) { in createSubmittableJob()
113 + " found in the partitions file is " + tableHash.partitions.size()); in createSubmittableJob()
[all …]
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/mapreduce/
H A DTestHashTable.java112 HashTable.TableHash tableHash = HashTable.TableHash.read(fs.getConf(), testDir); in testHashTable() local
113 assertEquals(tableName, tableHash.tableName); in testHashTable()
114 assertEquals(batchSize, tableHash.batchSize); in testHashTable()
115 assertEquals(numHashFiles, tableHash.numHashFiles); in testHashTable()
116 assertEquals(numHashFiles - 1, tableHash.partitions.size()); in testHashTable()
117 for (ImmutableBytesWritable bytes : tableHash.partitions) { in testHashTable()
H A DTestSyncTable.java213 HashTable.TableHash tableHash = HashTable.TableHash.read(fs.getConf(), testDir); in hashSourceTable() local
214 assertEquals(sourceTableName, tableHash.tableName); in hashSourceTable()
215 assertEquals(batchSize, tableHash.batchSize); in hashSourceTable()
216 assertEquals(numHashFiles, tableHash.numHashFiles); in hashSourceTable()
217 assertEquals(numHashFiles - 1, tableHash.partitions.size()); in hashSourceTable()
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/java.base/share/classes/sun/text/
H A DIntHashtable.java226 int tableHash = keyList[index]; in find() local
227 if (tableHash == key) { // quick check in find()
229 } else if (tableHash > MAX_UNUSED) { // neither correct nor unused in find()
231 } else if (tableHash == EMPTY) { // empty, end o' the line in find()
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/java.base/share/classes/sun/text/
H A DIntHashtable.java226 int tableHash = keyList[index]; in find() local
227 if (tableHash == key) { // quick check in find()
229 } else if (tableHash > MAX_UNUSED) { // neither correct nor unused in find()
231 } else if (tableHash == EMPTY) { // empty, end o' the line in find()
/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/src/java.base/share/classes/sun/text/
H A DIntHashtable.java226 int tableHash = keyList[index]; in find() local
227 if (tableHash == key) { // quick check in find()
229 } else if (tableHash > MAX_UNUSED) { // neither correct nor unused in find()
231 } else if (tableHash == EMPTY) { // empty, end o' the line in find()
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/src/java.base/share/classes/sun/text/
H A DIntHashtable.java226 int tableHash = keyList[index]; in find() local
227 if (tableHash == key) { // quick check in find()
229 } else if (tableHash > MAX_UNUSED) { // neither correct nor unused in find()
231 } else if (tableHash == EMPTY) { // empty, end o' the line in find()
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/java.base/share/classes/sun/text/
H A DIntHashtable.java226 int tableHash = keyList[index]; in find() local
227 if (tableHash == key) { // quick check in find()
229 } else if (tableHash > MAX_UNUSED) { // neither correct nor unused in find()
231 } else if (tableHash == EMPTY) { // empty, end o' the line in find()
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/src/java.base/share/classes/sun/text/
H A DIntHashtable.java226 int tableHash = keyList[index]; in find() local
227 if (tableHash == key) { // quick check in find()
229 } else if (tableHash > MAX_UNUSED) { // neither correct nor unused in find()
231 } else if (tableHash == EMPTY) { // empty, end o' the line in find()
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/src/java.base/share/classes/sun/text/
H A DIntHashtable.java226 int tableHash = keyList[index]; in find() local
227 if (tableHash == key) { // quick check in find()
229 } else if (tableHash > MAX_UNUSED) { // neither correct nor unused in find()
231 } else if (tableHash == EMPTY) { // empty, end o' the line in find()
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/src/java.base/share/classes/sun/text/
H A DIntHashtable.java226 int tableHash = keyList[index]; in find() local
227 if (tableHash == key) { // quick check in find()
229 } else if (tableHash > MAX_UNUSED) { // neither correct nor unused in find()
231 } else if (tableHash == EMPTY) { // empty, end o' the line in find()
/dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/sun/text/
H A DIntHashtable.java226 int tableHash = keyList[index]; in find() local
227 if (tableHash == key) { // quick check in find()
229 } else if (tableHash > MAX_UNUSED) { // neither correct nor unused in find()
231 } else if (tableHash == EMPTY) { // empty, end o' the line in find()
/dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/sun/text/
H A DIntHashtable.java226 int tableHash = keyList[index]; in find() local
227 if (tableHash == key) { // quick check in find()
229 } else if (tableHash > MAX_UNUSED) { // neither correct nor unused in find()
231 } else if (tableHash == EMPTY) { // empty, end o' the line in find()
/dports/databases/fastdb/fastdb/javacli/
H A DConnection.java149 synchronized (tableHash) { in insert()
150 tableDesc = (TableDescriptor)tableHash.get(className); in insert()
153 tableHash.put(className, tableDesc); in insert()
443 static Hashtable tableHash = new Hashtable(); field in Connection
H A DStatement.java268 synchronized (Connection.tableHash) { in Statement()
269 tableDesc = (TableDescriptor)Connection.tableHash.get(tableName); in Statement()
298 Connection.tableHash.put(tableName, tableDesc); in Statement()
/dports/databases/fastdb/fastdb/CSharpRemoteCLI/
H A DConnection.cs144 lock (tableHash) { in insert()
145 tableDesc = (TableDescriptor)tableHash[className]; in insert()
148 tableHash[className] = tableDesc; in insert()
436 internal static Hashtable tableHash = new Hashtable(); field in CSharpCLI.Connection
H A DStatement.cs289 lock (Connection.tableHash) { in Statement()
290 tableDesc = (TableDescriptor)Connection.tableHash[tableName]; in Statement()
326 Connection.tableHash[tableName] = tableDesc; in Statement()
/dports/databases/gigabase/gigabase/csharpcli/
H A DConnection.cs162 lock (tableHash) { in insert()
163 tableDesc = (TableDescriptor)tableHash[className]; in insert()
166 tableHash[className] = tableDesc; in insert()
457 internal static Hashtable tableHash = new Hashtable(); field in CSharpCLI.Connection
H A DStatement.cs289 lock (Connection.tableHash) { in Statement()
290 tableDesc = (TableDescriptor)Connection.tableHash[tableName]; in Statement()
339 Connection.tableHash[tableName] = tableDesc; in Statement()
/dports/databases/gigabase/gigabase/javacli/
H A DConnection.java166 synchronized (tableHash) { in insert()
167 tableDesc = (TableDescriptor)tableHash.get(className); in insert()
170 tableHash.put(className, tableDesc); in insert()
462 static Hashtable tableHash = new Hashtable(); field in Connection
H A DStatement.java268 synchronized (Connection.tableHash) { in Statement()
269 tableDesc = (TableDescriptor)Connection.tableHash.get(tableName); in Statement()
298 Connection.tableHash.put(tableName, tableDesc); in Statement()
/dports/lang/spidermonkey78/firefox-78.9.0/intl/icu/source/common/
H A Duhash.cpp340 int32_t tableHash; in _uhash_find() local
347 tableHash = elements[theIndex].hashcode; in _uhash_find()
348 if (tableHash == hashcode) { /* quick check */ in _uhash_find()
352 } else if (!IS_EMPTY_OR_DELETED(tableHash)) { in _uhash_find()
357 } else if (tableHash == HASH_EMPTY) { /* empty, end o' the line */ in _uhash_find()
374 } else if (tableHash != HASH_EMPTY) { in _uhash_find()
/dports/textproc/R-cran-stringi/stringi/src/icu55/common/
H A Duhash.c337 int32_t tableHash; in _uhash_find() local
344 tableHash = elements[theIndex].hashcode; in _uhash_find()
345 if (tableHash == hashcode) { /* quick check */ in _uhash_find()
349 } else if (!IS_EMPTY_OR_DELETED(tableHash)) { in _uhash_find()
354 } else if (tableHash == HASH_EMPTY) { /* empty, end o' the line */ in _uhash_find()
371 } else if (tableHash != HASH_EMPTY) { in _uhash_find()
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/icu/source/common/
H A Duhash.cpp340 int32_t tableHash; in _uhash_find() local
347 tableHash = elements[theIndex].hashcode; in _uhash_find()
348 if (tableHash == hashcode) { /* quick check */ in _uhash_find()
352 } else if (!IS_EMPTY_OR_DELETED(tableHash)) { in _uhash_find()
357 } else if (tableHash == HASH_EMPTY) { /* empty, end o' the line */ in _uhash_find()
374 } else if (tableHash != HASH_EMPTY) { in _uhash_find()

12