Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ import org.apache.cassandra.thrift.ColumnParent
trait ColumnFamily[+KeyType] extends StringValue {
val keyspace:Keyspace
lazy val columnParent = new ColumnParent().setColumn_family(value)

def \(value:String):KeyType

}
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ class Delete(val container:ColumnContainer[_, _], val predicate:Predicate) exten

out.setDeletion(del)
}

val family = container.family
val key = container.key
val keyspace = container.keyspace
Expand Down
2 changes: 1 addition & 1 deletion src/main/scala/com/shorrockin/cascal/utils/UUID.scala
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ import _root_.com.eaio.uuid.{UUID => EaioUUID}
* @author Chris Shorrock
*/
object UUID {

/**
* returns a new uuid, can be used as a time uuid
*/
Expand Down
30 changes: 15 additions & 15 deletions src/test/resources/storage-conf.xml
Original file line number Diff line number Diff line change
Expand Up @@ -44,8 +44,8 @@
</Keyspaces>

<!--
~ Turn on to make new [non-seed] nodes automatically migrate the right data
~ to themselves. (If no InitialToken is specified, they will pick one
~ Turn on to make new [non-seed] nodes automatically migrate the right data
~ to themselves. (If no InitialToken is specified, they will pick one
~ such that they will get half the range of the most-loaded node.)
~ If a node starts up without bootstrapping, it will mark itself bootstrapped
~ so that you can't subsequently accidently bootstrap a node with
Expand All @@ -65,7 +65,7 @@
~ Authenticator: any IAuthenticator may be used, including your own as long
~ as it is on the classpath. Out of the box, Cassandra provides
~ org.apache.cassandra.auth.AllowAllAuthenticator and,
~ org.apache.cassandra.auth.SimpleAuthenticator
~ org.apache.cassandra.auth.SimpleAuthenticator
~ (SimpleAuthenticator uses access.properties and passwd.properties by
~ default).
~
Expand Down Expand Up @@ -96,7 +96,7 @@
~ are sent to the node with the "closest" token, so distributing your
~ tokens equally along the key distribution space will spread keys
~ evenly across your cluster.) This setting is only checked the first
~ time a node is started.
~ time a node is started.

~ This can also be useful with RandomPartitioner to force equal spacing
~ of tokens around the hash space, especially for clusters with a small
Expand All @@ -110,7 +110,7 @@
~ performance
-->
<CommitLogDirectory>%temp-dir%commitlog</CommitLogDirectory>

<DataFileDirectories>
<DataFileDirectory>%temp-dir%data</DataFileDirectory>
</DataFileDirectories>
Expand All @@ -136,9 +136,9 @@

<!-- Local hosts and ports -->

<!--
<!--
~ Address to bind to and tell other nodes to connect to. You _must_
~ change this if you want multiple nodes to be able to communicate!
~ change this if you want multiple nodes to be able to communicate!
~
~ Leaving it blank leaves it up to InetAddress.getLocalHost(). This
~ will always do the Right Thing *if* the node is properly configured
Expand All @@ -160,9 +160,9 @@
<ThriftAddress>localhost</ThriftAddress>
<!-- Thrift RPC port (the port clients connect to). -->
<ThriftPort>9160</ThriftPort>
<!--
<!--
~ Whether or not to use a framed transport for Thrift. If this option
~ is set to true then you must also use a framed transport on the
~ is set to true then you must also use a framed transport on the
~ client-side, (framed and non-framed transports are not compatible).
-->
<ThriftFramedTransport>false</ThriftFramedTransport>
Expand Down Expand Up @@ -194,16 +194,16 @@

<!--
~ Buffer size to use when performing contiguous column slices. Increase
~ this to the size of the column slices you typically perform.
~ (Name-based queries are performed with a buffer size of
~ this to the size of the column slices you typically perform.
~ (Name-based queries are performed with a buffer size of
~ ColumnIndexSizeInKB.)
-->
<SlicedBufferSizeInKB>64</SlicedBufferSizeInKB>

<!--
~ Buffer size to use when flushing memtables to disk. (Only one
~ Buffer size to use when flushing memtables to disk. (Only one
~ memtable is ever flushed at a time.) Increase (decrease) the index
~ buffer size relative to the data buffer if you have few (many)
~ buffer size relative to the data buffer if you have few (many)
~ columns per key. Bigger is only better _if_ your memtables get large
~ enough to use the space. (Check in your data directory after your
~ app has been running long enough.) -->
Expand All @@ -223,7 +223,7 @@

<!--
~ Flush memtable after this much data has been inserted, including
~ overwritten data. There is one memtable per column family, and
~ overwritten data. There is one memtable per column family, and
~ this threshold is based solely on the amount of data stored, not
~ actual heap memory usage (there is some overhead in indexing the
~ columns).
Expand Down Expand Up @@ -288,7 +288,7 @@
~ individually). Reasonable values range from a minimal 0.1 to 10 or
~ even more if throughput matters more than latency.
-->
<!-- <CommitLogSyncBatchWindowInMS>1</CommitLogSyncBatchWindowInMS> -->
<!-- <CommitLogSyncBatchWindowInMS>1</CommitLogSyncBatchWindowInMS> -->

<!--
~ Time to wait before garbage-collection deletion markers. Set this to
Expand Down