我正在运行一个用scala编写的应用程序,它使用spark、ignite,并将writethrough缓存持久化到cassandra。在ignite base concepts代码中,您应该将cachestorefactory设置为:
<property name="cacheStoreFactory">
<bean class="org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory">
<!-- Datasource configuration bean which is responsible for Cassandra connection details -->
<property name="dataSourceBean" value="cassandraDataSource"/>
<!-- Persistent settings bean which is responsible for the details of how objects will be persisted to Cassandra -->
<property name="persistenceSettingsBean" value="cache1_persistence_settings"/>
</bean>
</property>
然而,当我运行应用程序时,我得到了一个错误:
java.lang.illegalstateexception异常:
未能获取cassandra数据源,因为spring应用程序上下文未注入cassandracachestorefactory
所有ignite.xml、connection-settings.xml和cassandra-store.xml的编写方式都与apacheignite-cassandra集成页面上的示例相同。指定cassandra数据源的spring应用程序上下文的xml文档中是否缺少某些内容?
暂无答案!
目前还没有任何答案,快来回答吧!