natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix LocalPartitioner duplication in *_for_key Accord system tables 

patch by Aleksey Yeschenko; reviewed by Marcus Eriksson for
CASSANDRA-19265
This commit is contained in:
Aleksey Yeschenko 2024-01-18 15:45:05 +00:00 committed by David Capwell
parent 20af77031a
commit 5385e9c60a
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/java/org/apache/cassandra/service/accord/AccordKeyspace.java
View File

@ -192,6 +192,10 @@ public class AccordKeyspace
private static final TupleType KEY_TYPE = new TupleType(Arrays.asList(UUIDType.instance, BytesType.instance));
private static final String KEY_TUPLE = KEY_TYPE.asCQL3Type().toString();
// shared LocalPartitioner for all *_for_key Accord tables with (store_id, key_token, key) partition key
private static final LocalPartitioner FOR_KEYS_LOCAL_PARTITIONER =
new LocalPartitioner(CompositeType.getInstance(Int32Type.instance, BytesType.instance, KEY_TYPE));
private static final ClusteringIndexFilter FULL_PARTITION = new ClusteringIndexSliceFilter(Slices.ALL, false);
private enum TokenType
@ -424,7 +428,7 @@ public class AccordKeyspace
+ format("last_write_timestamp %s, ", TIMESTAMP_TUPLE)
+ "PRIMARY KEY((store_id, key_token, key))"
+ ')')
.partitioner(new LocalPartitioner(CompositeType.getInstance(Int32Type.instance, BytesType.instance, KEY_TYPE)))
.partitioner(FOR_KEYS_LOCAL_PARTITIONER)
.build();
public static class TimestampsForKeyColumns
@ -558,7 +562,7 @@ public class AccordKeyspace
+ "data blob, "
+ "PRIMARY KEY((store_id, key_token, key), timestamp)"
+ ')')
.partitioner(new LocalPartitioner(CompositeType.getInstance(Int32Type.instance, BytesType.instance, KEY_TYPE)))
.partitioner(FOR_KEYS_LOCAL_PARTITIONER)
.build();
}