You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by sl...@apache.org on 2012/02/27 11:16:00 UTC
[25/28] git commit: [3649] Remove unused imports
[3649] Remove unused imports
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/37f6a9f1
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/37f6a9f1
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/37f6a9f1
Branch: refs/heads/trunk
Commit: 37f6a9f1037a764d6ceda74c02368d25579f8198
Parents: 9020f20
Author: Sylvain Lebresne <sy...@datastax.com>
Authored: Fri Feb 24 15:36:17 2012 +0100
Committer: Sylvain Lebresne <sy...@datastax.com>
Committed: Mon Feb 27 11:00:09 2012 +0100
----------------------------------------------------------------------
.../org/apache/cassandra/cache/KeyCacheKey.java | 3 ---
.../org/apache/cassandra/cache/RowCacheKey.java | 1 -
.../DebuggableScheduledThreadPoolExecutor.java | 3 ---
src/java/org/apache/cassandra/config/Config.java | 3 ---
.../cassandra/cql/CreateKeyspaceStatement.java | 2 --
src/java/org/apache/cassandra/cql/WhereClause.java | 1 -
.../org/apache/cassandra/cql3/CQLStatement.java | 3 ---
.../org/apache/cassandra/cql3/QueryProcessor.java | 5 -----
.../cassandra/cql3/statements/CFStatement.java | 1 -
.../cql3/statements/CreateIndexStatement.java | 2 --
.../cassandra/cql3/statements/DeleteStatement.java | 1 -
.../cassandra/cql3/statements/ParsedStatement.java | 7 -------
.../cql3/statements/SchemaAlteringStatement.java | 1 -
.../cassandra/cql3/statements/SelectStatement.java | 1 -
.../apache/cassandra/db/CollationController.java | 1 -
.../cassandra/db/ColumnFamilySerializer.java | 3 ---
.../cassandra/db/ColumnFamilyStoreMBean.java | 1 -
.../org/apache/cassandra/db/ColumnSerializer.java | 1 -
.../org/apache/cassandra/db/CounterColumn.java | 3 ---
.../org/apache/cassandra/db/CounterMutation.java | 1 -
.../cassandra/db/CounterMutationVerbHandler.java | 5 -----
src/java/org/apache/cassandra/db/DataTracker.java | 3 ---
src/java/org/apache/cassandra/db/EchoedRow.java | 1 -
.../org/apache/cassandra/db/IndexScanCommand.java | 4 ----
src/java/org/apache/cassandra/db/Memtable.java | 3 ---
.../org/apache/cassandra/db/RangeSliceCommand.java | 1 -
.../apache/cassandra/db/RowIteratorFactory.java | 2 --
src/java/org/apache/cassandra/db/Table.java | 4 ----
.../db/columniterator/IColumnIterator.java | 2 --
.../db/columniterator/SimpleSliceReader.java | 1 -
.../AbstractCommitLogExecutorService.java | 3 ---
.../db/commitlog/ICommitLogExecutorService.java | 2 --
.../db/compaction/AbstractCompactionStrategy.java | 1 -
.../db/compaction/CompactionManagerMBean.java | 1 -
.../db/compaction/LazilyCompactedRow.java | 1 -
.../db/compaction/LeveledCompactionTask.java | 7 -------
.../cassandra/db/compaction/LeveledManifest.java | 1 -
.../compaction/SizeTieredCompactionStrategy.java | 1 -
.../cassandra/db/index/SecondaryIndexSearcher.java | 2 --
.../db/marshal/AbstractCommutativeType.java | 2 --
.../org/apache/cassandra/dht/BootStrapper.java | 7 -------
src/java/org/apache/cassandra/dht/Range.java | 3 ---
.../org/apache/cassandra/dht/RingPosition.java | 9 ---------
.../cassandra/gms/GossipDigestAck2Message.java | 1 -
.../cassandra/gms/GossipDigestAckMessage.java | 2 --
.../cassandra/gms/GossipDigestSynMessage.java | 3 ---
src/java/org/apache/cassandra/gms/Gossiper.java | 3 ---
.../apache/cassandra/hadoop/BulkOutputFormat.java | 3 ---
.../apache/cassandra/hadoop/BulkRecordWriter.java | 1 -
.../cassandra/hadoop/ColumnFamilyInputFormat.java | 2 --
.../cassandra/hadoop/ColumnFamilyRecordWriter.java | 1 -
.../cassandra/io/compress/DeflateCompressor.java | 1 -
.../apache/cassandra/io/compress/ICompressor.java | 1 -
.../apache/cassandra/io/sstable/Descriptor.java | 5 -----
.../apache/cassandra/io/sstable/IndexSummary.java | 1 -
.../org/apache/cassandra/io/sstable/SSTable.java | 1 -
.../apache/cassandra/io/sstable/SSTableReader.java | 3 ---
.../io/sstable/SSTableSimpleUnsortedWriter.java | 8 --------
.../apache/cassandra/io/util/ColumnSortedMap.java | 1 -
.../locator/AbstractNetworkTopologySnitch.java | 1 -
.../cassandra/locator/NetworkTopologyStrategy.java | 3 ---
.../org/apache/cassandra/locator/SimpleSnitch.java | 2 --
.../cassandra/net/IncomingTcpConnection.java | 2 --
.../org/apache/cassandra/net/MessagingService.java | 2 --
.../notifications/SSTableAddedNotification.java | 2 --
.../SSTableListChangedNotification.java | 2 --
.../service/AbstractWriteResponseHandler.java | 5 -----
.../cassandra/service/AntiEntropyService.java | 1 -
.../org/apache/cassandra/service/CacheService.java | 4 ----
.../cassandra/service/DatacenterReadCallback.java | 2 --
.../cassandra/service/IWriteResponseHandler.java | 1 -
.../service/RangeSliceResponseResolver.java | 3 ---
.../org/apache/cassandra/service/StorageProxy.java | 2 --
.../cassandra/service/StorageServiceMBean.java | 4 ----
.../apache/cassandra/streaming/FileStreamTask.java | 1 -
.../org/apache/cassandra/streaming/StreamIn.java | 5 -----
.../apache/cassandra/thrift/CassandraDaemon.java | 1 -
.../cassandra/thrift/CustomTThreadPoolServer.java | 1 -
.../cassandra/thrift/TCustomServerSocket.java | 2 --
.../org/apache/cassandra/tools/BulkLoader.java | 4 ----
src/java/org/apache/cassandra/tools/NodeCmd.java | 2 --
src/java/org/apache/cassandra/tools/NodeProbe.java | 1 -
.../org/apache/cassandra/utils/FBUtilities.java | 4 ----
.../apache/cassandra/utils/LegacyBloomFilter.java | 1 -
.../utils/LegacyBloomFilterSerializer.java | 2 --
.../org/apache/cassandra/utils/SlabAllocator.java | 5 -----
.../db/compaction/LongCompactionSpeedTest.java | 2 --
.../cassandra/utils/LongBloomFilterTest.java | 1 -
.../cassandra/utils/LongLegacyBloomFilterTest.java | 1 -
test/unit/org/apache/cassandra/SchemaLoader.java | 1 -
.../apache/cassandra/cache/CacheProviderTest.java | 4 ----
test/unit/org/apache/cassandra/cli/CliTest.java | 1 -
test/unit/org/apache/cassandra/db/CleanupTest.java | 3 ---
.../apache/cassandra/db/ColumnFamilyStoreTest.java | 2 --
.../org/apache/cassandra/db/CommitLogTest.java | 1 -
.../org/apache/cassandra/db/CounterColumnTest.java | 7 -------
.../org/apache/cassandra/db/DirectoriesTest.java | 1 -
.../unit/org/apache/cassandra/db/KeyCacheTest.java | 3 ---
.../org/apache/cassandra/db/KeyCollisionTest.java | 2 --
.../org/apache/cassandra/db/MultitableTest.java | 1 -
.../unit/org/apache/cassandra/db/NameSortTest.java | 3 ---
.../apache/cassandra/db/RecoveryManager2Test.java | 3 ---
.../apache/cassandra/db/RecoveryManagerTest.java | 1 -
.../cassandra/db/RecoveryManagerTruncateTest.java | 1 -
.../cassandra/db/RemoveColumnFamilyTest.java | 1 -
.../db/RemoveColumnFamilyWithFlush1Test.java | 1 -
.../db/RemoveColumnFamilyWithFlush2Test.java | 1 -
.../org/apache/cassandra/db/RemoveColumnTest.java | 1 -
.../apache/cassandra/db/RemoveSubColumnTest.java | 1 -
.../apache/cassandra/db/RemoveSuperColumnTest.java | 1 -
.../org/apache/cassandra/db/RowIterationTest.java | 3 ---
test/unit/org/apache/cassandra/db/RowTest.java | 1 -
test/unit/org/apache/cassandra/db/ScrubTest.java | 1 -
.../org/apache/cassandra/db/SuperColumnTest.java | 4 ----
.../cassandra/db/context/CounterContextTest.java | 2 --
.../cassandra/db/marshal/CompositeTypeTest.java | 1 -
.../db/marshal/DynamicCompositeTypeTest.java | 1 -
.../cassandra/db/marshal/TypeParserTest.java | 13 -------------
.../cassandra/dht/ByteOrderedPartitionerTest.java | 4 ----
.../CollatingOrderPreservingPartitionerTest.java | 4 ----
.../dht/OrderPreservingPartitionerTest.java | 5 -----
.../apache/cassandra/dht/PartitionerTestCase.java | 4 ----
.../cassandra/dht/RandomPartitionerTest.java | 6 ------
.../cassandra/io/sstable/DescriptorTest.java | 4 ----
.../cassandra/io/sstable/IndexHelperTest.java | 2 --
.../cassandra/io/sstable/SSTableReaderTest.java | 2 --
.../io/sstable/SSTableSimpleWriterTest.java | 1 -
.../apache/cassandra/io/sstable/SSTableTest.java | 1 -
.../cassandra/locator/TokenMetadataTest.java | 3 ---
.../service/AntiEntropyServiceTestAbstract.java | 1 -
.../service/EmbeddedCassandraServiceTest.java | 3 ---
.../apache/cassandra/service/StorageProxyTest.java | 3 ---
.../service/StorageServiceClientTest.java | 1 -
.../service/StorageServiceServerTest.java | 1 -
.../cassandra/streaming/SerializationsTest.java | 3 ---
.../org/apache/cassandra/streaming/StreamUtil.java | 1 -
.../apache/cassandra/tools/SSTableImportTest.java | 2 --
.../apache/cassandra/utils/ByteBufferUtilTest.java | 1 -
.../apache/cassandra/utils/FBUtilitiesTest.java | 3 ---
.../apache/cassandra/utils/FilterTestHelper.java | 9 ---------
.../org/apache/cassandra/utils/IntervalTest.java | 1 -
.../stress/operations/CqlIndexedRangeSlicer.java | 1 -
.../stress/operations/CqlRangeSlicer.java | 1 -
.../cassandra/stress/operations/CqlReader.java | 1 -
.../cassandra/stress/server/StressThread.java | 2 --
145 files changed, 0 insertions(+), 352 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/cache/KeyCacheKey.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cache/KeyCacheKey.java b/src/java/org/apache/cassandra/cache/KeyCacheKey.java
index 81ca6c3..2b82574 100644
--- a/src/java/org/apache/cassandra/cache/KeyCacheKey.java
+++ b/src/java/org/apache/cassandra/cache/KeyCacheKey.java
@@ -19,10 +19,7 @@ package org.apache.cassandra.cache;
import java.nio.ByteBuffer;
-import org.apache.cassandra.db.DecoratedKey;
-import org.apache.cassandra.io.sstable.Component;
import org.apache.cassandra.io.sstable.Descriptor;
-import org.apache.cassandra.service.StorageService;
import org.apache.cassandra.utils.Pair;
public class KeyCacheKey extends Pair<Descriptor, ByteBuffer> implements CacheKey
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/cache/RowCacheKey.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cache/RowCacheKey.java b/src/java/org/apache/cassandra/cache/RowCacheKey.java
index 6a9a61c..180ed1b 100644
--- a/src/java/org/apache/cassandra/cache/RowCacheKey.java
+++ b/src/java/org/apache/cassandra/cache/RowCacheKey.java
@@ -21,7 +21,6 @@ import java.nio.ByteBuffer;
import org.apache.cassandra.config.Schema;
import org.apache.cassandra.db.DecoratedKey;
-import org.apache.cassandra.service.StorageService;
import org.apache.cassandra.utils.ByteBufferUtil;
import org.apache.cassandra.utils.Pair;
import org.apache.commons.lang.builder.HashCodeBuilder;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/concurrent/DebuggableScheduledThreadPoolExecutor.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/concurrent/DebuggableScheduledThreadPoolExecutor.java b/src/java/org/apache/cassandra/concurrent/DebuggableScheduledThreadPoolExecutor.java
index 55a2984..a41df54 100644
--- a/src/java/org/apache/cassandra/concurrent/DebuggableScheduledThreadPoolExecutor.java
+++ b/src/java/org/apache/cassandra/concurrent/DebuggableScheduledThreadPoolExecutor.java
@@ -19,9 +19,6 @@ package org.apache.cassandra.concurrent;
import java.util.concurrent.*;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
/**
* Like DebuggableThreadPoolExecutor, DebuggableScheduledThreadPoolExecutor always
* logs exceptions from the tasks it is given, even if Future.get is never called elsewhere.
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/config/Config.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/config/Config.java b/src/java/org/apache/cassandra/config/Config.java
index 01c47af..b5fbfb5 100644
--- a/src/java/org/apache/cassandra/config/Config.java
+++ b/src/java/org/apache/cassandra/config/Config.java
@@ -18,9 +18,6 @@
package org.apache.cassandra.config;
import org.apache.cassandra.cache.ConcurrentLinkedHashCacheProvider;
-import org.apache.cassandra.cache.IRowCacheProvider;
-
-import java.util.List;
public class Config
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/cql/CreateKeyspaceStatement.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cql/CreateKeyspaceStatement.java b/src/java/org/apache/cassandra/cql/CreateKeyspaceStatement.java
index 09569d7..7ef861a 100644
--- a/src/java/org/apache/cassandra/cql/CreateKeyspaceStatement.java
+++ b/src/java/org/apache/cassandra/cql/CreateKeyspaceStatement.java
@@ -23,8 +23,6 @@ import java.util.Map;
import org.apache.cassandra.config.ConfigurationException;
import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.locator.AbstractReplicationStrategy;
-import org.apache.cassandra.locator.IEndpointSnitch;
-import org.apache.cassandra.locator.TokenMetadata;
import org.apache.cassandra.service.StorageService;
import org.apache.cassandra.thrift.InvalidRequestException;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/cql/WhereClause.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cql/WhereClause.java b/src/java/org/apache/cassandra/cql/WhereClause.java
index 5871ac0..ceeaa06 100644
--- a/src/java/org/apache/cassandra/cql/WhereClause.java
+++ b/src/java/org/apache/cassandra/cql/WhereClause.java
@@ -17,7 +17,6 @@
*/
package org.apache.cassandra.cql;
-import java.nio.ByteBuffer;
import java.nio.charset.CharacterCodingException;
import java.util.ArrayList;
import java.util.LinkedHashSet;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/cql3/CQLStatement.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cql3/CQLStatement.java b/src/java/org/apache/cassandra/cql3/CQLStatement.java
index 790ef7b..ef24fc7 100644
--- a/src/java/org/apache/cassandra/cql3/CQLStatement.java
+++ b/src/java/org/apache/cassandra/cql3/CQLStatement.java
@@ -18,17 +18,14 @@
package org.apache.cassandra.cql3;
import java.nio.ByteBuffer;
-import java.util.Collections;
import java.util.List;
-import org.apache.cassandra.db.marshal.AbstractType;
import org.apache.cassandra.service.ClientState;
import org.apache.cassandra.thrift.CqlResult;
import org.apache.cassandra.thrift.InvalidRequestException;
import org.apache.cassandra.thrift.SchemaDisagreementException;
import org.apache.cassandra.thrift.TimedOutException;
import org.apache.cassandra.thrift.UnavailableException;
-import org.apache.cassandra.utils.Pair;
public interface CQLStatement
{
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/cql3/QueryProcessor.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cql3/QueryProcessor.java b/src/java/org/apache/cassandra/cql3/QueryProcessor.java
index 3a793f2..fb7cfb6 100644
--- a/src/java/org/apache/cassandra/cql3/QueryProcessor.java
+++ b/src/java/org/apache/cassandra/cql3/QueryProcessor.java
@@ -20,8 +20,6 @@ package org.apache.cassandra.cql3;
import java.nio.ByteBuffer;
import java.util.*;
-import com.google.common.base.Predicates;
-import com.google.common.collect.Maps;
import org.antlr.runtime.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -33,10 +31,7 @@ import org.apache.cassandra.db.marshal.AbstractType;
import org.apache.cassandra.db.marshal.TypeParser;
import org.apache.cassandra.service.ClientState;
import org.apache.cassandra.thrift.*;
-import org.apache.cassandra.thrift.Column;
-import org.apache.cassandra.utils.ByteBufferUtil;
import org.apache.cassandra.utils.FBUtilities;
-import org.apache.cassandra.utils.Pair;
import org.apache.cassandra.utils.SemanticVersion;
public class QueryProcessor
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/cql3/statements/CFStatement.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cql3/statements/CFStatement.java b/src/java/org/apache/cassandra/cql3/statements/CFStatement.java
index 392d3ea..dcc75b2 100644
--- a/src/java/org/apache/cassandra/cql3/statements/CFStatement.java
+++ b/src/java/org/apache/cassandra/cql3/statements/CFStatement.java
@@ -18,7 +18,6 @@
package org.apache.cassandra.cql3.statements;
import org.apache.cassandra.cql3.CFName;
-import org.apache.cassandra.cql3.CQLStatement;
import org.apache.cassandra.service.ClientState;
import org.apache.cassandra.thrift.InvalidRequestException;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/cql3/statements/CreateIndexStatement.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cql3/statements/CreateIndexStatement.java b/src/java/org/apache/cassandra/cql3/statements/CreateIndexStatement.java
index 98ae497..0ed12c2 100644
--- a/src/java/org/apache/cassandra/cql3/statements/CreateIndexStatement.java
+++ b/src/java/org/apache/cassandra/cql3/statements/CreateIndexStatement.java
@@ -17,8 +17,6 @@
*/
package org.apache.cassandra.cql3.statements;
-import java.io.IOException;
-
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/cql3/statements/DeleteStatement.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cql3/statements/DeleteStatement.java b/src/java/org/apache/cassandra/cql3/statements/DeleteStatement.java
index 90176e0..813caa2 100644
--- a/src/java/org/apache/cassandra/cql3/statements/DeleteStatement.java
+++ b/src/java/org/apache/cassandra/cql3/statements/DeleteStatement.java
@@ -25,7 +25,6 @@ import java.util.List;
import java.util.HashMap;
import java.util.Map;
-import org.apache.cassandra.auth.Permission;
import org.apache.cassandra.cql3.*;
import org.apache.cassandra.config.CFMetaData;
import org.apache.cassandra.db.IMutation;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/cql3/statements/ParsedStatement.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cql3/statements/ParsedStatement.java b/src/java/org/apache/cassandra/cql3/statements/ParsedStatement.java
index 079c92a..ece8f05 100644
--- a/src/java/org/apache/cassandra/cql3/statements/ParsedStatement.java
+++ b/src/java/org/apache/cassandra/cql3/statements/ParsedStatement.java
@@ -17,19 +17,12 @@
*/
package org.apache.cassandra.cql3.statements;
-import java.nio.ByteBuffer;
import java.util.Collections;
import java.util.List;
import org.apache.cassandra.cql3.*;
import org.apache.cassandra.db.marshal.AbstractType;
-import org.apache.cassandra.service.ClientState;
-import org.apache.cassandra.thrift.CqlResult;
import org.apache.cassandra.thrift.InvalidRequestException;
-import org.apache.cassandra.thrift.SchemaDisagreementException;
-import org.apache.cassandra.thrift.TimedOutException;
-import org.apache.cassandra.thrift.UnavailableException;
-import org.apache.cassandra.utils.Pair;
public abstract class ParsedStatement
{
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/cql3/statements/SchemaAlteringStatement.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cql3/statements/SchemaAlteringStatement.java b/src/java/org/apache/cassandra/cql3/statements/SchemaAlteringStatement.java
index b9ea2e7..76aaa1f 100644
--- a/src/java/org/apache/cassandra/cql3/statements/SchemaAlteringStatement.java
+++ b/src/java/org/apache/cassandra/cql3/statements/SchemaAlteringStatement.java
@@ -19,7 +19,6 @@ package org.apache.cassandra.cql3.statements;
import java.io.IOException;
import java.nio.ByteBuffer;
-import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.concurrent.Callable;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java b/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
index ce00077..72f1889 100644
--- a/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
+++ b/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
@@ -22,7 +22,6 @@ import java.nio.ByteBuffer;
import java.util.*;
import java.util.concurrent.TimeoutException;
-import com.google.common.base.Objects;
import com.google.common.collect.AbstractIterator;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/CollationController.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/CollationController.java b/src/java/org/apache/cassandra/db/CollationController.java
index 77962ef..9f6a489 100644
--- a/src/java/org/apache/cassandra/db/CollationController.java
+++ b/src/java/org/apache/cassandra/db/CollationController.java
@@ -21,7 +21,6 @@ import java.io.IOException;
import java.nio.ByteBuffer;
import java.util.*;
-import com.google.common.collect.Iterables;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/ColumnFamilySerializer.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/ColumnFamilySerializer.java b/src/java/org/apache/cassandra/db/ColumnFamilySerializer.java
index 42d5776..87ab030 100644
--- a/src/java/org/apache/cassandra/db/ColumnFamilySerializer.java
+++ b/src/java/org/apache/cassandra/db/ColumnFamilySerializer.java
@@ -20,17 +20,14 @@ package org.apache.cassandra.db;
import java.io.DataInput;
import java.io.DataOutput;
import java.io.IOException;
-import java.io.RandomAccessFile;
import java.util.Collection;
import org.apache.cassandra.config.Schema;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.apache.cassandra.config.CFMetaData;
import org.apache.cassandra.io.IColumnSerializer;
import org.apache.cassandra.io.ISerializer;
-import org.apache.cassandra.io.sstable.SSTableMetadata;
public class ColumnFamilySerializer implements ISerializer<ColumnFamily>
{
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/ColumnFamilyStoreMBean.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/ColumnFamilyStoreMBean.java b/src/java/org/apache/cassandra/db/ColumnFamilyStoreMBean.java
index 33c2eac..52f1be9 100644
--- a/src/java/org/apache/cassandra/db/ColumnFamilyStoreMBean.java
+++ b/src/java/org/apache/cassandra/db/ColumnFamilyStoreMBean.java
@@ -17,7 +17,6 @@
*/
package org.apache.cassandra.db;
-import java.io.IOException;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ExecutionException;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/ColumnSerializer.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/ColumnSerializer.java b/src/java/org/apache/cassandra/db/ColumnSerializer.java
index 5a50f3d..6e7449c 100644
--- a/src/java/org/apache/cassandra/db/ColumnSerializer.java
+++ b/src/java/org/apache/cassandra/db/ColumnSerializer.java
@@ -25,7 +25,6 @@ import java.nio.ByteBuffer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.apache.cassandra.db.context.CounterContext;
import org.apache.cassandra.io.IColumnSerializer;
import org.apache.cassandra.io.util.FileDataInput;
import org.apache.cassandra.utils.ByteBufferUtil;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/CounterColumn.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/CounterColumn.java b/src/java/org/apache/cassandra/db/CounterColumn.java
index 681322e..369e183 100644
--- a/src/java/org/apache/cassandra/db/CounterColumn.java
+++ b/src/java/org/apache/cassandra/db/CounterColumn.java
@@ -22,11 +22,8 @@ import java.nio.ByteBuffer;
import java.net.InetAddress;
import java.security.MessageDigest;
import java.util.concurrent.TimeoutException;
-import java.util.Arrays;
-import java.util.Map;
import java.util.Collection;
-import com.google.common.collect.Multimap;
import org.apache.log4j.Logger;
import org.apache.cassandra.config.CFMetaData;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/CounterMutation.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/CounterMutation.java b/src/java/org/apache/cassandra/db/CounterMutation.java
index 8f0fdd9..7ee9d80 100644
--- a/src/java/org/apache/cassandra/db/CounterMutation.java
+++ b/src/java/org/apache/cassandra/db/CounterMutation.java
@@ -28,7 +28,6 @@ import org.slf4j.LoggerFactory;
import org.apache.cassandra.db.filter.QueryPath;
import org.apache.cassandra.io.IVersionedSerializer;
-import org.apache.cassandra.io.util.DataOutputBuffer;
import org.apache.cassandra.net.Message;
import org.apache.cassandra.service.StorageService;
import org.apache.cassandra.utils.ByteBufferUtil;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/CounterMutationVerbHandler.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/CounterMutationVerbHandler.java b/src/java/org/apache/cassandra/db/CounterMutationVerbHandler.java
index a982371..12360f4 100644
--- a/src/java/org/apache/cassandra/db/CounterMutationVerbHandler.java
+++ b/src/java/org/apache/cassandra/db/CounterMutationVerbHandler.java
@@ -20,10 +20,6 @@ package org.apache.cassandra.db;
import java.io.*;
import java.util.concurrent.TimeoutException;
-import java.net.InetAddress;
-import java.nio.ByteBuffer;
-import java.util.Collections;
-
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -32,7 +28,6 @@ import org.apache.cassandra.io.util.FastByteArrayInputStream;
import org.apache.cassandra.net.*;
import org.apache.cassandra.utils.FBUtilities;
import org.apache.cassandra.service.StorageProxy;
-import org.apache.cassandra.thrift.ConsistencyLevel;
import org.apache.cassandra.thrift.UnavailableException;
public class CounterMutationVerbHandler implements IVerbHandler
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/DataTracker.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/DataTracker.java b/src/java/org/apache/cassandra/db/DataTracker.java
index 81b39e4..2e6fc8e 100644
--- a/src/java/org/apache/cassandra/db/DataTracker.java
+++ b/src/java/org/apache/cassandra/db/DataTracker.java
@@ -18,7 +18,6 @@
package org.apache.cassandra.db;
import java.io.File;
-import java.io.IOException;
import java.util.*;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.atomic.AtomicLong;
@@ -29,8 +28,6 @@ import com.google.common.collect.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.apache.cassandra.cache.AutoSavingCache;
-import org.apache.cassandra.cache.KeyCacheKey;
import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.io.sstable.SSTableReader;
import org.apache.cassandra.notifications.INotification;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/EchoedRow.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/EchoedRow.java b/src/java/org/apache/cassandra/db/EchoedRow.java
index 7fb791b..9067a10 100644
--- a/src/java/org/apache/cassandra/db/EchoedRow.java
+++ b/src/java/org/apache/cassandra/db/EchoedRow.java
@@ -22,7 +22,6 @@ import java.io.IOException;
import java.security.MessageDigest;
import org.apache.cassandra.db.compaction.AbstractCompactedRow;
-import org.apache.cassandra.db.compaction.CompactionController;
import org.apache.cassandra.io.sstable.SSTableIdentityIterator;
/**
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/IndexScanCommand.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/IndexScanCommand.java b/src/java/org/apache/cassandra/db/IndexScanCommand.java
index a974f6f..df19de7 100644
--- a/src/java/org/apache/cassandra/db/IndexScanCommand.java
+++ b/src/java/org/apache/cassandra/db/IndexScanCommand.java
@@ -21,14 +21,10 @@ import java.io.*;
import java.util.Arrays;
import org.apache.cassandra.dht.AbstractBounds;
-import org.apache.cassandra.dht.Bounds;
-import org.apache.cassandra.dht.Token;
-import org.apache.cassandra.dht.Range;
import org.apache.cassandra.io.IVersionedSerializer;
import org.apache.cassandra.io.util.DataOutputBuffer;
import org.apache.cassandra.io.util.FastByteArrayInputStream;
import org.apache.cassandra.net.Message;
-import org.apache.cassandra.net.MessagingService;
import org.apache.cassandra.net.MessageProducer;
import org.apache.cassandra.service.StorageService;
import org.apache.cassandra.thrift.IndexClause;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/Memtable.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/Memtable.java b/src/java/org/apache/cassandra/db/Memtable.java
index 7f31f35..b857686 100644
--- a/src/java/org/apache/cassandra/db/Memtable.java
+++ b/src/java/org/apache/cassandra/db/Memtable.java
@@ -25,8 +25,6 @@ import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicLong;
import com.google.common.base.Function;
-import com.google.common.collect.Iterators;
-import com.google.common.collect.PeekingIterator;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -38,7 +36,6 @@ import org.apache.cassandra.db.commitlog.ReplayPosition;
import org.apache.cassandra.db.filter.AbstractColumnIterator;
import org.apache.cassandra.db.filter.NamesQueryFilter;
import org.apache.cassandra.db.filter.SliceQueryFilter;
-import org.apache.cassandra.db.marshal.AbstractType;
import org.apache.cassandra.io.sstable.SSTableReader;
import org.apache.cassandra.io.sstable.SSTableWriter;
import org.apache.cassandra.utils.FBUtilities;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/RangeSliceCommand.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/RangeSliceCommand.java b/src/java/org/apache/cassandra/db/RangeSliceCommand.java
index 767deb4..c97c3af 100644
--- a/src/java/org/apache/cassandra/db/RangeSliceCommand.java
+++ b/src/java/org/apache/cassandra/db/RangeSliceCommand.java
@@ -42,7 +42,6 @@ import java.util.ArrayList;
import java.util.List;
import org.apache.cassandra.dht.AbstractBounds;
-import org.apache.cassandra.dht.Token;
import org.apache.cassandra.io.IVersionedSerializer;
import org.apache.cassandra.io.util.DataOutputBuffer;
import org.apache.cassandra.io.util.FastByteArrayInputStream;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/RowIteratorFactory.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/RowIteratorFactory.java b/src/java/org/apache/cassandra/db/RowIteratorFactory.java
index a1cb150..674d711 100644
--- a/src/java/org/apache/cassandra/db/RowIteratorFactory.java
+++ b/src/java/org/apache/cassandra/db/RowIteratorFactory.java
@@ -17,10 +17,8 @@
*/
package org.apache.cassandra.db;
-import java.io.Closeable;
import java.util.*;
-import com.google.common.base.Predicate;
import com.google.common.collect.AbstractIterator;
import org.apache.cassandra.db.columniterator.IColumnIterator;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/Table.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/Table.java b/src/java/org/apache/cassandra/db/Table.java
index a3d52c7..7c6a629 100644
--- a/src/java/org/apache/cassandra/db/Table.java
+++ b/src/java/org/apache/cassandra/db/Table.java
@@ -17,7 +17,6 @@
*/
package org.apache.cassandra.db;
-import java.io.File;
import java.io.IOError;
import java.io.IOException;
import java.nio.ByteBuffer;
@@ -39,10 +38,7 @@ import org.apache.cassandra.config.*;
import org.apache.cassandra.db.commitlog.CommitLog;
import org.apache.cassandra.db.filter.QueryFilter;
import org.apache.cassandra.db.filter.QueryPath;
-import org.apache.cassandra.io.sstable.SSTableDeletingTask;
import org.apache.cassandra.io.sstable.SSTableReader;
-import org.apache.cassandra.io.util.FileUtils;
-import org.apache.cassandra.io.util.MmappedSegmentedFile;
import org.apache.cassandra.locator.AbstractReplicationStrategy;
import org.apache.cassandra.service.StorageService;
import org.apache.cassandra.utils.ByteBufferUtil;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/columniterator/IColumnIterator.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/columniterator/IColumnIterator.java b/src/java/org/apache/cassandra/db/columniterator/IColumnIterator.java
index 268f870..bfef382 100644
--- a/src/java/org/apache/cassandra/db/columniterator/IColumnIterator.java
+++ b/src/java/org/apache/cassandra/db/columniterator/IColumnIterator.java
@@ -18,8 +18,6 @@
package org.apache.cassandra.db.columniterator;
import java.io.IOException;
-import java.util.Iterator;
-
import org.apache.cassandra.db.ColumnFamily;
import org.apache.cassandra.db.DecoratedKey;
import org.apache.cassandra.db.IColumn;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/columniterator/SimpleSliceReader.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/columniterator/SimpleSliceReader.java b/src/java/org/apache/cassandra/db/columniterator/SimpleSliceReader.java
index 4085db9..2a1e5cf 100644
--- a/src/java/org/apache/cassandra/db/columniterator/SimpleSliceReader.java
+++ b/src/java/org/apache/cassandra/db/columniterator/SimpleSliceReader.java
@@ -23,7 +23,6 @@ import java.nio.ByteBuffer;
import com.google.common.collect.AbstractIterator;
-import org.apache.cassandra.config.CFMetaData;
import org.apache.cassandra.db.ColumnFamily;
import org.apache.cassandra.db.DecoratedKey;
import org.apache.cassandra.db.IColumn;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/commitlog/AbstractCommitLogExecutorService.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/commitlog/AbstractCommitLogExecutorService.java b/src/java/org/apache/cassandra/db/commitlog/AbstractCommitLogExecutorService.java
index 612b931..ec43114 100644
--- a/src/java/org/apache/cassandra/db/commitlog/AbstractCommitLogExecutorService.java
+++ b/src/java/org/apache/cassandra/db/commitlog/AbstractCommitLogExecutorService.java
@@ -17,12 +17,9 @@
*/
package org.apache.cassandra.db.commitlog;
-import java.lang.management.ManagementFactory;
import java.util.List;
import java.util.concurrent.AbstractExecutorService;
import java.util.concurrent.TimeUnit;
-import javax.management.MBeanServer;
-import javax.management.ObjectName;
public abstract class AbstractCommitLogExecutorService extends AbstractExecutorService implements ICommitLogExecutorService
{
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/commitlog/ICommitLogExecutorService.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/commitlog/ICommitLogExecutorService.java b/src/java/org/apache/cassandra/db/commitlog/ICommitLogExecutorService.java
index c484c80..e2d0b0f 100644
--- a/src/java/org/apache/cassandra/db/commitlog/ICommitLogExecutorService.java
+++ b/src/java/org/apache/cassandra/db/commitlog/ICommitLogExecutorService.java
@@ -20,8 +20,6 @@ package org.apache.cassandra.db.commitlog;
import java.util.concurrent.Callable;
import java.util.concurrent.Future;
-import org.apache.cassandra.concurrent.IExecutorMBean;
-
/**
* Like ExecutorService, but customized for batch and periodic commitlog execution.
*/
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/compaction/AbstractCompactionStrategy.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/compaction/AbstractCompactionStrategy.java b/src/java/org/apache/cassandra/db/compaction/AbstractCompactionStrategy.java
index a1ad113..bb84d1d 100644
--- a/src/java/org/apache/cassandra/db/compaction/AbstractCompactionStrategy.java
+++ b/src/java/org/apache/cassandra/db/compaction/AbstractCompactionStrategy.java
@@ -18,7 +18,6 @@
package org.apache.cassandra.db.compaction;
import java.util.Collection;
-import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/compaction/CompactionManagerMBean.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/compaction/CompactionManagerMBean.java b/src/java/org/apache/cassandra/db/compaction/CompactionManagerMBean.java
index f12e258..07e4231 100644
--- a/src/java/org/apache/cassandra/db/compaction/CompactionManagerMBean.java
+++ b/src/java/org/apache/cassandra/db/compaction/CompactionManagerMBean.java
@@ -17,7 +17,6 @@
*/
package org.apache.cassandra.db.compaction;
-import java.util.HashMap;
import java.util.List;
import java.util.Map;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/compaction/LazilyCompactedRow.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/compaction/LazilyCompactedRow.java b/src/java/org/apache/cassandra/db/compaction/LazilyCompactedRow.java
index 5a70627..61546f3 100644
--- a/src/java/org/apache/cassandra/db/compaction/LazilyCompactedRow.java
+++ b/src/java/org/apache/cassandra/db/compaction/LazilyCompactedRow.java
@@ -20,7 +20,6 @@ package org.apache.cassandra.db.compaction;
import java.io.DataOutput;
import java.io.IOError;
import java.io.IOException;
-import java.nio.channels.ClosedByInterruptException;
import java.security.MessageDigest;
import java.util.Iterator;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/compaction/LeveledCompactionTask.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/compaction/LeveledCompactionTask.java b/src/java/org/apache/cassandra/db/compaction/LeveledCompactionTask.java
index 1978aa9..e513a58 100644
--- a/src/java/org/apache/cassandra/db/compaction/LeveledCompactionTask.java
+++ b/src/java/org/apache/cassandra/db/compaction/LeveledCompactionTask.java
@@ -17,19 +17,12 @@
*/
package org.apache.cassandra.db.compaction;
-import java.io.File;
import java.io.IOException;
import java.util.Collection;
import java.util.Set;
import java.util.concurrent.CountDownLatch;
-import com.google.common.collect.Iterables;
-
-import org.apache.commons.lang.StringUtils;
-
-import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.db.ColumnFamilyStore;
-import org.apache.cassandra.db.Table;
import org.apache.cassandra.io.sstable.SSTableReader;
import org.apache.cassandra.io.sstable.SSTableWriter;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/compaction/LeveledManifest.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/compaction/LeveledManifest.java b/src/java/org/apache/cassandra/db/compaction/LeveledManifest.java
index 1093f3d..b66426e 100644
--- a/src/java/org/apache/cassandra/db/compaction/LeveledManifest.java
+++ b/src/java/org/apache/cassandra/db/compaction/LeveledManifest.java
@@ -27,7 +27,6 @@ import com.google.common.primitives.Ints;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.db.ColumnFamilyStore;
import org.apache.cassandra.db.RowPosition;
import org.apache.cassandra.dht.Range;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/compaction/SizeTieredCompactionStrategy.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/compaction/SizeTieredCompactionStrategy.java b/src/java/org/apache/cassandra/db/compaction/SizeTieredCompactionStrategy.java
index 01bc75b..043e301 100644
--- a/src/java/org/apache/cassandra/db/compaction/SizeTieredCompactionStrategy.java
+++ b/src/java/org/apache/cassandra/db/compaction/SizeTieredCompactionStrategy.java
@@ -24,7 +24,6 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.apache.cassandra.db.ColumnFamilyStore;
-import org.apache.cassandra.db.DataTracker;
import org.apache.cassandra.io.sstable.SSTable;
import org.apache.cassandra.io.sstable.SSTableReader;
import org.apache.cassandra.utils.Pair;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/index/SecondaryIndexSearcher.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/index/SecondaryIndexSearcher.java b/src/java/org/apache/cassandra/db/index/SecondaryIndexSearcher.java
index 46f8813..783f7e8 100644
--- a/src/java/org/apache/cassandra/db/index/SecondaryIndexSearcher.java
+++ b/src/java/org/apache/cassandra/db/index/SecondaryIndexSearcher.java
@@ -22,10 +22,8 @@ import java.util.*;
import org.apache.cassandra.db.*;
import org.apache.cassandra.db.filter.IFilter;
-import org.apache.cassandra.db.filter.NamesQueryFilter;
import org.apache.cassandra.dht.AbstractBounds;
import org.apache.cassandra.thrift.IndexExpression;
-import org.apache.cassandra.thrift.IndexOperator;
public abstract class SecondaryIndexSearcher
{
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/db/marshal/AbstractCommutativeType.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/marshal/AbstractCommutativeType.java b/src/java/org/apache/cassandra/db/marshal/AbstractCommutativeType.java
index 193197e..a9c151d 100644
--- a/src/java/org/apache/cassandra/db/marshal/AbstractCommutativeType.java
+++ b/src/java/org/apache/cassandra/db/marshal/AbstractCommutativeType.java
@@ -18,8 +18,6 @@
package org.apache.cassandra.db.marshal;
import java.nio.ByteBuffer;
-import java.sql.Types;
-
import org.apache.cassandra.db.Column;
import org.apache.cassandra.db.context.CounterContext;
import org.apache.cassandra.utils.ByteBufferUtil;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/dht/BootStrapper.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/dht/BootStrapper.java b/src/java/org/apache/cassandra/dht/BootStrapper.java
index 06f0083..8699999 100644
--- a/src/java/org/apache/cassandra/dht/BootStrapper.java
+++ b/src/java/org/apache/cassandra/dht/BootStrapper.java
@@ -20,18 +20,13 @@ package org.apache.cassandra.dht;
import java.io.IOException;
import java.net.InetAddress;
import java.util.*;
- import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Condition;
import com.google.common.base.Charsets;
- import com.google.common.collect.ArrayListMultimap;
- import com.google.common.collect.HashMultimap;
- import com.google.common.collect.Multimap;
import org.apache.cassandra.config.Schema;
import org.apache.cassandra.gms.Gossiper;
import org.apache.commons.lang.ArrayUtils;
- import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -39,7 +34,6 @@ package org.apache.cassandra.dht;
import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.db.Table;
import org.apache.cassandra.gms.FailureDetector;
- import org.apache.cassandra.gms.IFailureDetector;
import org.apache.cassandra.locator.AbstractReplicationStrategy;
import org.apache.cassandra.locator.TokenMetadata;
import org.apache.cassandra.net.IAsyncCallback;
@@ -48,7 +42,6 @@ package org.apache.cassandra.dht;
import org.apache.cassandra.net.MessagingService;
import org.apache.cassandra.service.StorageService;
import org.apache.cassandra.streaming.OperationType;
- import org.apache.cassandra.streaming.StreamIn;
import org.apache.cassandra.utils.FBUtilities;
import org.apache.cassandra.utils.SimpleCondition;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/dht/Range.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/dht/Range.java b/src/java/org/apache/cassandra/dht/Range.java
index 1167068..c9948c3 100644
--- a/src/java/org/apache/cassandra/dht/Range.java
+++ b/src/java/org/apache/cassandra/dht/Range.java
@@ -18,15 +18,12 @@
package org.apache.cassandra.dht;
import java.io.Serializable;
-import java.nio.ByteBuffer;
import java.util.*;
-import org.apache.cassandra.utils.ByteBufferUtil;
import org.apache.commons.lang.ObjectUtils;
import org.apache.cassandra.db.RowPosition;
import org.apache.cassandra.service.StorageService;
-import org.apache.cassandra.utils.FBUtilities;
import org.apache.cassandra.utils.Pair;
/**
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/dht/RingPosition.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/dht/RingPosition.java b/src/java/org/apache/cassandra/dht/RingPosition.java
index 38281d6..8481b2c 100644
--- a/src/java/org/apache/cassandra/dht/RingPosition.java
+++ b/src/java/org/apache/cassandra/dht/RingPosition.java
@@ -17,15 +17,6 @@
*/
package org.apache.cassandra.dht;
-import java.io.DataInput;
-import java.io.DataOutput;
-import java.io.IOException;
-import java.nio.ByteBuffer;
-
-import org.apache.cassandra.db.DecoratedKey;
-import org.apache.cassandra.service.StorageService;
-import org.apache.cassandra.utils.ByteBufferUtil;
-
/**
* Interface representing a position on the ring.
* Both Token and DecoratedKey represent a position in the ring, a token being
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/gms/GossipDigestAck2Message.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/gms/GossipDigestAck2Message.java b/src/java/org/apache/cassandra/gms/GossipDigestAck2Message.java
index e448fdc..260cdcc 100644
--- a/src/java/org/apache/cassandra/gms/GossipDigestAck2Message.java
+++ b/src/java/org/apache/cassandra/gms/GossipDigestAck2Message.java
@@ -19,7 +19,6 @@ package org.apache.cassandra.gms;
import java.io.*;
import java.net.InetAddress;
-import java.util.HashMap;
import java.util.Map;
import org.apache.cassandra.io.IVersionedSerializer;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/gms/GossipDigestAckMessage.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/gms/GossipDigestAckMessage.java b/src/java/org/apache/cassandra/gms/GossipDigestAckMessage.java
index a8c59ec..de22794 100644
--- a/src/java/org/apache/cassandra/gms/GossipDigestAckMessage.java
+++ b/src/java/org/apache/cassandra/gms/GossipDigestAckMessage.java
@@ -19,8 +19,6 @@ package org.apache.cassandra.gms;
import java.io.*;
import java.net.InetAddress;
-import java.util.ArrayList;
-import java.util.HashMap;
import java.util.List;
import java.util.Map;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/gms/GossipDigestSynMessage.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/gms/GossipDigestSynMessage.java b/src/java/org/apache/cassandra/gms/GossipDigestSynMessage.java
index 6b871fe..54ae4e7 100644
--- a/src/java/org/apache/cassandra/gms/GossipDigestSynMessage.java
+++ b/src/java/org/apache/cassandra/gms/GossipDigestSynMessage.java
@@ -25,9 +25,6 @@ import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
import org.apache.cassandra.io.IVersionedSerializer;
import org.apache.cassandra.net.CompactEndpointSerializationHelper;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/gms/Gossiper.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/gms/Gossiper.java b/src/java/org/apache/cassandra/gms/Gossiper.java
index 0dad479..b166dd2 100644
--- a/src/java/org/apache/cassandra/gms/Gossiper.java
+++ b/src/java/org/apache/cassandra/gms/Gossiper.java
@@ -31,17 +31,14 @@ import javax.management.MBeanServer;
import javax.management.ObjectName;
import org.apache.cassandra.dht.Token;
-import org.apache.cassandra.db.SystemTable;
import org.apache.cassandra.io.util.FastByteArrayOutputStream;
import org.apache.cassandra.net.MessageProducer;
-import org.apache.cassandra.config.ConfigurationException;
import org.apache.cassandra.utils.FBUtilities;
import org.cliffc.high_scale_lib.NonBlockingHashMap;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.apache.cassandra.concurrent.DebuggableScheduledThreadPoolExecutor;
-import org.apache.cassandra.utils.FBUtilities;
import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.net.Message;
import org.apache.cassandra.net.MessagingService;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/hadoop/BulkOutputFormat.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/BulkOutputFormat.java b/src/java/org/apache/cassandra/hadoop/BulkOutputFormat.java
index 6656656..afa9e05 100644
--- a/src/java/org/apache/cassandra/hadoop/BulkOutputFormat.java
+++ b/src/java/org/apache/cassandra/hadoop/BulkOutputFormat.java
@@ -20,10 +20,7 @@ package org.apache.cassandra.hadoop;
import java.io.IOException;
import java.nio.ByteBuffer;
-import java.util.HashMap;
import java.util.List;
-import java.util.Map;
-
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java b/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java
index 6863676..79b1c85 100644
--- a/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java
+++ b/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java
@@ -27,7 +27,6 @@ import java.util.*;
import org.apache.cassandra.config.Config;
import org.apache.cassandra.config.DatabaseDescriptor;
-import org.apache.cassandra.db.IColumn;
import org.apache.cassandra.db.marshal.AbstractType;
import org.apache.cassandra.db.marshal.BytesType;
import org.apache.cassandra.dht.Range;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/hadoop/ColumnFamilyInputFormat.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/ColumnFamilyInputFormat.java b/src/java/org/apache/cassandra/hadoop/ColumnFamilyInputFormat.java
index 125eff8..028bff0 100644
--- a/src/java/org/apache/cassandra/hadoop/ColumnFamilyInputFormat.java
+++ b/src/java/org/apache/cassandra/hadoop/ColumnFamilyInputFormat.java
@@ -24,7 +24,6 @@ import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Random;
-import java.util.Set;
import java.util.SortedMap;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
@@ -42,7 +41,6 @@ import org.apache.cassandra.thrift.TokenRange;
import org.apache.commons.lang.StringUtils;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.mapred.*;
-import org.apache.hadoop.mapreduce.*;
import org.apache.hadoop.mapreduce.InputFormat;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.JobContext;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordWriter.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordWriter.java b/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordWriter.java
index 769b009..6b6d60b 100644
--- a/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordWriter.java
+++ b/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordWriter.java
@@ -30,7 +30,6 @@ import org.apache.cassandra.client.RingCache;
import org.apache.cassandra.dht.Range;
import org.apache.cassandra.dht.Token;
import org.apache.cassandra.thrift.*;
-import org.apache.cassandra.utils.ByteBufferUtil;
import org.apache.cassandra.utils.Pair;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.mapreduce.RecordWriter;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/io/compress/DeflateCompressor.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/io/compress/DeflateCompressor.java b/src/java/org/apache/cassandra/io/compress/DeflateCompressor.java
index 37ddb9e..fc7dee2 100644
--- a/src/java/org/apache/cassandra/io/compress/DeflateCompressor.java
+++ b/src/java/org/apache/cassandra/io/compress/DeflateCompressor.java
@@ -18,7 +18,6 @@
package org.apache.cassandra.io.compress;
import java.io.IOException;
-import java.util.HashMap;
import java.util.Map;
import java.util.zip.DataFormatException;
import java.util.zip.Deflater;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/io/compress/ICompressor.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/io/compress/ICompressor.java b/src/java/org/apache/cassandra/io/compress/ICompressor.java
index e65c527..9b189d9 100644
--- a/src/java/org/apache/cassandra/io/compress/ICompressor.java
+++ b/src/java/org/apache/cassandra/io/compress/ICompressor.java
@@ -18,7 +18,6 @@
package org.apache.cassandra.io.compress;
import java.io.IOException;
-import java.util.Map;
public interface ICompressor
{
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/io/sstable/Descriptor.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/io/sstable/Descriptor.java b/src/java/org/apache/cassandra/io/sstable/Descriptor.java
index 1bb8674..3c65208 100644
--- a/src/java/org/apache/cassandra/io/sstable/Descriptor.java
+++ b/src/java/org/apache/cassandra/io/sstable/Descriptor.java
@@ -18,15 +18,10 @@
package org.apache.cassandra.io.sstable;
import java.io.File;
-import java.io.IOException;
import java.util.StringTokenizer;
import com.google.common.base.Objects;
-import org.apache.cassandra.config.DatabaseDescriptor;
-import org.apache.cassandra.db.Directories;
-import org.apache.cassandra.db.Table;
-import org.apache.cassandra.io.util.FileUtils;
import org.apache.cassandra.utils.Pair;
import static org.apache.cassandra.io.sstable.Component.separator;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/io/sstable/IndexSummary.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/io/sstable/IndexSummary.java b/src/java/org/apache/cassandra/io/sstable/IndexSummary.java
index 610939c..ad738eb 100644
--- a/src/java/org/apache/cassandra/io/sstable/IndexSummary.java
+++ b/src/java/org/apache/cassandra/io/sstable/IndexSummary.java
@@ -22,7 +22,6 @@ import java.util.List;
import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.db.DecoratedKey;
-import org.apache.cassandra.db.RowPosition;
/**
* Two approaches to building an IndexSummary:
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/io/sstable/SSTable.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/io/sstable/SSTable.java b/src/java/org/apache/cassandra/io/sstable/SSTable.java
index 727cbe6..9269498 100644
--- a/src/java/org/apache/cassandra/io/sstable/SSTable.java
+++ b/src/java/org/apache/cassandra/io/sstable/SSTable.java
@@ -18,7 +18,6 @@
package org.apache.cassandra.io.sstable;
import java.io.File;
-import java.io.FileFilter;
import java.io.IOException;
import java.util.*;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/io/sstable/SSTableReader.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/io/sstable/SSTableReader.java b/src/java/org/apache/cassandra/io/sstable/SSTableReader.java
index 58c2d56..3f1c15f 100644
--- a/src/java/org/apache/cassandra/io/sstable/SSTableReader.java
+++ b/src/java/org/apache/cassandra/io/sstable/SSTableReader.java
@@ -24,9 +24,6 @@ import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.*;
-import com.google.common.base.Function;
-import com.google.common.collect.Collections2;
-
import org.apache.cassandra.cache.KeyCacheKey;
import org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor;
import org.apache.cassandra.config.ColumnDefinition;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/io/sstable/SSTableSimpleUnsortedWriter.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/io/sstable/SSTableSimpleUnsortedWriter.java b/src/java/org/apache/cassandra/io/sstable/SSTableSimpleUnsortedWriter.java
index 2312d4d..92ccb69 100644
--- a/src/java/org/apache/cassandra/io/sstable/SSTableSimpleUnsortedWriter.java
+++ b/src/java/org/apache/cassandra/io/sstable/SSTableSimpleUnsortedWriter.java
@@ -19,23 +19,15 @@ package org.apache.cassandra.io.sstable;
import java.io.File;
import java.io.IOException;
-import java.nio.ByteBuffer;
import java.util.Map;
import java.util.TreeMap;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.SynchronousQueue;
-import java.util.concurrent.locks.Condition;
-
import org.apache.cassandra.config.CFMetaData;
import org.apache.cassandra.db.*;
import org.apache.cassandra.db.marshal.AbstractType;
import org.apache.cassandra.dht.IPartitioner;
import org.apache.cassandra.io.compress.CompressionParameters;
-import org.apache.cassandra.service.StorageService;
-import org.apache.cassandra.utils.HeapAllocator;
-
-import org.apache.cassandra.utils.ByteBufferUtil;
-import org.apache.cassandra.utils.SimpleCondition;
/**
* A SSTable writer that doesn't assume rows are in sorted order.
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/io/util/ColumnSortedMap.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/io/util/ColumnSortedMap.java b/src/java/org/apache/cassandra/io/util/ColumnSortedMap.java
index 0d36a73..fa63567 100644
--- a/src/java/org/apache/cassandra/io/util/ColumnSortedMap.java
+++ b/src/java/org/apache/cassandra/io/util/ColumnSortedMap.java
@@ -24,7 +24,6 @@ import java.nio.ByteBuffer;
import java.util.*;
import java.util.Map.Entry;
-import org.apache.cassandra.db.ColumnFamilyStore;
import org.apache.cassandra.db.ColumnSerializer;
import org.apache.cassandra.db.IColumn;
import org.apache.cassandra.io.IColumnSerializer;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/locator/AbstractNetworkTopologySnitch.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/locator/AbstractNetworkTopologySnitch.java b/src/java/org/apache/cassandra/locator/AbstractNetworkTopologySnitch.java
index 58a3753..94199e6 100644
--- a/src/java/org/apache/cassandra/locator/AbstractNetworkTopologySnitch.java
+++ b/src/java/org/apache/cassandra/locator/AbstractNetworkTopologySnitch.java
@@ -19,7 +19,6 @@ package org.apache.cassandra.locator;
import java.net.InetAddress;
import java.net.UnknownHostException;
-import java.util.*;
/**
* An endpoint snitch tells Cassandra information about network topology that it can use to route
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java b/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java
index 8a28956..7b2ec91 100644
--- a/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java
+++ b/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java
@@ -21,15 +21,12 @@ import java.net.InetAddress;
import java.util.*;
import java.util.Map.Entry;
-import com.google.common.collect.Multimap;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.apache.cassandra.config.ConfigurationException;
import org.apache.cassandra.dht.Token;
-import org.apache.cassandra.service.*;
-import org.apache.cassandra.thrift.ConsistencyLevel;
import org.apache.cassandra.utils.FBUtilities;
import org.apache.cassandra.utils.Pair;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/locator/SimpleSnitch.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/locator/SimpleSnitch.java b/src/java/org/apache/cassandra/locator/SimpleSnitch.java
index 692a66f..27648c8 100644
--- a/src/java/org/apache/cassandra/locator/SimpleSnitch.java
+++ b/src/java/org/apache/cassandra/locator/SimpleSnitch.java
@@ -18,8 +18,6 @@
package org.apache.cassandra.locator;
import java.net.InetAddress;
-import java.util.ArrayList;
-import java.util.Collection;
import java.util.List;
/**
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/net/IncomingTcpConnection.java b/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
index c8c475e..510479c 100644
--- a/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
+++ b/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
@@ -19,7 +19,6 @@ package org.apache.cassandra.net;
import java.io.*;
import java.net.InetAddress;
-import java.net.InetSocketAddress;
import java.net.Socket;
import org.apache.cassandra.gms.Gossiper;
@@ -29,7 +28,6 @@ import org.slf4j.LoggerFactory;
import org.apache.cassandra.streaming.IncomingStreamReader;
import org.apache.cassandra.streaming.StreamHeader;
-import org.apache.cassandra.utils.FBUtilities;
public class IncomingTcpConnection extends Thread
{
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/net/MessagingService.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/net/MessagingService.java b/src/java/org/apache/cassandra/net/MessagingService.java
index ec51def..6789655 100644
--- a/src/java/org/apache/cassandra/net/MessagingService.java
+++ b/src/java/org/apache/cassandra/net/MessagingService.java
@@ -31,8 +31,6 @@ import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;
-import java.util.concurrent.locks.Lock;
-import java.util.concurrent.locks.ReentrantLock;
import javax.management.MBeanServer;
import javax.management.ObjectName;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/notifications/SSTableAddedNotification.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/notifications/SSTableAddedNotification.java b/src/java/org/apache/cassandra/notifications/SSTableAddedNotification.java
index 6d5dbbb..1f7ca54 100644
--- a/src/java/org/apache/cassandra/notifications/SSTableAddedNotification.java
+++ b/src/java/org/apache/cassandra/notifications/SSTableAddedNotification.java
@@ -19,8 +19,6 @@ package org.apache.cassandra.notifications;
import org.apache.cassandra.io.sstable.SSTableReader;
-import java.util.List;
-
public class SSTableAddedNotification implements INotification
{
public SSTableReader added;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/notifications/SSTableListChangedNotification.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/notifications/SSTableListChangedNotification.java b/src/java/org/apache/cassandra/notifications/SSTableListChangedNotification.java
index d043cbc..c363114 100644
--- a/src/java/org/apache/cassandra/notifications/SSTableListChangedNotification.java
+++ b/src/java/org/apache/cassandra/notifications/SSTableListChangedNotification.java
@@ -19,8 +19,6 @@ package org.apache.cassandra.notifications;
import org.apache.cassandra.io.sstable.SSTableReader;
-import java.util.List;
-
public class SSTableListChangedNotification implements INotification
{
public Iterable<SSTableReader> removed;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/service/AbstractWriteResponseHandler.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/AbstractWriteResponseHandler.java b/src/java/org/apache/cassandra/service/AbstractWriteResponseHandler.java
index 9f13e13..3f6742e 100644
--- a/src/java/org/apache/cassandra/service/AbstractWriteResponseHandler.java
+++ b/src/java/org/apache/cassandra/service/AbstractWriteResponseHandler.java
@@ -18,19 +18,14 @@
package org.apache.cassandra.service;
import java.net.InetAddress;
-import java.util.ArrayList;
import java.util.Collection;
-import java.util.List;
-import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
-import org.apache.cassandra.concurrent.CreationTimeAwareFuture;
import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.net.Message;
import org.apache.cassandra.thrift.ConsistencyLevel;
import org.apache.cassandra.thrift.UnavailableException;
-import org.apache.cassandra.utils.FBUtilities;
import org.apache.cassandra.utils.SimpleCondition;
public abstract class AbstractWriteResponseHandler implements IWriteResponseHandler
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/service/AntiEntropyService.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/AntiEntropyService.java b/src/java/org/apache/cassandra/service/AntiEntropyService.java
index 8b5c54d..7873173 100644
--- a/src/java/org/apache/cassandra/service/AntiEntropyService.java
+++ b/src/java/org/apache/cassandra/service/AntiEntropyService.java
@@ -43,7 +43,6 @@ import org.apache.cassandra.dht.RandomPartitioner;
import org.apache.cassandra.dht.Range;
import org.apache.cassandra.dht.Token;
import org.apache.cassandra.gms.*;
-import org.apache.cassandra.io.IVersionedSerializer;
import org.apache.cassandra.io.util.FastByteArrayInputStream;
import org.apache.cassandra.io.util.FastByteArrayOutputStream;
import org.apache.cassandra.net.CompactEndpointSerializationHelper;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/service/CacheService.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/CacheService.java b/src/java/org/apache/cassandra/service/CacheService.java
index 8878ee4..74f6ffd 100644
--- a/src/java/org/apache/cassandra/service/CacheService.java
+++ b/src/java/org/apache/cassandra/service/CacheService.java
@@ -20,7 +20,6 @@ package org.apache.cassandra.service;
import java.lang.management.ManagementFactory;
import java.util.ArrayList;
import java.util.List;
-import java.util.Set;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
@@ -30,9 +29,6 @@ import javax.management.ObjectName;
import org.apache.cassandra.cache.*;
import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.db.ColumnFamily;
-import org.apache.cassandra.db.ColumnFamilyStore;
-import org.apache.cassandra.db.DecoratedKey;
-import org.apache.cassandra.db.Table;
import org.apache.cassandra.utils.FBUtilities;
import org.slf4j.Logger;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/service/DatacenterReadCallback.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/DatacenterReadCallback.java b/src/java/org/apache/cassandra/service/DatacenterReadCallback.java
index 432eba5..1b59dae 100644
--- a/src/java/org/apache/cassandra/service/DatacenterReadCallback.java
+++ b/src/java/org/apache/cassandra/service/DatacenterReadCallback.java
@@ -22,10 +22,8 @@ import java.util.Collections;
import java.util.Comparator;
import java.util.List;
-import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.db.ReadResponse;
import org.apache.cassandra.db.Table;
-import org.apache.cassandra.locator.IEndpointSnitch;
import org.apache.cassandra.locator.NetworkTopologyStrategy;
import org.apache.cassandra.net.Message;
import org.apache.cassandra.thrift.ConsistencyLevel;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/service/IWriteResponseHandler.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/IWriteResponseHandler.java b/src/java/org/apache/cassandra/service/IWriteResponseHandler.java
index 2c960d7..330b51e 100644
--- a/src/java/org/apache/cassandra/service/IWriteResponseHandler.java
+++ b/src/java/org/apache/cassandra/service/IWriteResponseHandler.java
@@ -19,7 +19,6 @@ package org.apache.cassandra.service;
import java.util.concurrent.TimeoutException;
-import org.apache.cassandra.concurrent.CreationTimeAwareFuture;
import org.apache.cassandra.net.IAsyncCallback;
import org.apache.cassandra.thrift.UnavailableException;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/service/RangeSliceResponseResolver.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/RangeSliceResponseResolver.java b/src/java/org/apache/cassandra/service/RangeSliceResponseResolver.java
index e52729f..763a721 100644
--- a/src/java/org/apache/cassandra/service/RangeSliceResponseResolver.java
+++ b/src/java/org/apache/cassandra/service/RangeSliceResponseResolver.java
@@ -21,13 +21,10 @@ import java.io.IOException;
import java.net.InetAddress;
import java.util.*;
import java.util.concurrent.LinkedBlockingQueue;
-import java.util.concurrent.TimeUnit;
-
import com.google.common.collect.AbstractIterator;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.db.ColumnFamily;
import org.apache.cassandra.db.DecoratedKey;
import org.apache.cassandra.db.RangeSliceReply;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/service/StorageProxy.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/StorageProxy.java b/src/java/org/apache/cassandra/service/StorageProxy.java
index 936d94c..f2a41fd 100644
--- a/src/java/org/apache/cassandra/service/StorageProxy.java
+++ b/src/java/org/apache/cassandra/service/StorageProxy.java
@@ -39,7 +39,6 @@ import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.apache.cassandra.concurrent.CreationTimeAwareFuture;
import org.apache.cassandra.concurrent.Stage;
import org.apache.cassandra.concurrent.StageManager;
import org.apache.cassandra.config.DatabaseDescriptor;
@@ -47,7 +46,6 @@ import org.apache.cassandra.config.Schema;
import org.apache.cassandra.db.*;
import org.apache.cassandra.dht.AbstractBounds;
import org.apache.cassandra.dht.Bounds;
-import org.apache.cassandra.dht.IPartitioner;
import org.apache.cassandra.dht.RingPosition;
import org.apache.cassandra.dht.Token;
import org.apache.cassandra.gms.FailureDetector;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/service/StorageServiceMBean.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/StorageServiceMBean.java b/src/java/org/apache/cassandra/service/StorageServiceMBean.java
index 6dcdd2a..62f5196 100644
--- a/src/java/org/apache/cassandra/service/StorageServiceMBean.java
+++ b/src/java/org/apache/cassandra/service/StorageServiceMBean.java
@@ -19,7 +19,6 @@ package org.apache.cassandra.service;
import java.io.IOException;
import java.net.InetAddress;
-import java.net.UnknownHostException;
import java.nio.ByteBuffer;
import java.util.List;
import java.util.Map;
@@ -27,10 +26,7 @@ import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeoutException;
import org.apache.cassandra.config.ConfigurationException;
-import org.apache.cassandra.dht.Range;
-import org.apache.cassandra.dht.Token;
import org.apache.cassandra.thrift.InvalidRequestException;
-import org.apache.cassandra.thrift.TokenRange;
import org.apache.cassandra.thrift.UnavailableException;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/streaming/FileStreamTask.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/streaming/FileStreamTask.java b/src/java/org/apache/cassandra/streaming/FileStreamTask.java
index 074540f..7251387 100644
--- a/src/java/org/apache/cassandra/streaming/FileStreamTask.java
+++ b/src/java/org/apache/cassandra/streaming/FileStreamTask.java
@@ -30,7 +30,6 @@ import org.apache.cassandra.io.util.FileUtils;
import org.apache.cassandra.net.Header;
import org.apache.cassandra.net.Message;
import org.apache.cassandra.net.MessagingService;
-import org.apache.cassandra.net.OutboundTcpConnection;
import org.apache.cassandra.service.StorageService;
import org.apache.cassandra.utils.ByteBufferUtil;
import org.apache.cassandra.utils.Pair;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/streaming/StreamIn.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/streaming/StreamIn.java b/src/java/org/apache/cassandra/streaming/StreamIn.java
index 8ac0e5c..3b2c0be 100644
--- a/src/java/org/apache/cassandra/streaming/StreamIn.java
+++ b/src/java/org/apache/cassandra/streaming/StreamIn.java
@@ -20,11 +20,6 @@ package org.apache.cassandra.streaming;
import java.io.IOException;
import java.net.InetAddress;
import java.util.Collection;
-import java.util.Collections;
-import java.util.ArrayList;
-import java.util.List;
-
-import org.apache.cassandra.db.ColumnFamily;
import org.apache.cassandra.gms.Gossiper;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/thrift/CassandraDaemon.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/thrift/CassandraDaemon.java b/src/java/org/apache/cassandra/thrift/CassandraDaemon.java
index 9af105e..80cca29 100644
--- a/src/java/org/apache/cassandra/thrift/CassandraDaemon.java
+++ b/src/java/org/apache/cassandra/thrift/CassandraDaemon.java
@@ -22,7 +22,6 @@ import java.net.InetSocketAddress;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.ExecutorService;
-import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.TimeUnit;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/thrift/CustomTThreadPoolServer.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/thrift/CustomTThreadPoolServer.java b/src/java/org/apache/cassandra/thrift/CustomTThreadPoolServer.java
index 84bb91e..f34a72b 100644
--- a/src/java/org/apache/cassandra/thrift/CustomTThreadPoolServer.java
+++ b/src/java/org/apache/cassandra/thrift/CustomTThreadPoolServer.java
@@ -19,7 +19,6 @@ package org.apache.cassandra.thrift;
import java.net.SocketTimeoutException;
import java.util.concurrent.ExecutorService;
-import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import org.slf4j.Logger;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/thrift/TCustomServerSocket.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/thrift/TCustomServerSocket.java b/src/java/org/apache/cassandra/thrift/TCustomServerSocket.java
index 9625044..57bd495 100644
--- a/src/java/org/apache/cassandra/thrift/TCustomServerSocket.java
+++ b/src/java/org/apache/cassandra/thrift/TCustomServerSocket.java
@@ -27,9 +27,7 @@ import java.net.SocketException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.apache.thrift.transport.TServerSocket;
import org.apache.thrift.transport.TServerTransport;
-import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransportException;
/**
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/tools/BulkLoader.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/tools/BulkLoader.java b/src/java/org/apache/cassandra/tools/BulkLoader.java
index 15c9583..691e074 100644
--- a/src/java/org/apache/cassandra/tools/BulkLoader.java
+++ b/src/java/org/apache/cassandra/tools/BulkLoader.java
@@ -23,17 +23,13 @@ import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.*;
-import org.apache.cassandra.config.CFMetaData;
import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.dht.Range;
import org.apache.cassandra.dht.Token;
import org.apache.cassandra.io.sstable.SSTableLoader;
import org.apache.cassandra.streaming.PendingFile;
import org.apache.cassandra.thrift.*;
-import org.apache.cassandra.utils.FBUtilities;
-
import org.apache.commons.cli.*;
-import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TFramedTransport;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/tools/NodeCmd.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/tools/NodeCmd.java b/src/java/org/apache/cassandra/tools/NodeCmd.java
index 5a1b0b0..264249c 100644
--- a/src/java/org/apache/cassandra/tools/NodeCmd.java
+++ b/src/java/org/apache/cassandra/tools/NodeCmd.java
@@ -33,9 +33,7 @@ import org.apache.commons.cli.*;
import org.apache.cassandra.concurrent.JMXEnabledThreadPoolExecutorMBean;
import org.apache.cassandra.config.ConfigurationException;
import org.apache.cassandra.db.ColumnFamilyStoreMBean;
-import org.apache.cassandra.db.compaction.CompactionInfo;
import org.apache.cassandra.db.compaction.CompactionManagerMBean;
-import org.apache.cassandra.dht.Token;
import org.apache.cassandra.net.MessagingServiceMBean;
import org.apache.cassandra.thrift.InvalidRequestException;
import org.apache.cassandra.utils.EstimatedHistogram;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/tools/NodeProbe.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/tools/NodeProbe.java b/src/java/org/apache/cassandra/tools/NodeProbe.java
index ad1699d..5760d11 100644
--- a/src/java/org/apache/cassandra/tools/NodeProbe.java
+++ b/src/java/org/apache/cassandra/tools/NodeProbe.java
@@ -44,7 +44,6 @@ import org.apache.cassandra.config.ConfigurationException;
import org.apache.cassandra.db.ColumnFamilyStoreMBean;
import org.apache.cassandra.db.compaction.CompactionManager;
import org.apache.cassandra.db.compaction.CompactionManagerMBean;
-import org.apache.cassandra.dht.Token;
import org.apache.cassandra.gms.FailureDetector;
import org.apache.cassandra.gms.FailureDetectorMBean;
import org.apache.cassandra.locator.EndpointSnitchInfoMBean;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/utils/FBUtilities.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/utils/FBUtilities.java b/src/java/org/apache/cassandra/utils/FBUtilities.java
index 500bdff..811cff0 100644
--- a/src/java/org/apache/cassandra/utils/FBUtilities.java
+++ b/src/java/org/apache/cassandra/utils/FBUtilities.java
@@ -32,12 +32,8 @@ import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
-import java.util.concurrent.atomic.AtomicInteger;
-import java.util.concurrent.atomic.AtomicLong;
-
import com.google.common.base.Joiner;
import com.google.common.collect.AbstractIterator;
-import com.google.common.primitives.Ints;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/utils/LegacyBloomFilter.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/utils/LegacyBloomFilter.java b/src/java/org/apache/cassandra/utils/LegacyBloomFilter.java
index 8cbf660..cf61718 100644
--- a/src/java/org/apache/cassandra/utils/LegacyBloomFilter.java
+++ b/src/java/org/apache/cassandra/utils/LegacyBloomFilter.java
@@ -20,7 +20,6 @@ package org.apache.cassandra.utils;
import java.nio.ByteBuffer;
import java.util.BitSet;
-import org.apache.cassandra.io.IVersionedSerializer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/utils/LegacyBloomFilterSerializer.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/utils/LegacyBloomFilterSerializer.java b/src/java/org/apache/cassandra/utils/LegacyBloomFilterSerializer.java
index 9bf9a2b..a556876 100644
--- a/src/java/org/apache/cassandra/utils/LegacyBloomFilterSerializer.java
+++ b/src/java/org/apache/cassandra/utils/LegacyBloomFilterSerializer.java
@@ -20,8 +20,6 @@ package org.apache.cassandra.utils;
import java.io.*;
import java.util.BitSet;
-import org.apache.cassandra.io.IVersionedSerializer;
-
public class LegacyBloomFilterSerializer
{
public void serialize(LegacyBloomFilter bf, DataOutput dos)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/src/java/org/apache/cassandra/utils/SlabAllocator.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/utils/SlabAllocator.java b/src/java/org/apache/cassandra/utils/SlabAllocator.java
index ffff688..dd7799a 100644
--- a/src/java/org/apache/cassandra/utils/SlabAllocator.java
+++ b/src/java/org/apache/cassandra/utils/SlabAllocator.java
@@ -18,15 +18,10 @@
package org.apache.cassandra.utils;
import java.nio.ByteBuffer;
-import java.util.Collection;
-import java.util.Collections;
-import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;
import com.google.common.base.Preconditions;
-import com.google.common.collect.Iterables;
-import com.google.common.collect.MapMaker;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/test/long/org/apache/cassandra/db/compaction/LongCompactionSpeedTest.java
----------------------------------------------------------------------
diff --git a/test/long/org/apache/cassandra/db/compaction/LongCompactionSpeedTest.java b/test/long/org/apache/cassandra/db/compaction/LongCompactionSpeedTest.java
index ee65d5a..cc305ce 100644
--- a/test/long/org/apache/cassandra/db/compaction/LongCompactionSpeedTest.java
+++ b/test/long/org/apache/cassandra/db/compaction/LongCompactionSpeedTest.java
@@ -28,8 +28,6 @@ import org.apache.cassandra.db.*;
import org.apache.cassandra.io.sstable.SSTableReader;
import org.apache.cassandra.io.sstable.SSTableUtils;
-import static junit.framework.Assert.assertEquals;
-
public class LongCompactionSpeedTest extends CleanupHelper
{
public static final String TABLE1 = "Keyspace1";
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37f6a9f1/test/long/org/apache/cassandra/utils/LongBloomFilterTest.java
----------------------------------------------------------------------
diff --git a/test/long/org/apache/cassandra/utils/LongBloomFilterTest.java b/test/long/org/apache/cassandra/utils/LongBloomFilterTest.java
index b88f74f..e5a9e22 100644
--- a/test/long/org/apache/cassandra/utils/LongBloomFilterTest.java
+++ b/test/long/org/apache/cassandra/utils/LongBloomFilterTest.java
@@ -18,7 +18,6 @@
*/
package org.apache.cassandra.utils;
-import java.io.IOException;
import java.util.Random;
import org.junit.Test;