This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
cqlsh:ControlServerLogRequestCount> CREATE COLUMNFAMILY users (KEY varchar PRIMARY KEY,password varchar,gender varchar,session_token varchar,state varchar,birth_year bigint); | |
cqlsh:ControlServerLogRequestCount> INSERT INTO users (KEY, password) VALUES ('jsmith', 'ch@ngem3a'); | |
cqlsh:ControlServerLogRequestCount> select * from users where KEY='jsmith'; | |
Traceback (most recent call last): | |
File "bin/cqlsh", line 482, in perform_statement | |
self.cursor.execute(statement, decoder=decoder) | |
File "build/bdist.linux-x86_64/egg/cql/cursor.py", line 106, in execute | |
self.description = self.decoder.decode_description(self.result[0]) | |
File "build/bdist.linux-x86_64/egg/cql/decoders.py", line 33, in decode_description | |
comparator = schema.name_types.get(name, schema.default_name_type) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/** | |
* Licensed to the Apache Software Foundation (ASF) under one or more | |
* contributor license agreements. See the NOTICE file distributed with | |
* this work for additional information regarding copyright ownership. | |
* The ASF licenses this file to You under the Apache License, Version 2.0 | |
* (the "License"); you may not use this file except in compliance with | |
* the License. You may obtain a copy of the License at | |
* | |
* http://www.apache.org/licenses/LICENSE-2.0 | |
* |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/** | |
* Licensed to the Apache Software Foundation (ASF) under one or more | |
* contributor license agreements. See the NOTICE file distributed with | |
* this work for additional information regarding copyright ownership. | |
* The ASF licenses this file to You under the Apache License, Version 2.0 | |
* (the "License"); you may not use this file except in compliance with | |
* the License. You may obtain a copy of the License at | |
* | |
* http://www.apache.org/licenses/LICENSE-2.0 | |
* |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Index: core/src/main/scala/kafka/producer/SyncProducer.scala | |
=================================================================== | |
--- core/src/main/scala/kafka/producer/SyncProducer.scala (revision 1234442) | |
+++ core/src/main/scala/kafka/producer/SyncProducer.scala (working copy) | |
@@ -107,15 +107,18 @@ | |
/** | |
* Send a message | |
*/ | |
- def send(topic: String, partition: Int, messages: ByteBufferMessageSet) { | |
- verifyMessageSize(messages) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Index: core/src/main/scala/kafka/producer/ProducerPool.scala | |
=================================================================== | |
--- core/src/main/scala/kafka/producer/ProducerPool.scala (revision 1234442) | |
+++ core/src/main/scala/kafka/producer/ProducerPool.scala (working copy) | |
@@ -26,6 +26,8 @@ | |
import kafka.common.{UnavailableProducerException, InvalidConfigException} | |
import kafka.utils.{Utils, Logging} | |
import kafka.message.{NoCompressionCodec, ByteBufferMessageSet} | |
+import collection.mutable.{HashMap, ListBuffer} | |
+import kafka.api.{WiredTopic, WiredPartition} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Index: core/src/test/scala/unit/kafka/utils/TestUtils.scala | |
=================================================================== | |
--- core/src/test/scala/unit/kafka/utils/TestUtils.scala (revision 1234442) | |
+++ core/src/test/scala/unit/kafka/utils/TestUtils.scala (working copy) | |
@@ -29,6 +29,7 @@ | |
import kafka.message._ | |
import org.I0Itec.zkclient.ZkClient | |
import kafka.consumer.ConsumerConfig | |
+import kafka.api.{WiredTopic, WiredPartition} | |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Index: core/src/test/scala/unit/kafka/utils/TestUtils.scala | |
=================================================================== | |
--- core/src/test/scala/unit/kafka/utils/TestUtils.scala (revision 1234442) | |
+++ core/src/test/scala/unit/kafka/utils/TestUtils.scala (working copy) | |
@@ -29,6 +29,7 @@ | |
import kafka.message._ | |
import org.I0Itec.zkclient.ZkClient | |
import kafka.consumer.ConsumerConfig | |
+import kafka.api.{WiredTopic, WiredPartition} | |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Index: core/src/test/scala/unit/kafka/utils/TestUtils.scala | |
=================================================================== | |
--- core/src/test/scala/unit/kafka/utils/TestUtils.scala (revision 1234442) | |
+++ core/src/test/scala/unit/kafka/utils/TestUtils.scala (working copy) | |
@@ -29,6 +29,7 @@ | |
import kafka.message._ | |
import org.I0Itec.zkclient.ZkClient | |
import kafka.consumer.ConsumerConfig | |
+import kafka.api.{WiredTopic, WiredPartition} | |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Josephs-MacBook-Pro:~ josephstein$ cat test | |
1,,2 | |
1,1,2 | |
Josephs-MacBook-Pro:~ josephstein$ cat test |sort | |
1,,2 | |
1,1,2 | |
[root@megatron joestein]# cat test | |
1,,2 | |
1,1,2 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Index: lib/sbt-launch.jar | |
=================================================================== | |
Cannot display: file marked as a binary type. | |
svn:mime-type = application/octet-stream | |
Index: project/plugins/Plugins.scala | |
=================================================================== | |
--- project/plugins/Plugins.scala (revision 1338516) | |
+++ project/plugins/Plugins.scala (working copy) | |
@@ -1,23 +0,0 @@ | |
-/** |
OlderNewer