cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From slebre...@apache.org
Subject [1/28] git commit: [3649] Strip end of line whitespace
Date Mon, 27 Feb 2012 10:15:59 GMT
Updated Branches:
  refs/heads/trunk cbd46f11c -> 2fd3268b4


[3649] Strip end of line whitespace


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/2fd3268b
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/2fd3268b
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/2fd3268b

Branch: refs/heads/trunk
Commit: 2fd3268b4841ff14d1c27bdcb4f80efc4174ffd0
Parents: 5a6e2b0
Author: Sylvain Lebresne <sylvain@datastax.com>
Authored: Fri Feb 24 18:50:13 2012 +0100
Committer: Sylvain Lebresne <sylvain@datastax.com>
Committed: Mon Feb 27 11:01:07 2012 +0100

----------------------------------------------------------------------
 .../cassandra/auth/AllowAllAuthenticator.java      |    2 +-
 src/java/org/apache/cassandra/auth/IAuthority.java |    8 +-
 .../apache/cassandra/cache/AutoSavingCache.java    |    2 +-
 .../apache/cassandra/cache/SerializingCache.java   |    2 +-
 src/java/org/apache/cassandra/cli/CliClient.java   |  144 ++++++------
 src/java/org/apache/cassandra/cli/CliCompiler.java |   16 +-
 .../org/apache/cassandra/cli/CliCompleter.java     |    4 +-
 src/java/org/apache/cassandra/cli/CliMain.java     |   20 +-
 .../org/apache/cassandra/cli/CliSessionState.java  |    4 +-
 .../org/apache/cassandra/client/RingCache.java     |    4 +-
 .../concurrent/CreationTimeAwareFuture.java        |    8 +-
 .../JMXConfigurableThreadPoolExecutor.java         |    6 +-
 .../concurrent/JMXEnabledThreadPoolExecutor.java   |    4 +-
 .../cassandra/concurrent/NamedThreadFactory.java   |    6 +-
 .../apache/cassandra/concurrent/StageManager.java  |    6 +-
 .../org/apache/cassandra/config/CFMetaData.java    |   14 +-
 .../apache/cassandra/config/ColumnDefinition.java  |   24 +-
 src/java/org/apache/cassandra/config/Config.java   |   28 ++--
 .../cassandra/config/DatabaseDescriptor.java       |   26 +-
 .../apache/cassandra/config/SeedProviderDef.java   |    2 +-
 .../org/apache/cassandra/cql/CQLStatement.java     |    2 +-
 .../cassandra/cql/CreateColumnFamilyStatement.java |   20 +-
 .../apache/cassandra/cql/CreateIndexStatement.java |    8 +-
 .../cassandra/cql/CreateKeyspaceStatement.java     |   14 +-
 .../org/apache/cassandra/cql/DeleteStatement.java  |    2 +-
 .../org/apache/cassandra/cql/QueryProcessor.java   |   90 ++++----
 src/java/org/apache/cassandra/cql/Relation.java    |   16 +-
 .../org/apache/cassandra/cql/SelectExpression.java |   28 ++--
 .../org/apache/cassandra/cql/SelectStatement.java  |   28 ++--
 .../org/apache/cassandra/cql/StatementType.java    |    2 +-
 src/java/org/apache/cassandra/cql/Term.java        |   36 ++--
 .../org/apache/cassandra/cql/UpdateStatement.java  |   28 ++--
 src/java/org/apache/cassandra/cql/WhereClause.java |   16 +-
 .../cassandra/cql/jdbc/AbstractJdbcUUID.java       |    2 +-
 .../org/apache/cassandra/cql/jdbc/JdbcAscii.java   |    6 +-
 .../org/apache/cassandra/cql/jdbc/JdbcBoolean.java |    8 +-
 .../org/apache/cassandra/cql/jdbc/JdbcBytes.java   |    4 +-
 .../cassandra/cql/jdbc/JdbcCounterColumn.java      |    2 +-
 .../org/apache/cassandra/cql/jdbc/JdbcDate.java    |   10 +-
 .../org/apache/cassandra/cql/jdbc/JdbcDecimal.java |   10 +-
 .../org/apache/cassandra/cql/jdbc/JdbcDouble.java  |    8 +-
 .../org/apache/cassandra/cql/jdbc/JdbcFloat.java   |    8 +-
 .../org/apache/cassandra/cql/jdbc/JdbcInteger.java |    4 +-
 .../apache/cassandra/cql/jdbc/JdbcLexicalUUID.java |    4 +-
 .../apache/cassandra/cql/jdbc/JdbcTimeUUID.java    |    4 +-
 .../org/apache/cassandra/cql/jdbc/JdbcUTF8.java    |    4 +-
 .../org/apache/cassandra/cql/jdbc/JdbcUUID.java    |    6 +-
 .../org/apache/cassandra/cql/jdbc/TypesMap.java    |    4 +-
 .../statements/CreateColumnFamilyStatement.java    |    2 +-
 .../apache/cassandra/db/CollationController.java   |    2 +-
 src/java/org/apache/cassandra/db/Column.java       |    2 +-
 src/java/org/apache/cassandra/db/ColumnFamily.java |    2 +-
 .../org/apache/cassandra/db/ColumnFamilyStore.java |   18 +-
 .../org/apache/cassandra/db/ColumnSerializer.java  |    2 +-
 .../org/apache/cassandra/db/DeletedColumn.java     |    4 +-
 .../org/apache/cassandra/db/ExpiringColumn.java    |    4 +-
 src/java/org/apache/cassandra/db/Memtable.java     |    2 +-
 .../org/apache/cassandra/db/RangeSliceCommand.java |    2 +-
 src/java/org/apache/cassandra/db/ReadCommand.java  |    4 +-
 .../apache/cassandra/db/ReadRepairVerbHandler.java |    6 +-
 src/java/org/apache/cassandra/db/ReadResponse.java |    6 +-
 .../apache/cassandra/db/RowIteratorFactory.java    |    2 +-
 .../cassandra/db/RowMutationVerbHandler.java       |    6 +-
 .../cassandra/db/SchemaCheckVerbHandler.java       |    2 +-
 .../cassandra/db/SliceByNamesReadCommand.java      |    2 +-
 src/java/org/apache/cassandra/db/SystemTable.java  |   14 +-
 src/java/org/apache/cassandra/db/Table.java        |   20 +-
 .../db/UnserializableColumnFamilyException.java    |    2 +-
 .../org/apache/cassandra/db/WriteResponse.java     |    6 +-
 .../apache/cassandra/db/commitlog/CommitLog.java   |   14 +-
 .../cassandra/db/commitlog/CommitLogAllocator.java |    4 +-
 .../cassandra/db/commitlog/CommitLogSegment.java   |    8 +-
 .../cassandra/db/compaction/CompactionManager.java |   16 +-
 .../cassandra/db/filter/NamesQueryFilter.java      |    2 +-
 .../org/apache/cassandra/db/filter/QueryPath.java  |    4 +-
 .../cassandra/db/filter/SliceQueryFilter.java      |    6 +-
 .../db/index/PerColumnSecondaryIndex.java          |   14 +-
 .../cassandra/db/index/PerRowSecondaryIndex.java   |   16 +-
 .../apache/cassandra/db/index/SecondaryIndex.java  |   80 ++++----
 .../cassandra/db/index/SecondaryIndexBuilder.java  |    2 +-
 .../cassandra/db/index/SecondaryIndexManager.java  |  180 +++++++-------
 .../cassandra/db/index/SecondaryIndexSearcher.java |    2 +-
 .../apache/cassandra/db/index/keys/KeysIndex.java  |   22 +-
 .../cassandra/db/index/keys/KeysSearcher.java      |    6 +-
 .../apache/cassandra/db/marshal/AbstractType.java  |    4 +-
 .../apache/cassandra/db/marshal/BooleanType.java   |   10 +-
 .../org/apache/cassandra/db/marshal/BytesType.java |    4 +-
 .../org/apache/cassandra/db/marshal/DateType.java  |   12 +-
 .../apache/cassandra/db/marshal/DecimalType.java   |    6 +-
 .../apache/cassandra/db/marshal/DoubleType.java    |   14 +-
 .../org/apache/cassandra/db/marshal/FloatType.java |   12 +-
 .../org/apache/cassandra/db/marshal/Int32Type.java |    4 +-
 .../apache/cassandra/db/marshal/IntegerType.java   |    2 +-
 .../org/apache/cassandra/db/marshal/LongType.java  |    4 +-
 .../apache/cassandra/db/marshal/TimeUUIDType.java  |    8 +-
 .../org/apache/cassandra/db/marshal/UTF8Type.java  |   10 +-
 .../org/apache/cassandra/db/marshal/UUIDType.java  |    2 +-
 .../cassandra/db/migration/AddColumnFamily.java    |    2 +-
 .../apache/cassandra/db/migration/AddKeyspace.java |    2 +-
 .../cassandra/db/migration/DropColumnFamily.java   |    2 +-
 .../cassandra/db/migration/DropKeyspace.java       |    4 +-
 .../apache/cassandra/db/migration/Migration.java   |    6 +-
 .../org/apache/cassandra/dht/BootStrapper.java     |    6 +-
 src/java/org/apache/cassandra/dht/BytesToken.java  |    6 +-
 .../org/apache/cassandra/dht/IPartitioner.java     |    6 +-
 .../cassandra/dht/OrderPreservingPartitioner.java  |    2 +-
 .../apache/cassandra/dht/RandomPartitioner.java    |    2 +-
 .../org/apache/cassandra/gms/EndpointState.java    |   22 +-
 .../org/apache/cassandra/gms/FailureDetector.java  |   48 ++--
 .../org/apache/cassandra/gms/GossipDigest.java     |   20 +-
 .../cassandra/gms/GossipDigestAck2Message.java     |   10 +-
 .../cassandra/gms/GossipDigestAckMessage.java      |   10 +-
 .../cassandra/gms/GossipDigestSynMessage.java      |   24 +-
 src/java/org/apache/cassandra/gms/Gossiper.java    |   34 ++--
 .../org/apache/cassandra/gms/HeartBeatState.java   |   14 +-
 .../gms/IEndpointStateChangeSubscriber.java        |    4 +-
 .../gms/IFailureDetectionEventListener.java        |    2 +-
 .../org/apache/cassandra/gms/IFailureDetector.java |   26 +-
 .../apache/cassandra/gms/IFailureNotification.java |    2 +-
 .../org/apache/cassandra/gms/VersionGenerator.java |    4 +-
 .../org/apache/cassandra/gms/VersionedValue.java   |    6 +-
 .../apache/cassandra/hadoop/BulkOutputFormat.java  |    4 +-
 .../apache/cassandra/hadoop/BulkRecordWriter.java  |    2 +-
 .../cassandra/hadoop/ColumnFamilyInputFormat.java  |    4 +-
 .../cassandra/hadoop/ColumnFamilyOutputFormat.java |   14 +-
 .../cassandra/hadoop/ColumnFamilyRecordReader.java |   34 ++--
 .../cassandra/hadoop/ColumnFamilyRecordWriter.java |   18 +-
 .../apache/cassandra/hadoop/ColumnFamilySplit.java |    2 +-
 .../org/apache/cassandra/hadoop/ConfigHelper.java  |   16 +-
 .../cassandra/hadoop/pig/CassandraStorage.java     |    6 +-
 .../io/compress/CompressedSequentialWriter.java    |    4 +-
 .../org/apache/cassandra/io/sstable/Component.java |    2 +-
 .../apache/cassandra/io/sstable/Descriptor.java    |    2 +-
 .../cassandra/io/sstable/SSTableMetadata.java      |    4 +-
 .../apache/cassandra/io/sstable/SSTableWriter.java |    2 +-
 .../apache/cassandra/io/util/DataOutputBuffer.java |    8 +-
 .../io/util/FastByteArrayInputStream.java          |   22 +-
 .../io/util/FastByteArrayOutputStream.java         |   24 +-
 .../org/apache/cassandra/io/util/FileUtils.java    |    8 +-
 .../cassandra/io/util/MemoryInputStream.java       |   12 +-
 .../cassandra/io/util/MemoryOutputStream.java      |    6 +-
 .../org/apache/cassandra/io/util/OutputBuffer.java |    6 +-
 .../cassandra/locator/DynamicEndpointSnitch.java   |    4 +-
 .../cassandra/locator/Ec2MultiRegionSnitch.java    |   14 +-
 .../org/apache/cassandra/locator/Ec2Snitch.java    |    2 +-
 .../cassandra/locator/EndpointSnitchInfoMBean.java |    2 +-
 .../cassandra/locator/SimpleSeedProvider.java      |    8 +-
 .../apache/cassandra/locator/TokenMetadata.java    |    4 +-
 src/java/org/apache/cassandra/net/AsyncResult.java |   16 +-
 .../cassandra/net/CachingMessageProducer.java      |    2 +-
 .../org/apache/cassandra/net/CallbackInfo.java     |    2 +-
 .../net/CompactEndpointSerializationHelper.java    |    4 +-
 src/java/org/apache/cassandra/net/Header.java      |    8 +-
 src/java/org/apache/cassandra/net/HeaderTypes.java |    2 +-
 .../org/apache/cassandra/net/IAsyncResult.java     |    4 +-
 .../cassandra/net/IncomingTcpConnection.java       |   12 +-
 src/java/org/apache/cassandra/net/Message.java     |   12 +-
 .../org/apache/cassandra/net/MessagingService.java |    4 +-
 .../cassandra/net/OutboundTcpConnection.java       |    2 +-
 .../cassandra/net/OutboundTcpConnectionPool.java   |    8 +-
 .../apache/cassandra/net/ResponseVerbHandler.java  |    2 +-
 .../cassandra/scheduler/IRequestScheduler.java     |    2 +-
 .../apache/cassandra/scheduler/NoScheduler.java    |    2 +-
 .../cassandra/scheduler/RoundRobinScheduler.java   |    6 +-
 .../org/apache/cassandra/security/SSLFactory.java  |    2 +-
 .../cassandra/service/AbstractCassandraDaemon.java |   38 ++--
 .../cassandra/service/AntiEntropyService.java      |   20 +-
 .../apache/cassandra/service/CassandraDaemon.java  |   17 +-
 .../org/apache/cassandra/service/ClientState.java  |   12 +-
 .../cassandra/service/DatacenterReadCallback.java  |    2 +-
 .../service/DatacenterWriteResponseHandler.java    |    2 +-
 .../org/apache/cassandra/service/GCInspector.java  |   10 +-
 .../org/apache/cassandra/service/StorageProxy.java |   16 +-
 .../apache/cassandra/service/StorageService.java   |   20 +-
 .../cassandra/service/StorageServiceMBean.java     |    6 +-
 .../apache/cassandra/streaming/FileStreamTask.java |    4 +-
 .../apache/cassandra/streaming/PendingFile.java    |    8 +-
 .../apache/cassandra/streaming/StreamHeader.java   |    2 +-
 .../cassandra/streaming/StreamOutSession.java      |    4 +-
 .../cassandra/streaming/StreamRequestMessage.java  |    8 +-
 .../streaming/StreamRequestVerbHandler.java        |    2 +-
 .../cassandra/streaming/StreamingService.java      |    2 +-
 .../cassandra/streaming/StreamingServiceMBean.java |    2 +-
 .../apache/cassandra/thrift/CassandraDaemon.java   |   28 ++--
 .../apache/cassandra/thrift/CassandraServer.java   |   56 +++---
 .../apache/cassandra/thrift/CustomTHsHaServer.java |   26 +-
 .../cassandra/thrift/CustomTThreadPoolServer.java  |    6 +-
 .../thrift/TCustomNonblockingServerSocket.java     |    2 +-
 .../cassandra/thrift/TCustomServerSocket.java      |    2 +-
 .../org/apache/cassandra/thrift/TCustomSocket.java |   48 ++--
 .../apache/cassandra/thrift/ThriftValidation.java  |    8 +-
 src/java/org/apache/cassandra/tools/NodeCmd.java   |   46 ++--
 src/java/org/apache/cassandra/tools/NodeProbe.java |   44 ++--
 .../org/apache/cassandra/tools/SSTableExport.java  |   16 +-
 .../org/apache/cassandra/tools/SSTableImport.java  |   10 +-
 src/java/org/apache/cassandra/utils/Allocator.java |    2 +-
 .../org/apache/cassandra/utils/ByteBufferUtil.java |   38 ++--
 src/java/org/apache/cassandra/utils/CLibrary.java  |    2 +-
 .../org/apache/cassandra/utils/DefaultDouble.java  |   10 +-
 .../org/apache/cassandra/utils/DefaultInteger.java |   12 +-
 .../apache/cassandra/utils/EstimatedHistogram.java |    6 +-
 .../org/apache/cassandra/utils/FBUtilities.java    |    4 +-
 .../cassandra/utils/FastByteComparisons.java       |    6 +-
 .../org/apache/cassandra/utils/GuidGenerator.java  |    6 +-
 src/java/org/apache/cassandra/utils/Hex.java       |    8 +-
 .../org/apache/cassandra/utils/MerkleTree.java     |   42 ++--
 .../org/apache/cassandra/utils/MurmurHash.java     |    4 +-
 src/java/org/apache/cassandra/utils/Pair.java      |    4 +-
 .../org/apache/cassandra/utils/PureJavaCrc32.java  |    2 +-
 .../apache/cassandra/utils/ResourceWatcher.java    |    2 +-
 .../apache/cassandra/utils/SimpleCondition.java    |    2 +-
 .../cassandra/utils/SkipNullRepresenter.java       |    8 +-
 .../org/apache/cassandra/utils/SlabAllocator.java  |    2 +-
 .../org/apache/cassandra/utils/StatusLogger.java   |    2 +-
 src/java/org/apache/cassandra/utils/Throttle.java  |    2 +-
 src/java/org/apache/cassandra/utils/UUIDGen.java   |   52 ++--
 .../org/apache/cassandra/utils/obs/OpenBitSet.java |   16 +-
 .../apache/cassandra/db/MeteredFlusherTest.java    |    8 +-
 .../cassandra/AbstractSerializationsTester.java    |   18 +-
 test/unit/org/apache/cassandra/EmbeddedServer.java |   12 +-
 test/unit/org/apache/cassandra/SchemaLoader.java   |    6 +-
 test/unit/org/apache/cassandra/Util.java           |   12 +-
 .../apache/cassandra/cache/CacheProviderTest.java  |   12 +-
 test/unit/org/apache/cassandra/cli/CliTest.java    |    2 +-
 .../org/apache/cassandra/client/TestRingCache.java |    6 +-
 .../DebuggableThreadPoolExecutorTest.java          |    8 +-
 .../cassandra/config/ColumnDefinitionTest.java     |    8 +-
 .../cassandra/config/DatabaseDescriptorTest.java   |    2 +-
 .../apache/cassandra/cql/jdbc/ClientUtilsTest.java |    8 +-
 .../cassandra/db/ArrayBackedSortedColumnsTest.java |    8 +-
 .../apache/cassandra/db/ColumnFamilyStoreTest.java |  104 ++++----
 .../org/apache/cassandra/db/CommitLogTest.java     |    4 +-
 test/unit/org/apache/cassandra/db/DefsTest.java    |   82 ++++----
 .../unit/org/apache/cassandra/db/KeyCacheTest.java |    8 +-
 .../org/apache/cassandra/db/MultitableTest.java    |    8 +-
 .../org/apache/cassandra/db/ReadMessageTest.java   |   34 ++--
 .../apache/cassandra/db/RecoveryManager2Test.java  |    8 +-
 .../apache/cassandra/db/RecoveryManager3Test.java  |    8 +-
 test/unit/org/apache/cassandra/db/ScrubTest.java   |   40 ++--
 .../apache/cassandra/db/SerializationsTest.java    |   80 ++++----
 .../org/apache/cassandra/db/SuperColumnTest.java   |    4 +-
 .../org/apache/cassandra/db/SystemTableTest.java   |    8 +-
 test/unit/org/apache/cassandra/db/TableTest.java   |   34 ++--
 .../cassandra/db/context/CounterContextTest.java   |   12 +-
 .../cassandra/db/marshal/DecimalTypeTest.java      |   28 ++--
 .../apache/cassandra/db/marshal/RoundTripTest.java |   30 ++--
 .../cassandra/db/marshal/TimeUUIDTypeTest.java     |   12 +-
 .../cassandra/db/marshal/TypeCompareTest.java      |   12 +-
 .../cassandra/db/marshal/TypeValidationTest.java   |   34 ++--
 .../apache/cassandra/db/marshal/UUIDTypeTest.java  |    8 +-
 .../org/apache/cassandra/dht/BootStrapperTest.java |   30 ++--
 .../apache/cassandra/dht/PartitionerTestCase.java  |    6 +-
 .../cassandra/dht/RandomPartitionerTest.java       |    8 +-
 .../apache/cassandra/gms/ArrivalWindowTest.java    |   12 +-
 .../org/apache/cassandra/gms/GossipDigestTest.java |   12 +-
 .../apache/cassandra/gms/SerializationsTest.java   |   26 +-
 .../hadoop/ColumnFamilyInputFormatTest.java        |    8 +-
 .../cassandra/io/BloomFilterTrackerTest.java       |    8 +-
 .../apache/cassandra/io/CompactSerializerTest.java |   24 +-
 .../cassandra/io/LazilyCompactedRowTest.java       |    8 +-
 .../cassandra/io/sstable/DescriptorTest.java       |    8 +-
 .../cassandra/io/sstable/SSTableReaderTest.java    |    8 +-
 .../apache/cassandra/locator/EC2SnitchTest.java    |   14 +-
 .../cassandra/locator/SimpleStrategyTest.java      |    6 +-
 .../apache/cassandra/net/MessageSerializer.java    |    8 +-
 .../service/AntiEntropyServiceCounterTest.java     |    8 +-
 .../service/AntiEntropyServiceStandardTest.java    |    8 +-
 .../service/AntiEntropyServiceTestAbstract.java    |    6 +-
 .../service/EmbeddedCassandraServiceTest.java      |    2 +-
 .../apache/cassandra/service/InitClientTest.java   |    2 +-
 .../apache/cassandra/service/RowResolverTest.java  |    8 +-
 .../cassandra/service/SerializationsTest.java      |   20 +-
 .../cassandra/streaming/SerializationsTest.java    |   36 ++--
 .../org/apache/cassandra/streaming/StreamUtil.java |    4 +-
 .../cassandra/streaming/StreamingTransferTest.java |    8 +-
 .../cassandra/thrift/ThriftValidationTest.java     |    8 +-
 .../apache/cassandra/tools/SSTableExportTest.java  |   40 ++--
 .../apache/cassandra/tools/SSTableImportTest.java  |    4 +-
 .../cassandra/utils/BoundedStatsDequeTest.java     |   18 +-
 .../apache/cassandra/utils/FBUtilitiesTest.java    |    4 +-
 test/unit/org/apache/cassandra/utils/HexTest.java  |    2 +-
 .../org/apache/cassandra/utils/IntervalTest.java   |    8 +-
 .../apache/cassandra/utils/IntervalTreeTest.java   |    8 +-
 .../cassandra/utils/LegacyBloomFilterTest.java     |    2 +-
 .../apache/cassandra/utils/MergeIteratorTest.java  |    6 +-
 .../org/apache/cassandra/utils/MerkleTreeTest.java |   30 ++--
 .../apache/cassandra/utils/SerializationsTest.java |   30 ++--
 .../unit/org/apache/cassandra/utils/UUIDTests.java |   10 +-
 .../stress/operations/CqlCounterAdder.java         |    8 +-
 .../stress/operations/CqlCounterGetter.java        |    8 +-
 .../stress/operations/CqlIndexedRangeSlicer.java   |    8 +-
 .../cassandra/stress/operations/CqlInserter.java   |   20 +-
 .../stress/operations/CqlMultiGetter.java          |    8 +-
 .../stress/operations/CqlRangeSlicer.java          |   12 +-
 .../cassandra/stress/operations/CqlReader.java     |    8 +-
 295 files changed, 1883 insertions(+), 1884 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/auth/AllowAllAuthenticator.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/auth/AllowAllAuthenticator.java b/src/java/org/apache/cassandra/auth/AllowAllAuthenticator.java
