Author: eevans
Date: Mon Apr 5 17:01:15 2010
New Revision: 930901
URL: http://svn.apache.org/viewvc?rev=930901&view=rev
Log:
avro protocol schema changes for batch_mutate()
Patch by eevans
Modified:
cassandra/trunk/interface/cassandra.avpr
Modified: cassandra/trunk/interface/cassandra.avpr
URL:
http://svn.apache.org/viewvc/cassandra/trunk/interface/cassandra.avpr?rev=930901&r1=930900&r2=930901&view=diff
==============================================================================
--- cassandra/trunk/interface/cassandra.avpr (original)
+++ cassandra/trunk/interface/cassandra.avpr Mon Apr 5 17:01:15 2010
@@ -29,6 +29,36 @@
{"name": "super_column", "type": ["SuperColumn", "null"]}
]
},
+ {"name": "SliceRange", "type": "record",
+ "fields": [
+ {"name": "start", "type": "bytes"},
+ {"name": "finish", "type": "bytes"},
+ {"name": "reversed", "type": "boolean", "default": false},
+ {"name": "count", "type": "int", "default": 100},
+ {"name": "bitmasks", "type": {"type": "array", "items": "bytes"}}
+ ]
+ },
+ {"name": "SlicePredicate", "type": "record",
+ "fields": [
+ {"name": "column_names",
+ "type": [{"type": "array", "items": "bytes"}, "null"]},
+ {"name": "slice_range", "type": ["SliceRange", "null"]}
+ ]
+ },
+ {"name": "Deletion", "type": "record",
+ "fields": [
+ {"name": "timestamp", "type": "long"},
+ {"name": "super_column", "type": ["bytes", "null"]},
+ {"name": "predicate", "type": ["SlicePredicate", "null"]}
+ ]
+ },
+ {"name": "Mutation", "type": "record",
+ "fields": [
+ {"name": "column_or_supercolumn",
+ "type": ["ColumnOrSuperColumn", "null"]},
+ {"name": "deletion", "type": ["Deletion", "null"]}
+ ]
+ },
{"name": "ConsistencyLevel", "type": "enum",
"symbols": [
"ZERO", "ONE", "QUORUM", "DCQUORUM", "DCQUORUMSYNC", "ALL"
@@ -92,6 +122,24 @@
"errors": ["InvalidRequestException", "UnavailableException",
"TimedOutException"]
},
+ "batch_mutate": {
+ "request": [
+ {"name": "keyspace", "type": "string"},
+ /* Map<String, Map<String, List<Mutation>>> mutation_map */
+ {"name": "mutation_map",
+ "type": {
+ "type": "map", "values": {
+ "type": "map", "values": {
+ "type": "array", "items": "Mutation"}
+ }
+ }
+ },
+ {"name": "consistency_level", "type": "ConsistencyLevel"}
+ ],
+ "response": "null",
+ "errors": ["InvalidRequestException", "UnavailableException",
+ "TimedOutException"]
+ },
"get_api_version": {
"request": [],
"response": "string"
