Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

google-collections 1.0-rc2

  • Loading branch information...
commit f4b3d82dd5975f617e62c879a92d269baff1b712 1 parent 8abc7d4
Paul Lindner authored
View
4 contrib/hadoop-store-builder/src/java/voldemort/store/readonly/mr/HadoopStoreJobRunner.java
@@ -33,7 +33,7 @@
import voldemort.xml.ClusterMapper;
import voldemort.xml.StoreDefinitionsMapper;
-import com.google.common.base.Join;
+import com.google.common.base.Joiner;
import com.google.common.collect.ImmutableCollection;
/**
@@ -97,7 +97,7 @@ public int run(String[] args) throws Exception {
"storename",
"chunksize");
if(missing.size() > 0) {
- System.err.println("Missing required arguments: " + Join.join(", ", missing) + "\n");
+ System.err.println("Missing required arguments: " + Joiner.on(", ").join(missing) + "\n");
printUsage(parser, null);
System.exit(1);
}
View
BIN  lib/google-collect-snapshot-20090211.jar
Binary file not shown
View
4 src/java/voldemort/store/readonly/JsonStoreBuilder.java
@@ -51,7 +51,7 @@
import voldemort.xml.ClusterMapper;
import voldemort.xml.StoreDefinitionsMapper;
-import com.google.common.base.Join;
+import com.google.common.base.Joiner;
import com.google.common.collect.AbstractIterator;
/**
@@ -154,7 +154,7 @@ public static void main(String[] args) throws IOException {
"input",
"output");
if(missing.size() > 0) {
- System.err.println("Missing required arguments: " + Join.join(", ", missing));
+ System.err.println("Missing required arguments: " + Joiner.on(", ").join(missing));
parser.printHelpOn(System.err);
System.exit(1);
}
View
4 src/java/voldemort/store/readonly/StoreSwapper.java
@@ -32,7 +32,7 @@
import voldemort.utils.Time;
import voldemort.xml.ClusterMapper;
-import com.google.common.base.Join;
+import com.google.common.base.Joiner;
/**
* A helper class to invoke the FETCH and SWAP operations on a remote store via
@@ -166,7 +166,7 @@ public static void main(String[] args) throws Exception {
Set<String> missing = CmdUtils.missing(options, "cluster", "name", "file");
if(missing.size() > 0) {
- System.err.println("Missing required arguments: " + Join.join(", ", missing));
+ System.err.println("Missing required arguments: " + Joiner.on(", ").join(missing));
parser.printHelpOn(System.err);
System.exit(1);
}
View
2  src/java/voldemort/store/routed/ReadRepairer.java
@@ -60,7 +60,7 @@
// A Map of Version=>NodeValues that contains the current best estimate
// of the set of current versions
// and the nodes containing them
- Multimap<Version, NodeValue<K, V>> concurrents = new HashMultimap<Version, NodeValue<K, V>>();
+ Multimap<Version, NodeValue<K, V>> concurrents = HashMultimap.create();
concurrents.put(nodeValues.get(0).getVersion(), nodeValues.get(0));
// check each value against the current set of most current versions
View
6 test/integration/voldemort/performance/MysqlBench.java
@@ -35,7 +35,7 @@
import voldemort.utils.CmdUtils;
import voldemort.utils.Utils;
-import com.google.common.base.Join;
+import com.google.common.base.Joiner;
/**
* A simple MySQL benchmark
@@ -77,7 +77,7 @@ public static void main(String[] args) throws Exception {
Set<String> missing = CmdUtils.missing(options, "table", "requests", "db");
if(missing.size() > 0)
- Utils.croak("Missing required arguments: " + Join.join(", ", missing));
+ Utils.croak("Missing required arguments: " + Joiner.on(", ").join(missing));
String host = CmdUtils.valueOf(options, "host", "localhost");
String table = (String) options.valueOf("table");
@@ -235,4 +235,4 @@ public void doOperation(int index) throws Exception {
readTest.printStats();
}
}
-}
+}
View
4 test/integration/voldemort/performance/ReadOnlyStorePerformanceTest.java
@@ -42,7 +42,7 @@
import voldemort.versioning.ObsoleteVersionException;
import voldemort.versioning.Versioned;
-import com.google.common.base.Join;
+import com.google.common.base.Joiner;
public class ReadOnlyStorePerformanceTest {
@@ -66,7 +66,7 @@ public static void main(String[] args) throws FileNotFoundException, IOException
Set<String> missing = CmdUtils.missing(options, "requests", "store-dir");
if(missing.size() > 0) {
- System.err.println("Missing required arguments: " + Join.join(", ", missing));
+ System.err.println("Missing required arguments: " + Joiner.on(", ").join(missing));
parser.printHelpOn(System.err);
System.exit(1);
}
View
4 test/unit/voldemort/routing/ConsistentRoutingStrategyTest.java
@@ -122,8 +122,8 @@ public void testLoadBalancing(int numNodes,
assertEquals(tagsPerNode, router.getPartitionsByNode(n).size());
// do some requests and test the load balancing
- Multiset<Integer> masters = new HashMultiset<Integer>();
- Multiset<Integer> counts = new HashMultiset<Integer>();
+ Multiset<Integer> masters = HashMultiset.create();
+ Multiset<Integer> counts = HashMultiset.create();
byte[] key = new byte[16];
for(int i = 0; i < numRequests; i++) {
random.nextBytes(key);
Please sign in to comment.
Something went wrong with that request. Please try again.