index 98a8244..238dac4 100644
--- a/src/java/org/apache/cassandra/auth/AllowAllAuthenticator.java
+++ b/src/java/org/apache/cassandra/auth/AllowAllAuthenticator.java
@@ -35,7 +35,7 @@ public class AllowAllAuthenticator implements IAuthenticator
     {
         return USER;
     }
-    
+
     public void validateConfiguration() throws ConfigurationException
     {
         // pass

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/auth/IAuthority.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/auth/IAuthority.java b/src/java/org/apache/cassandra/auth/IAuthority.java
index 6546a3e..2ece320 100644
--- a/src/java/org/apache/cassandra/auth/IAuthority.java
+++ b/src/java/org/apache/cassandra/auth/IAuthority.java
@@ -25,7 +25,7 @@ import org.apache.cassandra.config.ConfigurationException;
 /**
  * Cassandra's resource hierarchy looks something like:
  * {{/cassandra/keyspaces/$ks_name/...}}
- * 
+ *
  * In table form:
  *  /cassandra/
  *    - no checked permissions
@@ -40,11 +40,11 @@ import org.apache.cassandra.config.ConfigurationException;
  *    - String
  *    * An individual keyspace: READ/WRITE permissions apply to the entire namespace and control the ability to both
  *      view and manipulate column families, and to read and write the data contained within.
- * 
+ *
  * Over time Cassandra _may_ add additional authorize calls for resources higher or lower in the hierarchy and
  * IAuthority implementations should be able to handle these calls (although many will choose to ignore them
  * completely).
- * 
+ *
  * NB: {{/cassandra/}} will not be checked for permissions via a call to IAuthority.authorize, so IAuthority
  * implementations can only deny access when a user attempts to access an ancestor resource.
  */
@@ -53,7 +53,7 @@ public interface IAuthority
     /**
      * @param user An authenticated user from a previous call to IAuthenticator.authenticate.
      * @param resource A List of Objects containing Strings and byte[]s: represents a resource in the hierarchy
-     * described in the Javadocs.  
+     * described in the Javadocs.
      * @return An AccessLevel representing the permissions for the user and resource: should never return null.
      */
     public EnumSet<Permission> authorize(AuthenticatedUser user, List<Object> resource);

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/cache/AutoSavingCache.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cache/AutoSavingCache.java b/src/java/org/apache/cassandra/cache/AutoSavingCache.java
index 5853b2c..d10a8f6 100644
--- a/src/java/org/apache/cassandra/cache/AutoSavingCache.java
+++ b/src/java/org/apache/cassandra/cache/AutoSavingCache.java
@@ -51,7 +51,7 @@ public class AutoSavingCache<K extends CacheKey, V> extends InstrumentingCache<K
 
     protected volatile ScheduledFuture<?> saveTask;
     protected final CacheService.CacheType cacheType;
-    
+
     public AutoSavingCache(ICache<K, V> cache, CacheService.CacheType cacheType)
     {
         super(cache);

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/cache/SerializingCache.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cache/SerializingCache.java b/src/java/org/apache/cassandra/cache/SerializingCache.java
index b39e757..1b317a9 100644
--- a/src/java/org/apache/cassandra/cache/SerializingCache.java
+++ b/src/java/org/apache/cassandra/cache/SerializingCache.java
@@ -41,7 +41,7 @@ public class SerializingCache<K, V> implements ICache<K, V>
 {
     private static final Logger logger = LoggerFactory.getLogger(SerializingCache.class);
     private static final int DEFAULT_CONCURENCY_LEVEL = 64;
-    
+
     private final ConcurrentLinkedHashMap<K, FreeableMemory> map;
     private final ISerializer<V> serializer;
 

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/cli/CliClient.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cli/CliClient.java b/src/java/org/apache/cassandra/cli/CliClient.java
index 6e53b03..e03897a 100644
--- a/src/java/org/apache/cassandra/cli/CliClient.java
+++ b/src/java/org/apache/cassandra/cli/CliClient.java
@@ -187,7 +187,7 @@ public class CliClient
         sessionState.out.println(getHelp().banner);
     }
 
-    // Execute a CLI Statement 
+    // Execute a CLI Statement
     public void executeCLIStatement(String statement) throws CharacterCodingException, TException, TimedOutException, NotFoundException, NoSuchFieldException, InvalidRequestException, UnavailableException, InstantiationException, IllegalAccessException, ClassNotFoundException, SchemaDisagreementException
     {
         Tree tree = CliCompiler.compileQuery(statement);
@@ -301,14 +301,14 @@ public class CliClient
         CliMain.disconnect();
         System.exit(0);
     }
-    
+
     public KsDef getKSMetaData(String keyspace)
             throws NotFoundException, InvalidRequestException, TException
     {
         // Lazily lookup keyspace meta-data.
         if (!(keyspacesMap.containsKey(keyspace)))
             keyspacesMap.put(keyspace, thriftClient.describe_keyspace(keyspace));
-        
+
         return keyspacesMap.get(keyspace);
     }
 
@@ -342,9 +342,9 @@ public class CliClient
 
         String columnFamily = CliCompiler.getColumnFamily(columnFamilySpec, keyspacesMap.get(keySpace).cf_defs);
         int columnSpecCnt = CliCompiler.numColumnSpecifiers(columnFamilySpec);
-       
+
         ColumnParent colParent = new ColumnParent(columnFamily).setSuper_column((ByteBuffer) null);
-       
+
         if (columnSpecCnt != 0)
         {
             Tree columnTree = columnFamilySpec.getChild(2);
@@ -362,8 +362,8 @@ public class CliClient
         int count = thriftClient.get_count(getKeyAsBytes(columnFamily, columnFamilySpec.getChild(1)), colParent, predicate, consistencyLevel);
         sessionState.out.printf("%d columns%n", count);
     }
-    
-    private void executeDelete(Tree statement) 
+
+    private void executeDelete(Tree statement)
             throws TException, InvalidRequestException, UnavailableException, TimedOutException
     {
         if (!CliMain.isConnected() || !hasKeySpace())
@@ -380,7 +380,7 @@ public class CliClient
         byte[] superColumnName = null;
         byte[] columnName = null;
         boolean isSuper = cfDef.column_type.equals("Super");
-     
+
         if ((columnSpecCnt < 0) || (columnSpecCnt > 2))
         {
             sessionState.out.println("Invalid row, super column, or column specification.");
@@ -445,7 +445,7 @@ public class CliClient
     private void doSlice(String keyspace, ByteBuffer key, String columnFamily, byte[] superColumnName, int limit)
             throws InvalidRequestException, UnavailableException, TimedOutException, TException, IllegalAccessException, NotFoundException, InstantiationException, NoSuchFieldException
     {
-        
+
         long startTime = System.currentTimeMillis();
         ColumnParent parent = new ColumnParent(columnFamily);
         if(superColumnName != null)
@@ -475,7 +475,7 @@ public class CliClient
                                                     validator.getString(col.value), col.timestamp,
                                                     col.isSetTtl() ? String.format(", ttl=%d", col.getTtl()) : "");
                 }
-                
+
                 sessionState.out.println(")");
             }
             else if (cosc.isSetColumn())
@@ -514,7 +514,7 @@ public class CliClient
                 sessionState.out.printf("=> (counter=%s, value=%s)%n", formattedName, column.value);
             }
         }
