如何使用 Ignite 创建我自己的 CacheStore 以二进制模式存储值 (setStoreKeepBinary(true))

Question

我想使用 Slick 创建自己的 CacheStore，以将数据值存储在 Postgres 数据库中的 BinaryMode 中。我在 Ignite 网站上阅读了与 Binary Marshaller 相关的文档。我受到这里代码的启发 https://github.com/gastonlucero/ignite-persistence/blob/master/src/main/scala/test/db/CachePostgresSlickStore.scala

所以我创建了该代码：

val myCacheCfg = new CacheConfiguration[String, MySpecialCustomObject]("MYCACHE")
myCacheCfg.setStoreKeepBinary(true)
myCacheCfg.setCacheStoreFactory(FactoryBuilder.factoryOf(classOf[myCacheSlickStore]))
myCacheCfg.setBackups(1)
myCacheCfg.setCacheMode(CacheMode.LOCAL)
myCacheCfg.setReadThrough(true)
myCacheCfg.setWriteThrough(true)

.......

class myCacheSlickStore extends CacheStoreAdapter[String, MySpecialCustomObject] with PostgresSlickConnection with Serializable {.....}

......

trait PostgresSlickConnection extends PostgresSlickParameters {

  val tableName: String
}

但是我有这种错误：“类型不匹配；”对于与 setCacheStoreFactory

相关的行

您有任何想法或示例可以使用 setStoreKeepBinary(true) 创建您自己的 CacheStore 吗？

Here a complete example to illustrate :

final case class myObject(
  parameters_1: Map[String, Set[String]],
  parameters_2: Map[String, Set[String]]
)

class CacheSlickStore extends CacheStoreAdapter[String, BinaryObject] {}


val JdbcPersistence =
      "myJdbcPersistence" 
val cacheCfg =
      new CacheConfiguration[String, myObject](JdbcPersistence)
cacheCfg.setStoreKeepBinary(true) 
cacheCfg.setCacheStoreFactory(
      FactoryBuilder.factoryOf(classOf[CacheSlickStore])
)
cacheCfg.setBackups(1)
cacheCfg.setCacheMode(CacheMode.LOCAL)
cacheCfg.setReadThrough(true)
cacheCfg.setWriteThrough(true)

var cache: IgniteCache[String, myObject] = _

val config = new IgniteConfiguration()

ignition = Ignition.getOrStart(config)

cache = ignition.getOrCreateCache[String, myObject](JdbcPersistence)
ignition.addCacheConfiguration(cacheCfg)

如果我强制转换 CacheConfiguration，它会编译但无法运行。

Answer 1

最后的解决方案是在 Scala 中强制转换为 Any 而不是 BinaryObject。您可以在这里找到解决方案 Github project

如何使用 Ignite 创建我自己的 CacheStore 以二进制模式存储值 (setStoreKeepBinary(true))

How to create my own CacheStore with Ignite to store value in Binary mode (setStoreKeepBinary(true))

scala

slick

ignite