Skip to content

Commit

Permalink
ignite-sql-tests - tests
Browse files Browse the repository at this point in the history
  • Loading branch information
S.Vladykin committed Feb 25, 2015
1 parent 29f294a commit 17b75ae
Show file tree
Hide file tree
Showing 6 changed files with 11 additions and 9 deletions.
Expand Up @@ -15,7 +15,7 @@
* limitations under the License. * limitations under the License.
*/ */


package org.apache.ignite.internal.processors.cache.query.reducefields; package org.apache.ignite.internal.processors.cache.reducefields;


import org.apache.ignite.cache.*; import org.apache.ignite.cache.*;
import org.apache.ignite.cache.affinity.*; import org.apache.ignite.cache.affinity.*;
Expand Down Expand Up @@ -80,7 +80,7 @@ protected CacheDistributionMode distributionMode() {
* @return Cache. * @return Cache.
*/ */
private CacheConfiguration cache(@Nullable String name) { private CacheConfiguration cache(@Nullable String name) {
CacheConfiguration cache = defaultCacheConfiguration(); CacheConfiguration<?,?> cache = defaultCacheConfiguration();


cache.setName(name); cache.setName(name);
cache.setCacheMode(cacheMode()); cache.setCacheMode(cacheMode());
Expand All @@ -89,7 +89,10 @@ private CacheConfiguration cache(@Nullable String name) {
cache.setWriteSynchronizationMode(FULL_SYNC); cache.setWriteSynchronizationMode(FULL_SYNC);
cache.setPreloadMode(SYNC); cache.setPreloadMode(SYNC);
cache.setQueryIndexEnabled(true); cache.setQueryIndexEnabled(true);
cache.setIndexedTypes(); cache.setIndexedTypes(
String.class, Organization.class,
CacheAffinityKey.class, Person.class
);


if (cacheMode() == PARTITIONED) if (cacheMode() == PARTITIONED)
cache.setBackups(1); cache.setBackups(1);
Expand Down
Expand Up @@ -15,7 +15,7 @@
* limitations under the License. * limitations under the License.
*/ */


package org.apache.ignite.internal.processors.cache.query.reducefields; package org.apache.ignite.internal.processors.cache.reducefields;


import org.apache.ignite.cache.*; import org.apache.ignite.cache.*;


Expand Down
Expand Up @@ -15,7 +15,7 @@
* limitations under the License. * limitations under the License.
*/ */


package org.apache.ignite.internal.processors.cache.query.reducefields; package org.apache.ignite.internal.processors.cache.reducefields;


import org.apache.ignite.cache.*; import org.apache.ignite.cache.*;


Expand Down
Expand Up @@ -15,11 +15,10 @@
* limitations under the License. * limitations under the License.
*/ */


package org.apache.ignite.internal.processors.cache.query.reducefields; package org.apache.ignite.internal.processors.cache.reducefields;


import org.apache.ignite.cache.*; import org.apache.ignite.cache.*;
import org.apache.ignite.internal.processors.cache.query.*; import org.apache.ignite.internal.processors.cache.query.*;
import org.apache.ignite.internal.processors.cache.query.*;
import org.apache.ignite.internal.*; import org.apache.ignite.internal.*;
import org.apache.ignite.lang.*; import org.apache.ignite.lang.*;


Expand Down
Expand Up @@ -15,7 +15,7 @@
* limitations under the License. * limitations under the License.
*/ */


package org.apache.ignite.internal.processors.cache.query.reducefields; package org.apache.ignite.internal.processors.cache.reducefields;


import org.apache.ignite.cache.*; import org.apache.ignite.cache.*;


Expand Down
Expand Up @@ -24,7 +24,7 @@
import org.apache.ignite.internal.processors.cache.local.*; import org.apache.ignite.internal.processors.cache.local.*;
import org.apache.ignite.internal.processors.cache.query.*; import org.apache.ignite.internal.processors.cache.query.*;
import org.apache.ignite.internal.processors.cache.query.continuous.*; import org.apache.ignite.internal.processors.cache.query.continuous.*;
import org.apache.ignite.internal.processors.cache.query.reducefields.*; import org.apache.ignite.internal.processors.cache.reducefields.*;
import org.apache.ignite.internal.processors.query.h2.sql.*; import org.apache.ignite.internal.processors.query.h2.sql.*;
import org.apache.ignite.spi.communication.tcp.*; import org.apache.ignite.spi.communication.tcp.*;


Expand Down

0 comments on commit 17b75ae

Please sign in to comment.