-        
+
         sessionState.out.println("Returned " + columns.size() + " results.");
         elapsedTime(startTime);
     }
@@ -557,7 +557,7 @@ public class CliClient
         int columnSpecCnt = CliCompiler.numColumnSpecifiers(columnFamilySpec);
         CfDef cfDef = getCfDef(columnFamily);
         boolean isSuper = cfDef.column_type.equals("Super");
-        
+
         byte[] superColumnName = null;
         ByteBuffer columnName;
 
@@ -647,7 +647,7 @@ public class CliClient
             return;
         }
 
-        byte[] columnValue = column.getValue();       
+        byte[] columnValue = column.getValue();
         String valueAsString;
 
         // we have ^(CONVERT_TO_TYPE <type>) inside of GET statement
@@ -725,7 +725,7 @@ public class CliClient
         String columnFamily = CliCompiler.getColumnFamily(statement, keyspacesMap.get(keySpace).cf_defs);
         // ^(CONDITIONS ^(CONDITION $column $value) ...)
         Tree conditions = statement.getChild(1);
-        
+
         // fetching column family definition
         CfDef columnFamilyDef = getCfDef(columnFamily);
 
@@ -785,8 +785,8 @@ public class CliClient
             {
                 throw new IllegalArgumentException("LIMIT should be greater than zero.");
             }
