[nitpick] ReadExampleCallable use readConnection
This commit is contained in:
parent
ed90a14995
commit
55cd146a75
|
@ -173,7 +173,7 @@ public class MultiThreadedClientExample extends Configured implements Tool {
|
||||||
} else if (r < .50) {
|
} else if (r < .50) {
|
||||||
f = internalPool.submit(new SingleWriteExampleCallable(writeConnection, tableName));
|
f = internalPool.submit(new SingleWriteExampleCallable(writeConnection, tableName));
|
||||||
} else {
|
} else {
|
||||||
f = internalPool.submit(new ReadExampleCallable(writeConnection, tableName));
|
f = internalPool.submit(new ReadExampleCallable(readConnection, tableName));
|
||||||
}
|
}
|
||||||
futures.add(f);
|
futures.add(f);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue