ignite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ilya Kasnacheev <ilya.kasnach...@gmail.com>
Subject Re: IgniteDataStreamer - into table and not key\value
Date Mon, 17 Sep 2018 14:52:39 GMT
Hello!

You don't need to remove those properties, just remove package names:
<property name="keyType" value="IndexcompositionKey"/>
<property name="valueType" value="Indexcomposition"/>

Please try and read mails carefully.

Regards,
-- 
Ilya Kasnacheev


пн, 17 сент. 2018 г. в 17:05, wt <waynetheron@gmail.com>:

> this is making no sense. There is absolutely nothing in the documentation
> that says remove those items from the configuration. All i am looking for
> is
> an example of a table that can be loaded with the data streamer without the
> data ending up outside of the table. I have tried with and without that
> simple mapper in th config and it makes no difference.
>
> simple example i have:
>
> 1) config (has no caches specified - contents placed at the end)
> 2) create table in jdbc
>
> CREATE TABLE IF NOT EXISTS Testy (
>   id int,
>   name varchar,
>    PRIMARY KEY (id)
> ) WITH "template=partitioned,backups=0";
>
> 3) table is visible in ignite
>
> {
>         "successStatus": 0,
>         "error": null,
>         "sessionToken": null,
>         "response": [
>                 {
>                         "cacheName": "SQL_PUBLIC_TESTY",
>                         "types": [
>
> "SQL_PUBLIC_TESTY_07052f5a_37ac_4992_8a19_79da93e3df8a"
>                         ],
>                         "keyClasses": {
>
> "SQL_PUBLIC_TESTY_07052f5a_37ac_4992_8a19_79da93e3df8a":
> "java.lang.Integer"
>                         },
>                         "valClasses": {
>
> "SQL_PUBLIC_TESTY_07052f5a_37ac_4992_8a19_79da93e3df8a":
> "java.lang.Object"
>                         },
>                         "fields": {
>
> "SQL_PUBLIC_TESTY_07052f5a_37ac_4992_8a19_79da93e3df8a": {
>                                         "ID": "java.lang.Integer",
>                                         "NAME": "java.lang.String"
>                                 }
>                         },
>                         "indexes": {
>
> "SQL_PUBLIC_TESTY_07052f5a_37ac_4992_8a19_79da93e3df8a": []
>                         }
>                 }}}
>
>
> 4) simple .net project
>
>
>         public class Testy
>         {
>
>             [QuerySqlField]
>             public int id { get; set; }
>             [QuerySqlField]
>             public string name { get; set; }
>
>         }
>
>             var cfg = new IgniteConfiguration()
>             {
>                 SpringConfigUrl = @"C:\Cluster-client.xml"
>             };
>
>             var ignite = Ignition.Start(cfg);
>             using (var ldr = ignite.GetDataStreamer<int,
> Testy>("SQL_PUBLIC_TESTY"))
>             {
>                 ldr.AddData(1, new Testy() {id=1, name = "ffff" });
>             }
>
>
> 5) db beaver
>
> SELECT count(*) FROM testy (result is 0)
>
> 6) rest query
>
>
> http://127.0.0.1:8080/ignite?cmd=get&cacheName=SQL_PUBLIC_TESTY&keyType=int&key=1
>
> {
>         "successStatus": 0,
>         "affinityNodeId": "9a006702-e11e-4fdc-bf84-7f0b28fc498f",
>         "error": null,
>         "sessionToken": null,
>         "response": {
>                 "name": "ffff",
>                 "id": 1
>         }
> }
>
>
>
>
> -----------------
> config file
>
> <beans xmlns="http://www.springframework.org/schema/beans"
>        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
>        xmlns:util="http://www.springframework.org/schema/util"
>        xsi:schemaLocation="http://www.springframework.org/schema/beans
>
> http://www.springframework.org/schema/beans/spring-beans.xsd
>                            http://www.springframework.org/schema/util
>
> http://www.springframework.org/schema/util/spring-util.xsd">
>
>     <bean class="org.apache.ignite.configuration.IgniteConfiguration">
>         <property name="clientMode" value="true"/>
>         <property name="igniteInstanceName" value="Cluster"/>
>
>         <property name="discoverySpi">
>             <bean
> class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
>                 <property name="ipFinder">
>                     <bean
>
> class="org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder">
>                         <property name="addresses">
>                             <list>
>                                 <value>127.0.0.1:47500..47510</value>
>                             </list>
>                         </property>
>                     </bean>
>                 </property>
>             </bean>
>         </property>
>
>         <property name="binaryConfiguration">
>             <bean
> class="org.apache.ignite.configuration.BinaryConfiguration">
>                 <property name="nameMapper">
>                     <bean
> class="org.apache.ignite.binary.BinaryBasicNameMapper">
>                         <property name="simpleName" value="true"/>
>                     </bean>
>                 </property>
>             </bean>
>         </property>
>
>         <property name="dataStorageConfiguration">
>             <bean
> class="org.apache.ignite.configuration.DataStorageConfiguration">
>                 <property name="defaultDataRegionConfiguration">
>                     <bean
> class="org.apache.ignite.configuration.DataRegionConfiguration">
>                         <property name="maxSize" value="3145728000"/>
>                         <property name="persistenceEnabled" value="true"/>
>                     </bean>
>                 </property>
>             </bean>
>         </property>
>
>     </bean>
> </beans>
>
>
>
>
>
> --
> Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message