diff --git a/lib/avro-1.4.0-sources~r986959.jar b/lib/avro-1.4.0~rc3-sources.jar similarity index 69% rename from lib/avro-1.4.0-sources~r986959.jar rename to lib/avro-1.4.0~rc3-sources.jar index 9bd5e2e95f..3ac7c72fe0 100644 Binary files a/lib/avro-1.4.0-sources~r986959.jar and b/lib/avro-1.4.0~rc3-sources.jar differ diff --git a/lib/avro-1.4.0~r986959.jar b/lib/avro-1.4.0~rc3.jar similarity index 70% rename from lib/avro-1.4.0~r986959.jar rename to lib/avro-1.4.0~rc3.jar index b3e2628138..6cf75c83b4 100644 Binary files a/lib/avro-1.4.0~r986959.jar and b/lib/avro-1.4.0~rc3.jar differ diff --git a/src/java/org/apache/cassandra/avro/CassandraServer.java b/src/java/org/apache/cassandra/avro/CassandraServer.java index fe75eab8d7..245433cfcd 100644 --- a/src/java/org/apache/cassandra/avro/CassandraServer.java +++ b/src/java/org/apache/cassandra/avro/CassandraServer.java @@ -279,7 +279,7 @@ public class CassandraServer implements Cassandra { } @Override - public GenericArray get_slice(ByteBuffer key, ColumnParent columnParent, + public List get_slice(ByteBuffer key, ColumnParent columnParent, SlicePredicate predicate, ConsistencyLevel consistencyLevel) throws AvroRemoteException, InvalidRequestException, UnavailableException, TimedOutException { @@ -293,7 +293,7 @@ public class CassandraServer implements Cassandra { return multigetSliceInternal(clientState.getKeyspace(), keys, columnParent, predicate, consistencyLevel).iterator().next().columns; } - private GenericArray multigetSliceInternal(String keyspace, GenericArray keys, + private List multigetSliceInternal(String keyspace, List keys, ColumnParent columnParent, SlicePredicate predicate, ConsistencyLevel consistencyLevel) throws InvalidRequestException, UnavailableException, TimedOutException { @@ -331,12 +331,12 @@ public class CassandraServer implements Cassandra { return getSlice(commands, consistencyLevel); } - private GenericArray getSlice(List commands, ConsistencyLevel consistencyLevel) + private List getSlice(List commands, ConsistencyLevel consistencyLevel) throws InvalidRequestException, UnavailableException, TimedOutException { Map, ColumnFamily> columnFamilies = readColumnFamily(commands, consistencyLevel); Schema sch = Schema.createArray(CoscsMapEntry.SCHEMA$); - GenericArray columnFamiliesList = new GenericData.Array(commands.size(), sch); + List columnFamiliesList = new GenericData.Array(commands.size(), sch); for (ReadCommand cmd : commands) { @@ -360,7 +360,7 @@ public class CassandraServer implements Cassandra { } @Override - public GenericArray multiget_slice(GenericArray keys, ColumnParent columnParent, + public List multiget_slice(List keys, ColumnParent columnParent, SlicePredicate predicate, ConsistencyLevel consistencyLevel) throws AvroRemoteException, InvalidRequestException, UnavailableException, TimedOutException { @@ -442,7 +442,7 @@ public class CassandraServer implements Cassandra { } @Override - public Void batch_mutate(GenericArray mutationMap, ConsistencyLevel consistencyLevel) + public Void batch_mutate(List mutationMap, ConsistencyLevel consistencyLevel) throws AvroRemoteException, InvalidRequestException, UnavailableException, TimedOutException { if (logger.isDebugEnabled()) @@ -453,9 +453,9 @@ public class CassandraServer implements Cassandra { for (MutationsMapEntry pair: mutationMap) { AvroValidation.validateKey(pair.key.array()); - Map> cfToMutations = pair.mutations; + Map> cfToMutations = pair.mutations; - for (Map.Entry> cfMutations : cfToMutations.entrySet()) + for (Map.Entry> cfMutations : cfToMutations.entrySet()) { String cfName = cfMutations.getKey().toString(); @@ -493,11 +493,11 @@ public class CassandraServer implements Cassandra { } // FIXME: This is copypasta from o.a.c.db.RowMutation, (RowMutation.getRowMutation uses Thrift types directly). - private static RowMutation getRowMutationFromMutations(String keyspace, byte[] key, Map> cfMap) + private static RowMutation getRowMutationFromMutations(String keyspace, byte[] key, Map> cfMap) { RowMutation rm = new RowMutation(keyspace, key); - for (Map.Entry> entry : cfMap.entrySet()) + for (Map.Entry> entry : cfMap.entrySet()) { String cfName = entry.getKey().toString();