-            
-            clause.setCount(limitValue);    
+
+            clause.setCount(limitValue);
         }
 
         try
@@ -812,7 +812,7 @@ public class CliClient
     {
         if (!CliMain.isConnected() || !hasKeySpace())
             return;
-        
+
         long startTime = System.currentTimeMillis();
         // ^(NODE_COLUMN_ACCESS <cf> <key> <column>)
         Tree columnFamilySpec = statement.getChild(0);
@@ -869,7 +869,7 @@ public class CliClient
             parent.setSuper_column(superColumnName);
 
         Column columnToInsert = new Column(columnName).setValue(columnValueInBytes).setTimestamp(FBUtilities.timestampMicros());
-        
+
         // children count = 3 mean that we have ttl in arguments
         if (statement.getChildCount() == 3)
         {
@@ -908,7 +908,7 @@ public class CliClient
         String columnFamily = CliCompiler.getColumnFamily(columnFamilySpec, keyspacesMap.get(keySpace).cf_defs);
         ByteBuffer key = getKeyAsBytes(columnFamily, columnFamilySpec.getChild(1));
         int columnSpecCnt = CliCompiler.numColumnSpecifiers(columnFamilySpec);
-        
+
         byte[] superColumnName = null;
         ByteBuffer columnName;
 
@@ -967,7 +967,7 @@ public class CliClient
     {
         if (!CliMain.isConnected())
             return;
-        
+
         sessionState.out.println(thriftClient.describe_cluster_name());
     }
 
@@ -980,7 +980,7 @@ public class CliClient
 
         if (!CliMain.isConnected())
             return;
-        
+
         // first value is the keyspace name, after that it is all key=value
         String keyspaceName = statement.getChild(0).getText();
         KsDef ksDef = new KsDef(keyspaceName, DEFAULT_PLACEMENT_STRATEGY, new LinkedList<CfDef>());
@@ -1108,9 +1108,9 @@ public class CliClient
     {
         KsDef ksDef = new KsDef(ksDefToUpdate);
 
-        // removing all column definitions - thrift system_update_keyspace method requires that 
+        // removing all column definitions - thrift system_update_keyspace method requires that
         ksDef.setCf_defs(new LinkedList<CfDef>());
-        
+
         for(int i = 1; i < statement.getChildCount(); i += 2)
         {
             String currentStatement = statement.getChild(i).getText().toUpperCase();
@@ -1119,7 +1119,7 @@ public class CliClient
 
             switch(mArgument)
             {
-            case PLACEMENT_STRATEGY: 
+            case PLACEMENT_STRATEGY:
                 ksDef.setStrategy_class(CliUtils.unescapeSQLString(mValue));
                 break;
             case STRATEGY_OPTIONS:
@@ -1152,7 +1152,7 @@ public class CliClient
 
         return ksDef;
     }
-    
+
     /**
      * Update column family definition attributes
      * @param statement - ANTLR tree representing current statement
@@ -1258,7 +1258,7 @@ public class CliClient
      * @throws TException - exception
      * @throws InvalidRequestException - exception
      * @throws NotFoundException - exception
-     * @throws SchemaDisagreementException 
+     * @throws SchemaDisagreementException
      */
     private void executeDelKeySpace(Tree statement)
             throws TException, InvalidRequestException, NotFoundException, SchemaDisagreementException
@@ -1270,7 +1270,7 @@ public class CliClient
         String version = thriftClient.system_drop_keyspace(keyspaceName);
         sessionState.out.println(version);
         validateSchemaIsSettled(version);
-       
+
         if (keyspaceName.equals(keySpace)) //we just deleted the keyspace we were authenticated too
             keySpace = null;
     }
@@ -1281,9 +1281,9 @@ public class CliClient
      * @throws TException - exception
      * @throws InvalidRequestException - exception
      * @throws NotFoundException - exception
-     * @throws SchemaDisagreementException 
+     * @throws SchemaDisagreementException
      */
-    private void executeDelColumnFamily(Tree statement) 
+    private void executeDelColumnFamily(Tree statement)
             throws TException, InvalidRequestException, NotFoundException, SchemaDisagreementException
     {
         if (!CliMain.isConnected() || !hasKeySpace())
@@ -1446,7 +1446,7 @@ public class CliClient
         if (!CliMain.isConnected() || !hasKeySpace())
             return;
 
-        // getting CfDef, it will fail if there is no such column family in current keySpace. 
+        // getting CfDef, it will fail if there is no such column family in current keySpace.
         CfDef cfDef = getCfDef(CliCompiler.getColumnFamily(columnFamily, keyspacesMap.get(keySpace).cf_defs));
 
         thriftClient.truncate(cfDef.getName());
@@ -1545,7 +1545,7 @@ public class CliClient
     {
         if (!CliMain.isConnected())
             return;
-        
+
         sessionState.out.println(thriftClient.describe_version());
     }
 
@@ -1822,34 +1822,34 @@ public class CliClient
      * Returns true if this.keySpace is set, false otherwise
      * @return boolean
      */
-    private boolean hasKeySpace() 
+    private boolean hasKeySpace()
     {
         if (keySpace == null)
         {
             sessionState.out.println("Not authenticated to a working keyspace.");
             return false;
         }
-        
+
         return true;
     }
-    
-    public String getKeySpace() 
+
+    public String getKeySpace()
     {
         return keySpace == null ? "unknown" : keySpace;
     }
-    
-    public void setKeySpace(String keySpace) throws NotFoundException, InvalidRequestException, TException 
+
+    public void setKeySpace(String keySpace) throws NotFoundException, InvalidRequestException, TException
     {
         this.keySpace = keySpace;
         // We do nothing with the return value, but it hits a cache and the tab-completer.
         getKSMetaData(keySpace);
     }
-    
-    public String getUsername() 
+
+    public String getUsername()
     {
         return username == null ? "default" : username;
     }
-    
+
     public void setUsername(String username)
     {
         this.username = username;
@@ -1872,14 +1872,14 @@ public class CliClient
             username  = statement.getChild(1).getText();
             password  = statement.getChild(2).getText();
         }
-        
+
         if (keySpaceName == null)
         {
             sessionState.out.println("Keyspace argument required");
             return;
         }
-        
-        try 
+
+        try
         {
             AuthenticationRequest authRequest;
             Map<String, String> credentials = new HashMap<String, String>();
@@ -1888,7 +1888,7 @@ public class CliClient
 
             thriftClient.set_keyspace(keySpaceName);
 
-            if (username != null && password != null) 
+            if (username != null && password != null)
             {
                 /* remove quotes */
                 password = password.replace("\'", "");
@@ -1900,16 +1900,16 @@ public class CliClient
 
             keySpace = keySpaceName;
             this.username = username != null ? username : "default";
-            
+
             CliMain.updateCompletor(CliUtils.getCfNamesByKeySpace(getKSMetaData(keySpace)));
             sessionState.out.println("Authenticated to keyspace: " + keySpace);
-        } 
-        catch (AuthenticationException e) 
+        }
+        catch (AuthenticationException e)
         {
             sessionState.err.println("Exception during authentication to the cassandra node: " +
                                      "verify keyspace exists, and you are using correct credentials.");
-        } 
-        catch (AuthorizationException e) 
+        }
+        catch (AuthorizationException e)
         {
             sessionState.err.println("You are not authorized to use keyspace: " + keySpaceName);
         }
@@ -1920,8 +1920,8 @@ public class CliClient
         catch (NotFoundException e)
         {
             sessionState.err.println(keySpaceName + " does not exist.");
-        } 
-        catch (TException e) 
+        }
+        catch (TException e)
         {
             if (sessionState.debug)
                 e.printStackTrace(sessionState.err);
@@ -2177,12 +2177,12 @@ public class CliClient
         int portNumber = Integer.parseInt(statement.getChild(1).getText());
 
         StringBuilder hostName = new StringBuilder();
-        int idCount = idList.getChildCount(); 
+        int idCount = idList.getChildCount();
         for (int idx = 0; idx < idCount; idx++)
         {
             hostName.append(idList.getChild(idx).getText());
         }
-        
+
         // disconnect current connection, if any.
         // This is a no-op, if you aren't currently connected.
         CliMain.disconnect();
@@ -2204,13 +2204,13 @@ public class CliClient
     /**
      * To get Column Family Definition object from specified keyspace
      * @param keySpaceName key space name to search for specific column family
-     * @param columnFamilyName column family name 
+     * @param columnFamilyName column family name
      * @return CfDef - Column family definition object
      */
     private CfDef getCfDef(String keySpaceName, String columnFamilyName)
     {
         KsDef keySpaceDefinition = keyspacesMap.get(keySpaceName);
-        
+
         for (CfDef columnFamilyDef : keySpaceDefinition.cf_defs)
         {
             if (columnFamilyDef.name.equals(columnFamilyName))
@@ -2245,24 +2245,24 @@ public class CliClient
 
     /**
      * Used to parse meta tree and compile meta attributes into List<ColumnDef>
-     * @param cfDef - column family definition 
+     * @param cfDef - column family definition
      * @param meta (Tree representing Array of the hashes with metadata attributes)
      * @return List<ColumnDef> List of the ColumnDef's
-     * 
+     *
      * meta is in following format - ^(ARRAY ^(HASH ^(PAIR .. ..) ^(PAIR .. ..)) ^(HASH ...))
      */
     private List<ColumnDef> getCFColumnMetaFromTree(CfDef cfDef, Tree meta)
     {
         // this list will be returned
         List<ColumnDef> columnDefinitions = new ArrayList<ColumnDef>();
-        
+
         // each child node is a ^(HASH ...)
         for (int i = 0; i < meta.getChildCount(); i++)
         {
             Tree metaHash = meta.getChild(i);
 
             ColumnDef columnDefinition = new ColumnDef();
-            
+
             // each child node is ^(PAIR $key $value)
             for (int j = 0; j < metaHash.getChildCount(); j++)
             {
@@ -2294,11 +2294,11 @@ public class CliClient
                 }
                 else if (metaKey.equals("index_name"))
                 {
-                    columnDefinition.setIndex_name(metaVal);    
+                    columnDefinition.setIndex_name(metaVal);
                 }
             }
 
-            // validating columnDef structure, 'name' and 'validation_class' must be set 
+            // validating columnDef structure, 'name' and 'validation_class' must be set
             try
             {
                 columnDefinition.validate();
@@ -2316,7 +2316,7 @@ public class CliClient
 
     /**
      * Getting IndexType object from indexType string
-     * @param indexTypeAsString - string return by parser corresponding to IndexType 
+     * @param indexTypeAsString - string return by parser corresponding to IndexType
      * @return IndexType - an IndexType object
      */
     private IndexType getIndexTypeFromString(String indexTypeAsString)
@@ -2368,14 +2368,14 @@ public class CliClient
             throw new RuntimeException(e);
         }
     }
-    
+
     /**
      * Converts column name into byte[] according to comparator type
      * @param column - column name from parser
      * @param columnFamily - column family name from parser
      * @return ByteBuffer - bytes into which column name was converted according to comparator type
      */
-    private ByteBuffer columnNameAsBytes(String column, String columnFamily) 
+    private ByteBuffer columnNameAsBytes(String column, String columnFamily)
     {
         CfDef columnFamilyDef = getCfDef(columnFamily);
         return columnNameAsBytes(column, columnFamilyDef);
@@ -2386,7 +2386,7 @@ public class CliClient
      * @param columnFamilyDef - column family from parser
      * @return ByteBuffer bytes - into which column name was converted according to comparator type
      */
-    private ByteBuffer columnNameAsBytes(String column, CfDef columnFamilyDef) 
+    private ByteBuffer columnNameAsBytes(String column, CfDef columnFamilyDef)
     {
         String comparatorClass = columnFamilyDef.comparator_type;
         return getBytesAccordingToType(column, getFormatType(comparatorClass));
@@ -2432,7 +2432,7 @@ public class CliClient
      * @param columnFamilyDef - column family from parser
      * @return ByteBuffer bytes - into which column name was converted according to comparator type
      */
-    private ByteBuffer subColumnNameAsBytes(String superColumn, CfDef columnFamilyDef) 
+    private ByteBuffer subColumnNameAsBytes(String superColumn, CfDef columnFamilyDef)
     {
         String comparatorClass = columnFamilyDef.subcomparator_type;
 
@@ -2498,7 +2498,7 @@ public class CliClient
     private AbstractType<?> getValidatorForValue(CfDef ColumnFamilyDef, byte[] columnNameInBytes)
     {
         String defaultValidator = ColumnFamilyDef.default_validation_class;
-        
+
         for (ColumnDef columnDefinition : ColumnFamilyDef.getColumn_metadata())
         {
             byte[] nameInBytes = columnDefinition.getName();
@@ -2509,7 +2509,7 @@ public class CliClient
             }
         }
 
-        if (defaultValidator != null && !defaultValidator.isEmpty()) 
+        if (defaultValidator != null && !defaultValidator.isEmpty())
         {
             return getFormatType(defaultValidator);
         }
@@ -2548,7 +2548,7 @@ public class CliClient
             // current $value
             String val = CliUtils.unescapeSQLString(optionPair.getChild(1).getText());
 
-            strategyOptions.put(key, val);           
+            strategyOptions.put(key, val);
         }
 
         return strategyOptions;
@@ -2558,15 +2558,15 @@ public class CliClient
      * Used to convert value (function argument, string) into byte[]
      * calls convertValueByFunction method with "withUpdate" set to false
      * @param functionCall - tree representing function call ^(FUNCTION_CALL function_name value)
-     * @param columnFamily - column family definition (CfDef) 
+     * @param columnFamily - column family definition (CfDef)
      * @param columnName   - also updates column family metadata for given column
-     * @return byte[] - string value as byte[] 
+     * @return byte[] - string value as byte[]
      */
     private ByteBuffer convertValueByFunction(Tree functionCall, CfDef columnFamily, ByteBuffer columnName)
     {
         return convertValueByFunction(functionCall, columnFamily, columnName, false);
     }
-    
+
     /**
      * Used to convert value (function argument, string) into byte[]
      * @param functionCall - tree representing function call ^(FUNCTION_CALL function_name value)

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/cli/CliCompiler.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cli/CliCompiler.java b/src/java/org/apache/cassandra/cli/CliCompiler.java
index 125c0ea..eaa274f 100644
--- a/src/java/org/apache/cassandra/cli/CliCompiler.java
+++ b/src/java/org/apache/cassandra/cli/CliCompiler.java
@@ -35,7 +35,7 @@ public class CliCompiler
     // of the ANTLRStringStream class. Note: This doesn't change the
     // token text-- but just relaxes the matching rules to match
     // in upper case. [Logic borrowed from Hive code.]
-    // 
+    //
     // Also see discussion on this topic in:
     // http://www.antlr.org/wiki/pages/viewpage.action?pageId=1782.
     public static class ANTLRNoCaseStringStream  extends ANTLRStringStream
@@ -44,15 +44,15 @@ public class CliCompiler
         {
             super(input);
         }
-    
+
         public int LA(int i)
         {
             int returnChar = super.LA(i);
             if (returnChar == CharStream.EOF)
             {
-                return returnChar; 
+                return returnChar;
             }
-            else if (returnChar == 0) 
+            else if (returnChar == 0)
             {
                 return returnChar;
             }
@@ -64,7 +64,7 @@ public class CliCompiler
     public static Tree compileQuery(String query)
     {
         Tree queryTree;
-        
+
         try
         {
             ANTLRStringStream input = new ANTLRNoCaseStringStream(query);
@@ -86,7 +86,7 @@ public class CliCompiler
             // if there was an exception we don't want to process request any further
             throw new RuntimeException(e.getMessage(), e);
         }
-        
+
         return queryTree;
     }
     /*
@@ -166,7 +166,7 @@ public class CliCompiler
     public static String getColumn(Tree astNode, int pos)
     {
         // Skip over table, column family and rowKey
-        return CliUtils.unescapeSQLString(astNode.getChild(pos + 2).getText()); 
+        return CliUtils.unescapeSQLString(astNode.getChild(pos + 2).getText());
     }
- 
+
 }

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/cli/CliCompleter.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cli/CliCompleter.java b/src/java/org/apache/cassandra/cli/CliCompleter.java
index 72d254a..a95de54 100644
--- a/src/java/org/apache/cassandra/cli/CliCompleter.java
+++ b/src/java/org/apache/cassandra/cli/CliCompleter.java
@@ -38,7 +38,7 @@ public class CliCompleter extends SimpleCompletor
             "rename keyspace",
             "rename column family",
             "consistencylevel",
-            
+
             "help connect",
             "help describe keyspace",
             "help exit",
@@ -77,7 +77,7 @@ public class CliCompleter extends SimpleCompletor
     {
         super(commands);
     }
-    
+
     String[] getKeyspaceCommands()
     {
         return keyspaceCommands;

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/cli/CliMain.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cli/CliMain.java b/src/java/org/apache/cassandra/cli/CliMain.java
index 43c24d7..ff73aea 100644
--- a/src/java/org/apache/cassandra/cli/CliMain.java
+++ b/src/java/org/apache/cassandra/cli/CliMain.java
@@ -65,7 +65,7 @@ public class CliMain
         {
             transport = new TFramedTransport(socket);
         }
-        else 
+        else
         {
             transport = socket;
         }
@@ -87,7 +87,7 @@ public class CliMain
 
         thriftClient = cassandraClient;
         cliClient = new CliClient(sessionState, thriftClient);
-        
+
         if ((sessionState.username != null) && (sessionState.password != null))
         {
             // Authenticate
@@ -120,7 +120,7 @@ public class CliMain
                 return;
             }
         }
-        
+
         if (sessionState.keyspace != null)
         {
             try
@@ -191,7 +191,7 @@ public class CliMain
         }
         return true;
     }
-    
+
     public static void updateCompletor(Set<String> candidates)
     {
         Set<String> actions = new HashSet<String>();
@@ -200,9 +200,9 @@ public class CliMain
             for (String cmd : completer.getKeyspaceCommands())
                 actions.add(String.format("%s %s", cmd, cf));
         }
-        
+
         String[] strs = Arrays.copyOf(actions.toArray(), actions.toArray().length, String[].class);
-        
+
         completer.setCandidateStrings(strs);
     }
 
@@ -251,14 +251,14 @@ public class CliMain
         {
             try
             {
-                connect(sessionState.hostName, sessionState.thriftPort);   
+                connect(sessionState.hostName, sessionState.thriftPort);
             }
             catch (RuntimeException e)
             {
                 sessionState.err.println(e.getMessage());
             }
         }
-        
+
         if ( cliClient == null )
         {
             // Connection parameter was either invalid or not present.
@@ -286,12 +286,12 @@ public class CliMain
         }
 
         ConsoleReader reader = new ConsoleReader();
-        
+
         if (!sessionState.batch)
         {
             reader.addCompletor(completer);
             reader.setBellEnabled(false);
-            
+
             String historyFile = System.getProperty("user.home") + File.separator + HISTORYFILE;
 
             try

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/cli/CliSessionState.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cli/CliSessionState.java b/src/java/org/apache/cassandra/cli/CliSessionState.java
index a1a607a..1907c4b 100644
--- a/src/java/org/apache/cassandra/cli/CliSessionState.java
+++ b/src/java/org/apache/cassandra/cli/CliSessionState.java
@@ -30,7 +30,7 @@ public class CliSessionState
 
     public String  hostName;      // cassandra server name
     public int     thriftPort;    // cassandra server's thrift port
-    public boolean framed = true; // cassandra server's framed transport 
+    public boolean framed = true; // cassandra server's framed transport
     public boolean debug = false; // print stack traces when errors occur in the CLI
     public String  username;      // cassandra login name (if SimpleAuthenticator is used)
     public String  password;      // cassandra login password (if SimpleAuthenticator is used)
@@ -56,7 +56,7 @@ public class CliSessionState
 
     public void setOut(PrintStream newOut)
     {
-        this.out = newOut;   
+        this.out = newOut;
     }
 
     public void setErr(PrintStream newErr)

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/client/RingCache.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/client/RingCache.java b/src/java/org/apache/cassandra/client/RingCache.java
index dc09ac2..4db4a0d 100644
--- a/src/java/org/apache/cassandra/client/RingCache.java
+++ b/src/java/org/apache/cassandra/client/RingCache.java
@@ -62,12 +62,12 @@ public class RingCache
     public void refreshEndpointMap()
     {
             try {
-                
+
                 Cassandra.Client client = ConfigHelper.getClientFromOutputAddressList(conf);
 
                 List<TokenRange> ring = client.describe_ring(ConfigHelper.getOutputKeyspace(conf));
                 rangeMap = ArrayListMultimap.create();
-                
+
                 for (TokenRange range : ring)
                 {
                     Token<?> left = partitioner.getTokenFactory().fromString(range.start_token);

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/concurrent/CreationTimeAwareFuture.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/concurrent/CreationTimeAwareFuture.java b/src/java/org/apache/cassandra/concurrent/CreationTimeAwareFuture.java
index 6c06495..d9d8185 100644
--- a/src/java/org/apache/cassandra/concurrent/CreationTimeAwareFuture.java
+++ b/src/java/org/apache/cassandra/concurrent/CreationTimeAwareFuture.java
@@ -32,25 +32,25 @@ import java.util.concurrent.TimeoutException;
  *
  * @param <V>
  */
-public class CreationTimeAwareFuture<V> implements Future<V> 
+public class CreationTimeAwareFuture<V> implements Future<V>
 {
 
     private final long creationTime = System.currentTimeMillis();
     private final Future<V> future;
 
-    public CreationTimeAwareFuture(Future<V> future) 
+    public CreationTimeAwareFuture(Future<V> future)
     {
         this.future = future;
     }
 
-    public V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException 
+    public V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException
     {
         timeout = unit.toMillis(timeout);
         long overallTimeout = timeout - (System.currentTimeMillis() - creationTime);
         return future.get(overallTimeout, TimeUnit.MILLISECONDS);
     }
 
-    public boolean cancel(boolean mayInterruptIfRunning) 
+    public boolean cancel(boolean mayInterruptIfRunning)
     {
         return future.cancel(mayInterruptIfRunning);
     }

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/concurrent/JMXConfigurableThreadPoolExecutor.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/concurrent/JMXConfigurableThreadPoolExecutor.java b/src/java/org/apache/cassandra/concurrent/JMXConfigurableThreadPoolExecutor.java
index cd7c9e3..7fe6c07 100644
--- a/src/java/org/apache/cassandra/concurrent/JMXConfigurableThreadPoolExecutor.java
+++ b/src/java/org/apache/cassandra/concurrent/JMXConfigurableThreadPoolExecutor.java
@@ -20,17 +20,17 @@ package org.apache.cassandra.concurrent;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.TimeUnit;
 
-public class JMXConfigurableThreadPoolExecutor extends JMXEnabledThreadPoolExecutor implements JMXConfigurableThreadPoolExecutorMBean 
+public class JMXConfigurableThreadPoolExecutor extends JMXEnabledThreadPoolExecutor implements JMXConfigurableThreadPoolExecutorMBean
 {
 
     public JMXConfigurableThreadPoolExecutor(int corePoolSize,
                                              long keepAliveTime,
                                              TimeUnit unit,
-                                             BlockingQueue<Runnable> workQueue, 
+                                             BlockingQueue<Runnable> workQueue,
                                              NamedThreadFactory threadFactory,
                                              String jmxPath)
     {
         super(corePoolSize, keepAliveTime, unit, workQueue, threadFactory, jmxPath);
     }
-    
+
 }

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/concurrent/JMXEnabledThreadPoolExecutor.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/concurrent/JMXEnabledThreadPoolExecutor.java b/src/java/org/apache/cassandra/concurrent/JMXEnabledThreadPoolExecutor.java
index 76df64d..f75a04b 100644
--- a/src/java/org/apache/cassandra/concurrent/JMXEnabledThreadPoolExecutor.java
+++ b/src/java/org/apache/cassandra/concurrent/JMXEnabledThreadPoolExecutor.java
@@ -28,7 +28,7 @@ import javax.management.ObjectName;
 
 /**
  * This is a wrapper class for the <i>ScheduledThreadPoolExecutor</i>. It provides an implementation
- * for the <i>afterExecute()</i> found in the <i>ThreadPoolExecutor</i> class to log any unexpected 
+ * for the <i>afterExecute()</i> found in the <i>ThreadPoolExecutor</i> class to log any unexpected
  * Runtime Exceptions.
  */
 
@@ -63,7 +63,7 @@ public class JMXEnabledThreadPoolExecutor extends DebuggableThreadPoolExecutor i
     {
         this(corePoolSize, corePoolSize, keepAliveTime, unit, workQueue, threadFactory, jmxPath);
     }
-    
+
     public JMXEnabledThreadPoolExecutor(int corePoolSize,
                                         int maxPoolSize,
                                         long keepAliveTime,

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/concurrent/NamedThreadFactory.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/concurrent/NamedThreadFactory.java b/src/java/org/apache/cassandra/concurrent/NamedThreadFactory.java
index de3028a..4c6763c 100644
--- a/src/java/org/apache/cassandra/concurrent/NamedThreadFactory.java
+++ b/src/java/org/apache/cassandra/concurrent/NamedThreadFactory.java
@@ -21,8 +21,8 @@ import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.atomic.AtomicInteger;
 
 /**
- * This class is an implementation of the <i>ThreadFactory</i> interface. This 
- * is useful to give Java threads meaningful names which is useful when using 
+ * This class is an implementation of the <i>ThreadFactory</i> interface. This
+ * is useful to give Java threads meaningful names which is useful when using
  * a tool like JConsole.
  */
 
@@ -45,7 +45,7 @@ public class NamedThreadFactory implements ThreadFactory
     }
 
     public Thread newThread(Runnable runnable)
-    {        
+    {
         String name = id + ":" + n.getAndIncrement();
         Thread thread = new Thread(runnable, name);
         thread.setPriority(priority);

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/concurrent/StageManager.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/concurrent/StageManager.java b/src/java/org/apache/cassandra/concurrent/StageManager.java
index b8e098e..ffbc5d4 100644
--- a/src/java/org/apache/cassandra/concurrent/StageManager.java
+++ b/src/java/org/apache/cassandra/concurrent/StageManager.java
@@ -39,7 +39,7 @@ public class StageManager
     static
     {
         stages.put(Stage.MUTATION, multiThreadedConfigurableStage(Stage.MUTATION, getConcurrentWriters()));
-        stages.put(Stage.READ, multiThreadedConfigurableStage(Stage.READ, getConcurrentReaders()));        
+        stages.put(Stage.READ, multiThreadedConfigurableStage(Stage.READ, getConcurrentReaders()));
         stages.put(Stage.REQUEST_RESPONSE, multiThreadedStage(Stage.REQUEST_RESPONSE, Runtime.getRuntime().availableProcessors()));
         stages.put(Stage.INTERNAL_RESPONSE, multiThreadedStage(Stage.INTERNAL_RESPONSE, Runtime.getRuntime().availableProcessors()));
         stages.put(Stage.REPLICATE_ON_WRITE, multiThreadedConfigurableStage(Stage.REPLICATE_ON_WRITE, getConcurrentReplicators()));
@@ -61,7 +61,7 @@ public class StageManager
                                                 new NamedThreadFactory(stage.getJmxName()),
                                                 stage.getJmxType());
     }
-    
+
     private static ThreadPoolExecutor multiThreadedConfigurableStage(Stage stage, int numThreads)
     {
         return new JMXConfigurableThreadPoolExecutor(numThreads,
@@ -80,7 +80,7 @@ public class StageManager
     {
         return stages.get(stage);
     }
-    
+
     /**
      * This method shuts down all registered stages.
      */

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/config/CFMetaData.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/config/CFMetaData.java b/src/java/org/apache/cassandra/config/CFMetaData.java
index bb16c57..5f7d21c 100644
--- a/src/java/org/apache/cassandra/config/CFMetaData.java
+++ b/src/java/org/apache/cassandra/config/CFMetaData.java
@@ -314,7 +314,7 @@ public final class CFMetaData
                       .bloomFilterFpChance(oldCFMD.bloomFilterFpChance)
                       .caching(oldCFMD.caching);
     }
-    
+
     /**
      * generate a column family name for an index corresponding to the given column.
      * This is NOT the same as the index's name! This is only used in sstable filenames and is not exposed to users.
@@ -436,7 +436,7 @@ public final class CFMetaData
     {
         return new ArrayList<T>(array);
     }
-    
+
     public String getComment()
     {
         return comment;
@@ -456,7 +456,7 @@ public final class CFMetaData
     {
         return replicateOnWrite;
     }
-    
+
     public int getGcGraceSeconds()
     {
         return gcGraceSeconds;
@@ -610,7 +610,7 @@ public final class CFMetaData
     }
 
     /** applies implicit defaults to cf definition. useful in updates */
-    public static void applyImplicitDefaults(org.apache.cassandra.thrift.CfDef cf_def) 
+    public static void applyImplicitDefaults(org.apache.cassandra.thrift.CfDef cf_def)
     {
         if (!cf_def.isSetComment())
             cf_def.setComment("");
@@ -780,7 +780,7 @@ public final class CFMetaData
         for (ByteBuffer name : column_metadata.keySet())
             if (!newColumns.contains(name))
                 toRemove.add(name);
-        
+
         // remove the ones leaving.
         for (ByteBuffer indexName : toRemove)
         {
@@ -801,7 +801,7 @@ public final class CFMetaData
         for (ColumnDef def : toAdd)
         {
             AbstractType<?> dValidClass = TypeParser.parse(def.validation_class);
-            ColumnDefinition cd = new ColumnDefinition(def.name, 
+            ColumnDefinition cd = new ColumnDefinition(def.name,
                                                        dValidClass,
                                                        def.index_type == null ? null : IndexType.valueOf(def.index_type.name()),
                                                        def.index_options,
@@ -966,7 +966,7 @@ public final class CFMetaData
         try
         {
             AbstractType<?> comparator = TypeParser.parse(cf_def.comparator_type);
-            
+
             for (org.apache.cassandra.thrift.ColumnDef column : cf_def.column_metadata)
             {
                 if (column.index_type != null && column.index_name == null)

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/config/ColumnDefinition.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/config/ColumnDefinition.java b/src/java/org/apache/cassandra/config/ColumnDefinition.java
index 6fdbd10..ec79a72 100644
--- a/src/java/org/apache/cassandra/config/ColumnDefinition.java
+++ b/src/java/org/apache/cassandra/config/ColumnDefinition.java
@@ -41,13 +41,13 @@ public class ColumnDefinition
     private IndexType index_type;
     private Map<String,String> index_options;
     private String index_name;
-    
+
     public ColumnDefinition(ByteBuffer name, AbstractType<?> validator, IndexType index_type, Map<String, String> index_options, String index_name)
     {
         this.name = name;
         this.index_name = index_name;
         this.validator = validator;
-    
+
         this.setIndexType(index_type, index_options);
     }
 
@@ -278,7 +278,7 @@ public class ColumnDefinition
     {
         return index_name;
     }
-    
+
     public void setIndexName(String s)
     {
         index_name = s;
@@ -287,19 +287,19 @@ public class ColumnDefinition
     public void setIndexType(IndexType index_type, Map<String,String> index_options)
     {
         this.index_type = index_type;
-        this.index_options = index_options;         
+        this.index_options = index_options;
     }
 
     public IndexType getIndexType()
     {
         return index_type;
     }
-    
+
     public Map<String,String> getIndexOptions()
     {
         return index_options;
     }
-    
+
     public AbstractType<?> getValidator()
     {
         return validator;
@@ -309,18 +309,18 @@ public class ColumnDefinition
     {
         this.validator = validator;
     }
-    
+
     public static Map<String,String> getStringMap(Map<CharSequence, CharSequence> charMap)
     {
         if (charMap == null)
             return null;
-        
+
         Map<String,String> stringMap = new HashMap<String, String>();
-            
-        for (Map.Entry<CharSequence, CharSequence> entry : charMap.entrySet())        
+
+        for (Map.Entry<CharSequence, CharSequence> entry : charMap.entrySet())
             stringMap.put(entry.getKey().toString(), entry.getValue().toString());
-            
-            
+
+
         return stringMap;
     }
 }

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/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 b5fbfb5..5685e07 100644
--- a/src/java/org/apache/cassandra/config/Config.java
+++ b/src/java/org/apache/cassandra/config/Config.java
@@ -25,46 +25,46 @@ public class Config
     public String cluster_name = "Test Cluster";
     public String authenticator;
     public String authority;
-    
+
     /* Hashing strategy Random or OPHF */
     public String partitioner;
-    
+
     public Boolean auto_bootstrap = true;
     public Boolean hinted_handoff_enabled = true;
     public Integer max_hint_window_in_ms = Integer.MAX_VALUE;
-    
+
     public SeedProviderDef seed_provider;
     public DiskAccessMode disk_access_mode = DiskAccessMode.auto;
-    
+
     /* Address where to run the job tracker */
     public String job_tracker_host;
-    
+
     /* Job Jar Location */
     public String job_jar_file_location;
-    
+
     /* initial token in the ring */
     public String initial_token;
-    
+
     public Long rpc_timeout_in_ms = new Long(2000);
 
     public Integer streaming_socket_timeout_in_ms = new Integer(0);
 
     public Integer phi_convict_threshold = 8;
-    
+
     public Integer concurrent_reads = 8;
     public Integer concurrent_writes = 32;
     public Integer concurrent_replicates = 32;
-    
+
     public Integer memtable_flush_writers = null; // will get set to the length of data dirs in DatabaseDescriptor
     public Integer memtable_total_space_in_mb;
 
     public Integer sliced_buffer_size_in_kb = 64;
-    
+
     public Integer storage_port = 7000;
     public Integer ssl_storage_port = 7001;
     public String listen_address;
     public String broadcast_address;
-    
+
     public String rpc_address;
     public Integer rpc_port = 9160;
     public String rpc_server_type = "sync";
@@ -97,7 +97,7 @@ public class Config
     public CommitLogSync commitlog_sync;
     public Double commitlog_sync_batch_window_in_ms;
     public Integer commitlog_sync_period_in_ms;
-    
+
     public String endpoint_snitch;
     public Boolean dynamic_snitch = true;
     public Integer dynamic_snitch_update_interval_in_ms = 100;
@@ -157,14 +157,14 @@ public class Config
         periodic,
         batch
     }
-    
+
     public static enum DiskAccessMode {
         auto,
         mmap,
         mmap_index_only,
         standard,
     }
-    
+
     public static enum RequestSchedulerId
     {
         keyspace

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/config/DatabaseDescriptor.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/config/DatabaseDescriptor.java b/src/java/org/apache/cassandra/config/DatabaseDescriptor.java
index dde24eb..71f2ae3 100644
--- a/src/java/org/apache/cassandra/config/DatabaseDescriptor.java
+++ b/src/java/org/apache/cassandra/config/DatabaseDescriptor.java
@@ -70,7 +70,7 @@ public class DatabaseDescriptor
     private static IPartitioner partitioner;
 
     private static Config.DiskAccessMode indexAccessMode;
-    
+
     private static Config conf;
 
     private static IAuthenticator authenticator = new AllowAllAuthenticator();
@@ -471,7 +471,7 @@ public class DatabaseDescriptor
     }
 
     /** load keyspace (table) definitions, but do not initialize the table instances. */
-    public static void loadSchemas() throws IOException                         
+    public static void loadSchemas() throws IOException
     {
         ColumnFamilyStore schemaCFS = SystemTable.schemaCFS(SystemTable.SCHEMA_KEYSPACES_CF);
 
@@ -555,8 +555,8 @@ public class DatabaseDescriptor
     {
         return conf.thrift_max_message_length_in_mb * 1024 * 1024;
     }
-    
-    public static int getThriftFramedTransportSize() 
+
+    public static int getThriftFramedTransportSize()
     {
         return conf.thrift_framed_transport_size_in_mb * 1024 * 1024;
     }
@@ -602,7 +602,7 @@ public class DatabaseDescriptor
     {
         partitioner = newPartitioner;
     }
-    
+
     public static IEndpointSnitch getEndpointSnitch()
     {
         return snitch;
@@ -631,7 +631,7 @@ public class DatabaseDescriptor
     {
         return conf.job_tracker_host;
     }
-    
+
     public static int getColumnIndexSize()
     {
         return conf.column_index_size_in_kb * 1024;
@@ -761,7 +761,7 @@ public class DatabaseDescriptor
     {
         return conf.saved_caches_directory;
     }
-    
+
     public static Set<InetAddress> getSeeds()
     {
         return Collections.unmodifiableSet(new HashSet(seedProvider.getSeeds()));
@@ -771,22 +771,22 @@ public class DatabaseDescriptor
     {
         return listenAddress;
     }
-    
+
     public static InetAddress getBroadcastAddress()
     {
         return broadcastAddress;
     }
-    
+
     public static void setBroadcastAddress(InetAddress broadcastAdd)
     {
         broadcastAddress = broadcastAdd;
     }
-    
+
     public static InetAddress getRpcAddress()
     {
         return rpcAddress;
     }
-    
+
     public static String getRpcServerType()
     {
         return conf.rpc_server_type;
@@ -801,12 +801,12 @@ public class DatabaseDescriptor
     {
         return conf.rpc_min_threads;
     }
-    
+
     public static Integer getRpcMaxThreads()
     {
         return conf.rpc_max_threads;
     }
-    
+
     public static Integer getRpcSendBufferSize()
     {
         return conf.rpc_send_buff_size_in_bytes;

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/config/SeedProviderDef.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/config/SeedProviderDef.java b/src/java/org/apache/cassandra/config/SeedProviderDef.java
index b0c4082..54853df 100644
--- a/src/java/org/apache/cassandra/config/SeedProviderDef.java
+++ b/src/java/org/apache/cassandra/config/SeedProviderDef.java
@@ -26,7 +26,7 @@ public class SeedProviderDef
 {
     public String class_name;
     public Map<String, String> parameters;
-    
+
     public SeedProviderDef(LinkedHashMap p)
     {
         class_name = (String)p.get("class_name");

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/cql/CQLStatement.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cql/CQLStatement.java b/src/java/org/apache/cassandra/cql/CQLStatement.java
index b495211..157ce67 100644
--- a/src/java/org/apache/cassandra/cql/CQLStatement.java
+++ b/src/java/org/apache/cassandra/cql/CQLStatement.java
@@ -22,7 +22,7 @@ public class CQLStatement
     public final StatementType type;
     public final Object statement;
     public final int boundTerms;
-    
+
     public CQLStatement(StatementType type, Object statement, int lastMarker)
     {
         this.type = type;

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/cql/CreateColumnFamilyStatement.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cql/CreateColumnFamilyStatement.java b/src/java/org/apache/cassandra/cql/CreateColumnFamilyStatement.java
index 636b589..d9dcc62 100644
--- a/src/java/org/apache/cassandra/cql/CreateColumnFamilyStatement.java
+++ b/src/java/org/apache/cassandra/cql/CreateColumnFamilyStatement.java
@@ -46,7 +46,7 @@ public class CreateColumnFamilyStatement
     {
         this.name = name;
     }
-    
+
     /** Perform validation of parsed params */
     private void validate(List<ByteBuffer> variables) throws InvalidRequestException
     {
@@ -57,7 +57,7 @@ public class CreateColumnFamilyStatement
             throw new InvalidRequestException(String.format("\"%s\" is not a valid column family name", name));
         if (name.length() > 32)
             throw new InvalidRequestException(String.format("Column family names shouldn't be more than 32 character long (got \"%s\")", name));
-        
+
         // Ensure that exactly one key has been specified.
         if (keyValidator.size() < 1)
             throw new InvalidRequestException("You must specify a PRIMARY KEY");
@@ -86,18 +86,18 @@ public class CreateColumnFamilyStatement
 
         }
     }
-    
+
     /** Map a column name to a validator for its value */
     public void addColumn(Term term, String comparator)
     {
         columns.put(term, comparator);
     }
-    
+
     public void setKeyType(String validator)
     {
         keyValidator.add(validator);
     }
-    
+
     public String getKeyType()
     {
         return keyValidator.get(0);
@@ -121,12 +121,12 @@ public class CreateColumnFamilyStatement
     {
         return name;
     }
-    
+
     // Column definitions
     private Map<ByteBuffer, ColumnDefinition> getColumns(AbstractType<?> comparator) throws InvalidRequestException
     {
         Map<ByteBuffer, ColumnDefinition> columnDefs = new HashMap<ByteBuffer, ColumnDefinition>();
-        
+
         for (Map.Entry<Term, String> col : columns.entrySet())
         {
             try
@@ -145,14 +145,14 @@ public class CreateColumnFamilyStatement
                 throw ex;
             }
         }
-        
+
         return columnDefs;
     }
 
     /**
      * Returns a CFMetaData instance based on the parameters parsed from this
      * <code>CREATE</code> statement, or defaults where applicable.
-     * 
+     *
      * @param keyspace keyspace to apply this column family to
      * @return a CFMetaData instance corresponding to the values parsed from this statement
      * @throws InvalidRequestException on failure to validate parsed parameters
@@ -194,7 +194,7 @@ public class CreateColumnFamilyStatement
         }
         return newCFMD;
     }
-    
+
     private String getPropertyString(String key, String defaultValue)
     {
         return cfProps.getPropertyString(key, defaultValue);

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/cql/CreateIndexStatement.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cql/CreateIndexStatement.java b/src/java/org/apache/cassandra/cql/CreateIndexStatement.java
index d15a7e9..54b5eef 100644
--- a/src/java/org/apache/cassandra/cql/CreateIndexStatement.java
+++ b/src/java/org/apache/cassandra/cql/CreateIndexStatement.java
@@ -23,26 +23,26 @@ public class CreateIndexStatement
     private final String columnFamily;
     private final String indexName;
     private final Term columnName;
-    
+
     public CreateIndexStatement(String indexName, String columnFamily, Term columnName)
     {
         this.indexName = indexName;
         this.columnFamily = columnFamily;
         this.columnName = columnName;
     }
-    
+
     /** Column family namespace. */
     public String getColumnFamily()
     {
         return columnFamily;
     }
-    
+
     /** Column name to index. */
     public Term getColumnName()
     {
         return columnName;
     }
-    
+
     /** Index name (or null). */
     public String getIndexName()
     {

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/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 9899218..7dbf355 100644
--- a/src/java/org/apache/cassandra/cql/CreateKeyspaceStatement.java
+++ b/src/java/org/apache/cassandra/cql/CreateKeyspaceStatement.java
@@ -28,16 +28,16 @@ import org.apache.cassandra.thrift.InvalidRequestException;
 
 /** A <code>CREATE KEYSPACE</code> statement parsed from a CQL query. */
 public class CreateKeyspaceStatement
-{   
+{
     private final String name;
     private final Map<String, String> attrs;
     private String strategyClass;
     private final Map<String, String> strategyOptions = new HashMap<String, String>();
-    
+
     /**
      * Creates a new <code>CreateKeyspaceStatement</code> instance for a given
      * keyspace name and keyword arguments.
-     *  
+     *
      * @param name the name of the keyspace to create
      * @param attrs map of the raw keyword arguments that followed the <code>WITH</code> keyword.
      */
@@ -46,12 +46,12 @@ public class CreateKeyspaceStatement
         this.name = name;
         this.attrs = attrs;
     }
-    
+
     /**
      * The <code>CqlParser</code> only goes as far as extracting the keyword arguments
      * from these statements, so this method is responsible for processing and
      * validating, and must be called prior to access.
-     * 
+     *
      * @throws InvalidRequestException if arguments are missing or unacceptable
      */
     public void validate() throws InvalidRequestException
@@ -61,12 +61,12 @@ public class CreateKeyspaceStatement
             throw new InvalidRequestException(String.format("\"%s\" is not a valid keyspace name", name));
         if (name.length() > 32)
             throw new InvalidRequestException(String.format("Keyspace names shouldn't be more than 32 character long (got \"%s\")", name));
-        
+
         // required
         if (!attrs.containsKey("strategy_class"))
             throw new InvalidRequestException("missing required argument \"strategy_class\"");
         strategyClass = attrs.get("strategy_class");
-        
+
         // optional
         for (String key : attrs.keySet())
             if ((key.contains(":")) && (key.startsWith("strategy_options")))

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2fd3268b/src/java/org/apache/cassandra/cql/DeleteStatement.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cql/DeleteStatement.java b/src/java/org/apache/cassandra/cql/DeleteStatement.java
index 8d2a968..1c26877 100644
--- a/src/java/org/apache/cassandra/cql/DeleteStatement.java
+++ b/src/java/org/apache/cassandra/cql/DeleteStatement.java
@@ -42,7 +42,7 @@ public class DeleteStatement extends AbstractModification
 {
     private List<Term> columns;
     private List<Term> keys;
-    
+
     public DeleteStatement(List<Term> columns, String keyspace, String columnFamily, String keyName, List<Term> keys, Attributes attrs)
     {
         super(keyspace, columnFamily, keyName, attrs);


Mime
View raw message