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

HBASE-12893 - IntegrationTestBigLinkedListWithVisibility should use

Browse Source 
buffered writes (Jingcheng Du)
This commit is contained in:
Ramkrishna 2015-01-27 10:25:23 +05:30
parent 2fb19fb951
commit cfb0cf72d4
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

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