Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-12893 - IntegrationTestBigLinkedListWithVisibility should use 

buffered writes (Jingcheng Du)
This commit is contained in:
Ramkrishna 2015-01-29 12:41:30 +05:30
parent a2d8b0e52b
commit 7b4058a41a
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedListWithVisibility.java
View File

@ -39,6 +39,8 @@ import org.apache.hadoop.hbase.testclassification.IntegrationTests;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.chaos.factories.MonkeyFactory;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.BufferedMutator;
import org.apache.hadoop.hbase.client.BufferedMutatorParams;
import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.HConnection;
@ -46,7 +48,6 @@ import org.apache.hadoop.hbase.client.HConnectionManager;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
import org.apache.hadoop.hbase.io.hfile.HFile;
import org.apache.hadoop.hbase.mapreduce.Import;
@ -171,8 +172,7 @@ public class IntegrationTestBigLinkedListWithVisibility extends IntegrationTestB
}
static class VisibilityGeneratorMapper extends GeneratorMapper {
Table[] tables = new Table[DEFAULT_TABLES_COUNT];
Table commonTable = null;
BufferedMutator[] tables = new BufferedMutator[DEFAULT_TABLES_COUNT];
@Override
protected void setup(org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException,
@ -183,8 +183,9 @@ public class IntegrationTestBigLinkedListWithVisibility extends IntegrationTestB
@Override
protected void instantiateHTable() throws IOException {
for (int i = 0; i < DEFAULT_TABLES_COUNT; i++) {
Table table = connection.getTable(getTableName(i));
//table.setWriteBufferSize(4 * 1024 * 1024);
BufferedMutatorParams params = new BufferedMutatorParams(getTableName(i));
params.writeBufferSize(4 * 1024 * 1024);
BufferedMutator table = connection.getBufferedMutator(params);
this.tables[i] = table;
}
}
@ -217,7 +218,7 @@ public class IntegrationTestBigLinkedListWithVisibility extends IntegrationTestB
}
visibilityExps = split[j * 2] + OR + split[(j * 2) + 1];
put.setCellVisibility(new CellVisibility(visibilityExps));
tables[j].put(put);
tables[j].mutate(put);
try {
Thread.sleep(1);
} catch (InterruptedException e) {