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

HDFS-12481. Ozone: Corona: Support for variable key length in offline mode. Contributed by Nandakumar.

This commit is contained in:
Anu Engineer 2017-09-18 14:43:35 -07:00 committed by Owen O'Malley
parent d9c3d9a5ef
commit b984e903f3
1 changed files with 24 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/ozone/tools/Corona.java
View File

@ -91,6 +91,7 @@ public final class Corona extends Configured implements Tool {
private static final String NUM_OF_VOLUMES = "numOfVolumes";
private static final String NUM_OF_BUCKETS = "numOfBuckets";
private static final String NUM_OF_KEYS = "numOfKeys";
private static final String KEY_SIZE = "keySize";
private static final String MODE_DEFAULT = "offline";
private static final String SOURCE_DEFAULT =
@ -101,6 +102,8 @@ public final class Corona extends Configured implements Tool {
private static final String NUM_OF_BUCKETS_DEFAULT = "1000";
private static final String NUM_OF_KEYS_DEFAULT = "500000";
private static final int KEY_SIZE_DEFAULT = 10240;
private static final Logger LOG =
LoggerFactory.getLogger(Corona.class);
@ -115,6 +118,8 @@ public final class Corona extends Configured implements Tool {
private String numOfBuckets;
private String numOfKeys;
private int keySize;
private boolean validateWrites;
private OzoneClient ozoneClient;
@ -157,8 +162,8 @@ public final class Corona extends Configured implements Tool {
@Override
public int run(String[] args) throws Exception {
GenericOptionsParser parser = new GenericOptionsParser(getConf(),
getOzonePetaGenOptions(), args);
parseOzonePetaGenOptions(parser.getCommandLine());
getOptions(), args);
parseOptions(parser.getCommandLine());
if(printUsage) {
usage();
return 0;
@ -174,6 +179,7 @@ public int run(String[] args) throws Exception {
LOG.info("Number of Volumes: {}.", numOfVolumes);
LOG.info("Number of Buckets per Volume: {}.", numOfBuckets);
LOG.info("Number of Keys per Bucket: {}.", numOfKeys);
LOG.info("Key size: {} bytes", keySize);
for (int i = 0; i < Integer.parseInt(numOfVolumes); i++) {
String volume = "vol-" + i + "-" +
RandomStringUtils.randomNumeric(5);
@ -205,7 +211,7 @@ public int run(String[] args) throws Exception {
return 0;
}
private Options getOzonePetaGenOptions() {
private Options getOptions() {
Options options = new Options();
OptionBuilder.withDescription("prints usage.");
@ -251,6 +257,12 @@ private Options getOzonePetaGenOptions() {
"created per Bucket in offline mode");
Option optNumOfKeys = OptionBuilder.create(NUM_OF_KEYS);
OptionBuilder.withArgName("value");
OptionBuilder.hasArg();
OptionBuilder.withDescription("specifies the size of Key in bytes to be " +
"created in offline mode");
Option optKeySize = OptionBuilder.create(KEY_SIZE);
options.addOption(optHelp);
options.addOption(optMode);
options.addOption(optSource);
@ -259,10 +271,11 @@ private Options getOzonePetaGenOptions() {
options.addOption(optNumOfVolumes);
options.addOption(optNumOfBuckets);
options.addOption(optNumOfKeys);
options.addOption(optKeySize);
return options;
}
private void parseOzonePetaGenOptions(CommandLine cmdLine) {
private void parseOptions(CommandLine cmdLine) {
printUsage = cmdLine.hasOption(HELP);
mode = cmdLine.hasOption(MODE) ?
@ -284,6 +297,10 @@ private void parseOzonePetaGenOptions(CommandLine cmdLine) {
numOfKeys = cmdLine.hasOption(NUM_OF_KEYS) ?
cmdLine.getOptionValue(NUM_OF_KEYS) : NUM_OF_KEYS_DEFAULT;
keySize = cmdLine.hasOption(KEY_SIZE) ?
Integer.parseInt(cmdLine.getOptionValue(KEY_SIZE)) : KEY_SIZE_DEFAULT;
}
private void usage() {
@ -306,6 +323,8 @@ private void usage() {
System.out.println("-numOfKeys <value> "
+ "specifies number of Keys to be created per Bucket " +
"in offline mode");
System.out.println("-keySize <value> "
+ "specifies the size of Key in bytes to be created in offline mode");
System.out.println("-help "
+ "prints usage.");
System.out.println();
@ -343,8 +362,7 @@ public void run() {
String key = "key-" + k + "-" +
RandomStringUtils.randomNumeric(5);
byte[] value = DFSUtil.string2Bytes(
RandomStringUtils.randomAscii(10240));
RandomStringUtils.randomAscii(keySize));
try {
LOG.trace("Adding key: {} in bucket: {} of volume: {}",
key, bucket, volume);