Что, где и как я должен что то зарегестрировать как кодек для пользовательского типа
определил тип
@UDT(name = "bucket", keyspace = "us")
public class BucketType {
@Field(name = "event_time")
private Date eventTime;
@Field(name = "product_id")
private String productId;
//setters and getters
}
структура таблицы
CREATE TABLE keyspace.shops (
user_id stext,
buckets list<frozen <bucket>>
PRIMARY KEY (user_id));
Зависимости
compile group: 'com.datastax.cassandra', name: 'cassandra-driver-mapping', version: '3.5.0'
compile group: 'com.datastax.cassandra', name: 'cassandra-driver-core', version: '3.5.0'
Делаю запрос в cassandra
Session session = cluster.connect();
ResultSet resultSet = session.execute("select * from keyspace.shops;");
resultSet.forEach(row -> {
List<BucketType> list1 = row.getList(1, BucketType.class);
}
Пробовал разные методы get, getValue, и индексы разные Выдает ошибку
com.datastax.driver.core.exceptions.CodecNotFoundException: Codec not found for requested operation: [ups.cart_add <-> com.test.entity.type.BucketType]
at com.datastax.driver.core.CodecRegistry.notFound(CodecRegistry.java:741) ~[cassandra-driver-core-3.5.0.jar:na]
at com.datastax.driver.core.CodecRegistry.createCodec(CodecRegistry.java:588) ~[cassandra-driver-core-3.5.0.jar:na]
at com.datastax.driver.core.CodecRegistry.findCodec(CodecRegistry.java:558) ~[cassandra-driver-core-3.5.0.jar:na]
row.getList("buckets", BucketType.class)
row.getList("buckets", TypeToken.of(BucketType.class))
cluster.connect("ups")
.