Package org.apache.ignite.migrationtools.persistence

Class MigrationCacheProcessor

java.lang.Object
org.apache.ignite.internal.processors.GridProcessorAdapter
org.apache.ignite.internal.processors.cache.GridCacheProcessor
org.apache.ignite.migrationtools.persistence.MigrationCacheProcessor
All Implemented Interfaces:
org.apache.ignite.internal.GridComponent, org.apache.ignite.internal.processors.GridProcessor
public class MigrationCacheProcessor extends org.apache.ignite.internal.processors.cache.GridCacheProcessor
This is a lazy version of the GridCacheProcessor.

This class does not start all the caches automatically during startup. Instead, it blocks the CacheRecoveryLifecycle of the underlying GridCacheProcessor. DynamicCacheDescriptors can be explicitly loaded using cacheDescriptor(String) or loadAllDescriptors(). Caches must be started explicitly using startCache(DynamicCacheDescriptor).

Important: This is not a fully featured GridCacheProcessor, it should only be used with caution in the context of a migration.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent

    org.apache.ignite.internal.GridComponent.DiscoveryDataExchangeType

  • Field Summary

    Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheProcessor

    CACHE_GRP_IO_VIEW, CACHE_GRP_IO_VIEW_DESC, CACHE_GRP_PAGE_LIST_VIEW, CACHE_GRP_PAGE_LIST_VIEW_DESC, CLUSTER_READ_ONLY_MODE_ERROR_MSG_FORMAT, DFLT_ALLOW_START_CACHES_IN_PARALLEL, EXPRITY_POLICY_MSG, PART_STATES_VIEW, PART_STATES_VIEW_DESC

    Fields inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

    ctx, diagnosticLog, log

  • Constructor Summary

    Constructors
    Constructor
    Description
    MigrationCacheProcessor(org.apache.ignite.internal.GridKernalContext ctx)
    Constructor.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.ignite.internal.processors.cache.DynamicCacheDescriptor
    cacheDescriptor(String name)
     
    Map<String,org.apache.ignite.internal.processors.cache.DynamicCacheDescriptor>
    cacheDescriptors()
     
    void
    loadAllDescriptors()
    Load all descriptors.
    Collection<org.apache.ignite.internal.processors.cache.DynamicCacheDescriptor>
    persistentCaches()
     
    void
    start()
     
    void
    startCache(org.apache.ignite.internal.processors.cache.DynamicCacheDescriptor cacheDescr)
    Starts a cache.

    Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheProcessor

    addCacheConfiguration, addjCacheProxy, awaitStarted, blockGateway, blockGateways, blockGateways, cache, cacheConfiguration, cacheDescriptor, cacheGroup, cacheGroupDescriptor, cacheGroupDescriptors, cacheGroups, cacheMode, cacheNames, caches, cacheType, checkReadOnlyState, cleanupCachesDirectories, clearStatistics, clone, collectGridNodeData, collectJoiningNodeData, completeCacheStartFuture, completeProxyInitialize, completeProxyRestart, configManager, context, createFromTemplate, createStopRequest, discoveryDataType, dynamicChangeCaches, dynamicDestroyCache, dynamicDestroyCaches, dynamicDestroyCaches, dynamicStartCache, dynamicStartCache, dynamicStartCaches, dynamicStartCachesByStoredConf, dynamicStartSqlCache, enableStatistics, enricher, exchangeTaskForCustomDiscoveryMessage, finalizePartitionsCounters, getConfigFromTemplate, getOrCreateFromTemplate, getOrCreateFromTemplate, getOrStartCache, getOrStartCache, getOrStartPublicCache, hasCachesReceivedFromJoin, internalCache, internalCaches, isCacheRestarting, isEncrypted, jcache, jcacheProxy, jcaches, keepStaticCacheConfiguration, localJoinCachesContext, onCacheStatisticsModeChange, onCustomEvent, onDisconnected, onDiscoveryEvent, onExchangeDone, onGridDataReceived, onJoiningNodeDataReceived, onKernalStart, onKernalStop, onKernalStopCaches, onReconnected, onStateChangeFinish, onStateChangeRequest, onUndeployed, persistentGroups, prepareCacheStart, prepareCacheStop, prepareCacheStop, preparePageStore, printMemoryStats, processStatisticsModeChange, publicAndDsCacheNames, publicCache, publicCacheNames, publicCaches, publicJCache, publicJCache, registrateProxyRestart, resetCacheState, resetRestartingProxies, restartProxies, saveCacheConfiguration, shutdownNotFinishedRecoveryCaches, splitter, startCachesOnLocalJoin, startReceivedCaches, stop, stopCaches, stopWarmUp, systemCache, transactions, utilityCache, validateNode, validateNode

    Methods inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

    assertParameter, toString

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

  • Constructor Details

    • MigrationCacheProcessor

      public MigrationCacheProcessor(org.apache.ignite.internal.GridKernalContext ctx)
      Constructor.

  • Method Details

    • start

      public void start() throws org.apache.ignite.IgniteCheckedException
      Specified by:
      start in interface org.apache.ignite.internal.GridComponent
      Overrides:
      start in class org.apache.ignite.internal.processors.cache.GridCacheProcessor
      Throws:
      org.apache.ignite.IgniteCheckedException

    • cacheDescriptor

      public org.apache.ignite.internal.processors.cache.DynamicCacheDescriptor cacheDescriptor(String name)
      Overrides:
      cacheDescriptor in class org.apache.ignite.internal.processors.cache.GridCacheProcessor

    • cacheDescriptors

      public Map<String,org.apache.ignite.internal.processors.cache.DynamicCacheDescriptor> cacheDescriptors()
      Overrides:
      cacheDescriptors in class org.apache.ignite.internal.processors.cache.GridCacheProcessor

    • persistentCaches

      public Collection<org.apache.ignite.internal.processors.cache.DynamicCacheDescriptor> persistentCaches()
      Overrides:
      persistentCaches in class org.apache.ignite.internal.processors.cache.GridCacheProcessor

    • loadAllDescriptors

      public void loadAllDescriptors() throws org.apache.ignite.IgniteCheckedException
      Load all descriptors.
      Throws:
      org.apache.ignite.IgniteCheckedException - in case of an error.

    • startCache

      public void startCache(org.apache.ignite.internal.processors.cache.DynamicCacheDescriptor cacheDescr)
      Starts a cache.
      Parameters:
      cacheDescr - The descriptor of the cache to be started.