Skip to content

Instantly share code, notes, and snippets.

View patricioe's full-sized avatar

Patricio Echague patricioe

View GitHub Profile
package io.split.engine;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.Collection;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
@patricioe
patricioe / chc-issue.diff
Created June 11, 2012 02:40
CassandraHostConfigurator clock resolution issue
diff --git a/core/src/main/java/me/prettyprint/cassandra/service/CassandraHostConfigurator.java b/core/src/main/java/me/prettyprint/cassandra/service/CassandraHostConfigurator.java
index b40bc06..40a38e1 100644
--- a/core/src/main/java/me/prettyprint/cassandra/service/CassandraHostConfigurator.java
+++ b/core/src/main/java/me/prettyprint/cassandra/service/CassandraHostConfigurator.java
@@ -18,6 +18,9 @@ import me.prettyprint.hector.api.factory.HFactory;
public final class CassandraHostConfigurator implements Serializable {
// update this if you make changes
private static final long serialVersionUID = -5798876803582956262L;
+
+ public static final ClockResolution DEF_CLOCK_RESOLUTION = HFactory.createClockResolution(ClockResolution.MICROSECONDS_SYNC);
1 diff --git a/core/src/main/java/me/prettyprint/cassandra/connection/NodeAutoDiscoverService.java b/core/src/main/java/me/prettyprint/cassandra/connection/NodeAutoDiscoverService.jav a
2 index bc2e3a3..375d489 100644
3 --- a/core/src/main/java/me/prettyprint/cassandra/connection/NodeAutoDiscoverService.java
4 +++ b/core/src/main/java/me/prettyprint/cassandra/connection/NodeAutoDiscoverService.java
5 @@ -11,6 +11,7 @@ import me.prettyprint.hector.api.Keyspace;
6
7 import org.apache.cassandra.thrift.KsDef;
8 import org.apache.cassandra.thrift.TokenRange;
9 +import org.apache.thrift.transport.TTransportException;
10 import org.slf4j.Logger;