答复: problems in test ignite PersistentStore

[罗 辉]

thank you dkarachentsev, i realized the type undefined mistake


     I correct my codes like below :

object SingleNodePersist {
  def main(args: Array[String]) {
    Ignition.setClientMode(true)
    val config = "/data/disk01/huzongxing/ignite/config/test.xml"
    val ig = Ignition.start(config)
    ig.active(true)
    val cache = ig.getOrCreateCache[Long, Int]("organization")
    val psc = new PersistentStoreConfiguration
    psc.setPersistentStorePath("/ssd")

    val streamer = ig.dataStreamer[Long, Int]("organization")
    streamer.allowOverwrite(true)
    for (i <- 1 to 10000) {
      streamer.addData(i, i)
      if (i > 0 && i % 10000 == 0)
        println("Done: " + i)
    }

    cache.close()
  }
}


and my test.xml as well:

<beans xmlns="http://www.springframework.org/schema/beans";
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd";>
    <bean id="ignite.cfg" 
class="org.apache.ignite.configuration.IgniteConfiguration">
        <!-- Enabling Apache Ignite Persistent Store. -->
        <property name="persistentStoreConfiguration">
            <bean 
class="org.apache.ignite.configuration.PersistentStoreConfiguration"/>
        </property>
        <!-- Setting up caches. -->
        <property name="cacheConfiguration">
            <list>
                <bean 
class="org.apache.ignite.configuration.CacheConfiguration">
                    <property name="name" value="organization"/>
                    <property name="backups" value="1"/>
                    <property name="atomicityMode" value="TRANSACTIONAL"/>
                    <property name="writeSynchronizationMode" 
value="FULL_SYNC"/>
<!--
                    <property name="indexedTypes">
                        <list>
                            <value>java.lang.Long</value>
                            <value>java.lang.Int</value>
                        </list>
                    </property>
-->
                </bean>
            </list>
        </property>
        <property name="binaryConfiguration">
            <bean class="org.apache.ignite.configuration.BinaryConfiguration">
                <property name="compactFooter" value="false"/>
            </bean>
        </property>
        <!-- Explicitly configure TCP discovery SPI to provide a list of 
initial nodes. -->
        <property name="discoverySpi">
            <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
                <property name="ipFinder">
                    <!-- Uncomment static IP finder to enable static-based 
discovery of initial nodes. -->
                    <!--<bean 
class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">-->
                    <bean 
class="org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder">
                        <property name="addresses">
                            <list>
                                <!-- In distributed environment, replace with 
actual host IP address. -->
                                <value>127.0.0.1:47500..47502</value>
                            </list>
                        </property>
                    </bean>
                </property>
            </bean>
        </property>
    </bean>
</beans>

after I changed my code and xml file，the test program can run normally.
I am expecting something to be written into /ssd directory , however I found 
nothing.
It seems the cache default behaviour is to store the cache data into memory 
only , not memory and disk simultaneously.
I will continue to look up the docs which you mentioned .

thanks again.


________________________________
发件人: dkarachentsev <dkarachent...@gridgain.com>
发送时间: 2017年8月18日 0:08:17
收件人: user@ignite.apache.org
主题: Re: problems in test ignite PersistentStore

Hi,

1. You need to set types for datastreamer just like for cache you did:
var streamer = ig.dataStreamer[Int, String]("organization")

2. Check that classes from ignite/examples are in classpath. It's a maven
module which has scala examples that you may play with.

3. [1, 2, 3]

[1]
https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/configuration/PersistentStoreConfiguration.html#setPersistentStorePath(java.lang.String)
[2]
https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/configuration/PersistentStoreConfiguration.html#setWalStorePath(java.lang.String)
[3]
https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/configuration/PersistentStoreConfiguration.html#setWalArchivePath(java.lang.String)

Thanks!
-Dmitry.



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/problems-in-test-ignite-PersistentStore-tp16244p16256.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.