ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Valentin Kulichenko <valentin.kuliche...@gmail.com>
Subject Re: Trouble Enabling Query Indexing
Date Sat, 13 Jun 2015 00:56:12 GMT
Fluffy,

You have a cache configuration in both code and XML. The one in XML is
actually used, but it doesn't provide indexed types. Your code
configuration looks correct, so I think you should simply remove it from
XML.

-Val

On Fri, Jun 12, 2015 at 1:39 PM, fluffy <fhafner@gmail.com> wrote:

> I have a very very simple example. And based on everything I know and see
> in
> the documentation, indexing should work on this with no problems. Here's
> the
> code. I'm also attaching the Spring Config File.
>
> Any help would be much appreciated....
>
> ----------------------
>
> Source Code
>
> ----------------------
> /packagegrid.test;
>
> import org.apache.ignite.*;
> import org.apache.ignite.cache.query.QueryCursor;
> import org.apache.ignite.cache.query.SqlFieldsQuery;
> import org.apache.ignite.cache.query.annotations.QuerySqlField;
> import org.apache.ignite.configuration.CacheConfiguration;
> import org.apache.ignite.logger.log4j.Log4JLogger;
>
> import java.io.Serializable;
> import java.util.Collection;
> import java.util.Iterator;
> import java.util.List;
> import java.util.UUID;
>
> public class TestCacheConfig {
>
>     public static void main(String[] args) throws IgniteException,
> InterruptedException {
>
>         Ignite ignite;
>         IgniteLogger log = new Log4JLogger();
>
>         boolean rungrid=true;
>
>         try {
>
>             log.debug("STARTING GRID....");
>             ignite = Ignition.start("<grid-cache.xml&quot;);
>             ignite.configuration().setNetworkTimeout(5000);
>             ignite.configuration().setClientMode(false);
>
>            CacheConfiguration&lt;UUID, BasicGridPoint> pointCfg = new
> CacheConfiguration<>("Points");
>
>             pointCfg.setName("Points");
>             pointCfg.setIndexedTypes(UUID.class, BasicGridPoint.class);
>
>             IgniteCache<String, BasicGridPoint> pointCache =
> ignite.cache("Points");
>             pointCache.put("dsadsa-dsadsa-dsasd",new BasicGridPoint());
>
>             while (rungrid) {
>
>                 try {
>                     log.debug("-------------------------------");
>                     log.debug(" # of Nodes: " +
> ignite.cluster().nodes().size());//+" | Grid Size: "+
> g.cache(CACHE_NAME).keySet().size());
>                     log.debug(" Local Node ID: " +
> ignite.cluster().localNode().id());
>                     log.debug(" Global Point Cache Keys: " +
> pointCache.size());
>                     log.debug("-------------------------------");
>
>
>                     SqlFieldsQuery PointTypeQuery = new
> SqlFieldsQuery("select distinct Type from BasicGridPoint");
>                     try (QueryCursor<List&lt;?>> cursor =
> pointCache.query(PointTypeQuery)) {
>                         Collection<List&lt;?>> PointTypesRaw =
> cursor.getAll();
>                         Iterator PointCountIter = PointTypesRaw.iterator();
>                         while (PointCountIter.hasNext()) {
>                             List tmpList = (List) PointCountIter.next();
>                             Iterator ListIter = tmpList.iterator();
>                             while (ListIter.hasNext()) {
>                                 String type = (String) ListIter.next();
>                                 System.out.print("Type: " + type);
>                             }
>                         }
>                     }
>
>                     Thread.sleep(10000);
>                 } catch (Exception e) {
>                     log.debug("Loop - Caught:" + e.toString());
>                     for (int i=0; i<e.getStackTrace().length; i++)
>                         log.debug(e.getStackTrace()[i].toString());
>                     Thread.sleep(10000);
>                 }
>             }
>
>             //Stopping Grid and associated subprocesses
>             log.debug(&quot;Shutting things down...&quot;);
>
>               Ignition.stop(true);
>
>
>         } catch (Exception e) {
>             log.debug(&quot;Main - Caught:&quot; + e.toString());
>         }
>
>     }
>     public static class BasicGridPoint implements Serializable {
>
>         @QuerySqlField
>         private String Type;
>         @QuerySqlField
>         private String Ident;
>
>
>         public String getType() {
>             return Type;
>         }
>
>         public void setType(String pointType) {
>             Type = pointType;
>         }
>
>         public String getIdent() {
>             return Ident;
>         }
>
>         public void setIdent(String ident) {
>             Ident = ident;
>         }
>     }
>
> }
>
> ----------------------------
>
> Spring config
>
> ---------------------------
>
> &lt;?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?>
>
> <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 id="ignite.cfg"
> class="org.apache.ignite.configuration.IgniteConfiguration">
>
>
>         <property name="peerClassLoadingEnabled" value="false"/>
>
>         <property name="marshaller">
>             <bean
> class="org.apache.ignite.marshaller.optimized.OptimizedMarshaller">
>
>                 <property name="requireSerializable" value="false"/>
>             </bean>
>         </property>
>
>
>         <property name="cacheConfiguration">
>
>                 <list>
>                 <bean
> class="org.apache.ignite.configuration.CacheConfiguration">
>                     <property name="name" value="Points"/>
>                     <property name="cacheMode" value="PARTITIONED"/>
>                     <property name="atomicityMode" value="ATOMIC"/>
>                     <property name="backups" value="0"/>
>                     <property name="offHeapMaxMemory" value="0"/>
>                     <property name="startSize" value="3000000"/>
>                 </bean>
>                 </list>
>         </property>
>
>         <property name="discoverySpi">
>             <bean
> class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
>                 <property name="ipFinder">
>                      <bean
>
> class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
>                         <property name="addresses">
>                             <list>
>                                  <value>127.0.0.1:47500..47509</value>
>                             </list>
>                         </property>
>                     </bean>
>                 </property>
>             </bean>
>         </property>
>
>     </bean>
>
> </beans>
> /
>
>
>
>
> --
> View this message in context:
> http://apache-ignite-users.70518.x6.nabble.com/Trouble-Enabling-Query-Indexing-tp377p481.html
> Sent from the Apache Ignite Users mailing list archive at Nabble.com.
>

Mime
View raw message