Skip to content

Commit

Permalink
ignite-sql-old - rename
Browse files Browse the repository at this point in the history
  • Loading branch information
S.Vladykin committed Feb 14, 2015
1 parent d026ccf commit 72ec8d6
Show file tree
Hide file tree
Showing 11 changed files with 29 additions and 25 deletions.
Expand Up @@ -21,7 +21,6 @@
import org.apache.ignite.cache.*;
import org.apache.ignite.cache.affinity.*;
import org.apache.ignite.cache.eviction.*;
import org.apache.ignite.cache.query.*;
import org.apache.ignite.cache.store.*;
import org.apache.ignite.internal.util.typedef.internal.*;
import org.apache.ignite.spi.indexing.*;
Expand Down Expand Up @@ -1434,7 +1433,7 @@ public void setAffinityMapper(CacheAffinityKeyMapper affMapper) {
* SPI is configured. In majority of the cases default value should be used.
*
* @return Name of SPI to use for indexing.
* @see GridIndexingSpi
* @see IndexingSpi
*/
public String getIndexingSpiName() {
return indexingSpiName;
Expand All @@ -1448,7 +1447,7 @@ public String getIndexingSpiName() {
* SPI is configured. In majority of the cases default value should be used.
*
* @param indexingSpiName Name.
* @see GridIndexingSpi
* @see IndexingSpi
*/
public void setIndexingSpiName(String indexingSpiName) {
this.indexingSpiName = indexingSpiName;
Expand Down
Expand Up @@ -314,7 +314,7 @@ public class IgniteConfiguration {
private SwapSpaceSpi swapSpaceSpi;

/** Indexing SPI. */
private GridIndexingSpi indexingSpi;
private IndexingSpi indexingSpi;

/** Address resolver. */
private AddressResolver addrRslvr;
Expand Down Expand Up @@ -1808,12 +1808,12 @@ public SwapSpaceSpi getSwapSpaceSpi() {
}

/**
* Sets fully configured instances of {@link org.apache.ignite.spi.indexing.GridIndexingSpi}.
* Sets fully configured instances of {@link IndexingSpi}.
*
* @param indexingSpi Fully configured instances of {@link org.apache.ignite.spi.indexing.GridIndexingSpi}.
* @param indexingSpi Fully configured instances of {@link IndexingSpi}.
* @see IgniteConfiguration#getIndexingSpi()
*/
public void setIndexingSpi(GridIndexingSpi indexingSpi) {
public void setIndexingSpi(IndexingSpi indexingSpi) {
this.indexingSpi = indexingSpi;
}

Expand All @@ -1822,7 +1822,7 @@ public void setIndexingSpi(GridIndexingSpi indexingSpi) {
*
* @return Indexing SPI implementation.
*/
public GridIndexingSpi getIndexingSpi() {
public IndexingSpi getIndexingSpi() {
return indexingSpi;
}

Expand Down
Expand Up @@ -50,6 +50,7 @@
import org.apache.ignite.spi.failover.*;
import org.apache.ignite.spi.failover.always.*;
import org.apache.ignite.spi.indexing.*;
import org.apache.ignite.spi.indexing.noop.*;
import org.apache.ignite.spi.loadbalancing.*;
import org.apache.ignite.spi.loadbalancing.roundrobin.*;
import org.apache.ignite.spi.swapspace.*;
Expand Down Expand Up @@ -1448,7 +1449,7 @@ private void start0(GridStartContext startCtx) throws IgniteCheckedException {
FailoverSpi[] failSpi = cfg.getFailoverSpi();
LoadBalancingSpi[] loadBalancingSpi = cfg.getLoadBalancingSpi();
SwapSpaceSpi swapspaceSpi = cfg.getSwapSpaceSpi();
GridIndexingSpi indexingSpi = cfg.getIndexingSpi();
IndexingSpi indexingSpi = cfg.getIndexingSpi();

execSvc = new IgniteThreadPoolExecutor(
"pub-" + cfg.getGridName(),
Expand Down Expand Up @@ -1635,7 +1636,7 @@ else if (marsh instanceof OptimizedMarshaller && !U.isHotSpot()) {
}

if (indexingSpi == null)
indexingSpi = new GridNoopIndexingSpi();
indexingSpi = new NoopIndexingSpi();

myCfg.setCommunicationSpi(commSpi);
myCfg.setDiscoverySpi(discoSpi);
Expand Down
Expand Up @@ -30,7 +30,7 @@
/**
* Manages cache indexing.
*/
public class GridIndexingManager extends GridManagerAdapter<GridIndexingSpi> {
public class GridIndexingManager extends GridManagerAdapter<IndexingSpi> {
/** */
private final GridSpinBusyLock busyLock = new GridSpinBusyLock();

Expand Down
Expand Up @@ -151,7 +151,7 @@ public GridCacheQueriesImpl(GridCacheContext<K, V> ctx, @Nullable GridCacheProje
}

/**
* Query for {@link GridIndexingSpi}.
* Query for {@link IndexingSpi}.
*
* @return Query.
*/
Expand Down
Expand Up @@ -43,7 +43,7 @@ public interface GridCacheSqlMetadata extends Externalizable {
* <p>
* By default, type name is equal to simple class name
* of stored object, but it can depend on implementation
* of {@link GridIndexingSpi}.
* of {@link IndexingSpi}.
*
* @return Collection of available types.
*/
Expand Down
Expand Up @@ -20,6 +20,7 @@
import org.apache.ignite.spi.*;
import org.jetbrains.annotations.*;

import javax.cache.*;
import java.util.*;

/**
Expand Down Expand Up @@ -57,17 +58,17 @@
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
*/
public interface GridIndexingSpi extends IgniteSpi {
public interface IndexingSpi extends IgniteSpi {
/**
* Executes query.
*
* @param spaceName Space name.
* @param params Query parameters.
* @param filters System filters.
* @return Query result.
* @return Query result. If the iterator implements {@link AutoCloseable} it will be correctly closed.
* @throws IgniteSpiException If failed.
*/
public Iterator<?> query(@Nullable String spaceName, Collection<Object> params,
public Iterator<Cache.Entry<?,?>> query(@Nullable String spaceName, Collection<Object> params,
@Nullable IndexingQueryFilter filters) throws IgniteSpiException;

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

package org.apache.ignite.spi.indexing;
package org.apache.ignite.spi.indexing.noop;

import org.apache.ignite.spi.*;
import org.apache.ignite.spi.indexing.*;
import org.jetbrains.annotations.*;

import javax.cache.*;
import java.util.*;

/**
* Default implementation of {@link GridIndexingSpi} which does not index cache.
* Default implementation of {@link IndexingSpi} which does not index cache.
*/
@IgniteSpiNoop
public class GridNoopIndexingSpi extends IgniteSpiAdapter implements GridIndexingSpi {
public class NoopIndexingSpi extends IgniteSpiAdapter implements IndexingSpi {
/** {@inheritDoc} */
@Override public Iterator<?> query(@Nullable String spaceName, Collection<Object> params,
@Override public Iterator<Cache.Entry<?,?>> query(@Nullable String spaceName, Collection<Object> params,
@Nullable IndexingQueryFilter filters) throws IgniteSpiException {
throw new IgniteSpiException("You have to configure custom GridIndexingSpi implementation.");
}
Expand Down
Expand Up @@ -588,7 +588,7 @@ private Integer keyForNode(ClusterNode node, int type) {
/**
* Indexing SPI that can fail on demand.
*/
private static class TestIndexingSpi extends IgniteSpiAdapter implements GridIndexingSpi {
private static class TestIndexingSpi extends IgniteSpiAdapter implements IndexingSpi {
/** Fail flag. */
private volatile boolean fail;

Expand All @@ -600,7 +600,8 @@ public void forceFail(boolean fail) {
}

/** {@inheritDoc} */
@Override public Iterator<?> query(@Nullable String spaceName, Collection<Object> params, @Nullable IndexingQueryFilter filters) throws IgniteSpiException {
@Override public Iterator<Cache.Entry<?,?>> query(@Nullable String spaceName, Collection<Object> params,
@Nullable IndexingQueryFilter filters) throws IgniteSpiException {
throw new UnsupportedOperationException();
}

Expand Down
Expand Up @@ -88,7 +88,7 @@
* different key types
* </li>
* </ul>
* @see GridIndexingSpi
* @see IndexingSpi
*/
@SuppressWarnings({"UnnecessaryFullyQualifiedName", "NonFinalStaticVariableUsedInClassInitialization"})
public class IgniteH2Indexing implements GridQueryIndexing {
Expand Down
4 changes: 2 additions & 2 deletions pom.xml
Expand Up @@ -769,7 +769,7 @@
</group>
<group>
<title>SPI: Indexing</title>
<packages>org.apache.ignite.spi.indexing:org.apache.ignite.spi.indexing.h2</packages>
<packages>org.apache.ignite.spi.indexing:org.apache.ignite.spi.indexing.noop</packages>
</group>
<group>
<title>SPI: Load Balancing</title>
Expand Down Expand Up @@ -964,7 +964,7 @@
</group>
<group>
<title>SPI: Indexing</title>
<packages>org.apache.ignite.spi.indexing:org.apache.ignite.spi.indexing.h2</packages>
<packages>org.apache.ignite.spi.indexing:org.apache.ignite.spi.indexing.noop</packages>
</group>
<group>
<title>SPI: Load Balancing</title>
Expand Down

0 comments on commit 72ec8d6

Please sign in to comment.