| Package | Description |
|---|---|
| org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
| org.apache.ignite.internal |
Contains main implementation.
|
| org.apache.ignite.internal.processors.cache | |
| org.apache.ignite.internal.processors.datastreamer |
Data streamer processor.
|
| org.apache.ignite.internal.processors.dr |
Data center replication processor. |
| org.apache.ignite.internal.processors.platform.cache | |
| org.apache.ignite.internal.processors.platform.datastreamer | |
| org.apache.ignite.stream |
Contains Ignite Streamer classes.
|
| Modifier and Type | Method and Description |
|---|---|
<K,V> IgniteCache<K,V> |
Ignite.cache(String name)
Gets an instance of
IgniteCache API. |
<K,V> IgniteCache<K,V> |
Ignite.createCache(CacheConfiguration<K,V> cacheCfg)
Dynamically starts new cache with the given cache configuration.
|
<K,V> IgniteCache<K,V> |
Ignite.createCache(CacheConfiguration<K,V> cacheCfg,
NearCacheConfiguration<K,V> nearCfg)
Dynamically starts new cache with the given cache configuration.
|
<K,V> IgniteCache<K,V> |
Ignite.createCache(String cacheName)
Dynamically starts new cache using template configuration.
|
<K,V> IgniteCache<K,V> |
Ignite.createNearCache(String cacheName,
NearCacheConfiguration<K,V> nearCfg)
Starts a near cache on local node if cache was previously started with one of the
Ignite.createCache(CacheConfiguration) or Ignite.createCache(CacheConfiguration, NearCacheConfiguration)
methods. |
<K,V> IgniteCache<K,V> |
Ignite.getOrCreateCache(CacheConfiguration<K,V> cacheCfg)
Gets existing cache with the given name or creates new one with the given configuration.
|
<K,V> IgniteCache<K,V> |
Ignite.getOrCreateCache(CacheConfiguration<K,V> cacheCfg,
NearCacheConfiguration<K,V> nearCfg)
Gets existing cache with the given cache configuration or creates one if it does not exist.
|
<K,V> IgniteCache<K,V> |
Ignite.getOrCreateCache(String cacheName)
Gets existing cache with the given name or creates new one using template configuration.
|
<K,V> IgniteCache<K,V> |
Ignite.getOrCreateNearCache(String cacheName,
NearCacheConfiguration<K,V> nearCfg)
Gets existing near cache with the given name or creates a new one.
|
IgniteCache<K,V> |
IgniteCache.withAsync()
Deprecated.
|
IgniteCache<K,V> |
IgniteCache.withExpiryPolicy(javax.cache.expiry.ExpiryPolicy plc)
Returns cache with the specified expired policy set.
|
<K1,V1> IgniteCache<K1,V1> |
IgniteCache.withKeepBinary()
Returns cache that will operate with binary objects.
|
IgniteCache<K,V> |
IgniteCache.withNoRetries() |
IgniteCache<K,V> |
IgniteCache.withPartitionRecover()
Gets an instance of
IgniteCache that will be allowed to execute cache operations (read, write)
regardless of partition loss policy. |
IgniteCache<K,V> |
IgniteCache.withSkipStore() |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgniteCache> |
Ignite.createCaches(Collection<CacheConfiguration> cacheCfgs)
Dynamically starts new caches with the given cache configurations.
|
Collection<IgniteCache> |
Ignite.getOrCreateCaches(Collection<CacheConfiguration> cacheCfgs)
Gets existing caches with the given name or created one with the given configuration.
|
| Modifier and Type | Method and Description |
|---|---|
<K,V> IgniteCache<K,V> |
IgniteKernal.cache(String name)
Gets an instance of
IgniteCache API. |
<K,V> IgniteCache<K,V> |
IgniteKernal.createCache(CacheConfiguration<K,V> cacheCfg)
Dynamically starts new cache with the given cache configuration.
|
<K,V> IgniteCache<K,V> |
IgniteKernal.createCache(CacheConfiguration<K,V> cacheCfg,
NearCacheConfiguration<K,V> nearCfg)
Dynamically starts new cache with the given cache configuration.
|
<K,V> IgniteCache<K,V> |
IgniteKernal.createCache(String cacheName)
Dynamically starts new cache using template configuration.
|
<K,V> IgniteCache<K,V> |
IgniteKernal.createNearCache(String cacheName,
NearCacheConfiguration<K,V> nearCfg)
Starts a near cache on local node if cache was previously started with one of the
Ignite.createCache(CacheConfiguration) or Ignite.createCache(CacheConfiguration, NearCacheConfiguration)
methods. |
<K,V> IgniteCache<K,V> |
IgniteKernal.getOrCreateCache(CacheConfiguration<K,V> cacheCfg)
Gets existing cache with the given name or creates new one with the given configuration.
|
<K,V> IgniteCache<K,V> |
IgniteKernal.getOrCreateCache(CacheConfiguration<K,V> cacheCfg,
NearCacheConfiguration<K,V> nearCfg)
Gets existing cache with the given cache configuration or creates one if it does not exist.
|
<K,V> IgniteCache<K,V> |
IgniteKernal.getOrCreateCache(String cacheName)
Gets existing cache with the given name or creates new one using template configuration.
|
<K,V> IgniteCache<K,V> |
IgniteKernal.getOrCreateNearCache(String cacheName,
NearCacheConfiguration<K,V> nearCfg)
Gets existing near cache with the given name or creates a new one.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<IgniteCache> |
IgniteKernal.createCaches(Collection<CacheConfiguration> cacheCfgs)
Dynamically starts new caches with the given cache configurations.
|
Collection<IgniteCache> |
IgniteKernal.getOrCreateCaches(Collection<CacheConfiguration> cacheCfgs)
Gets existing caches with the given name or created one with the given configuration.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteCacheProxy<K,V>
Cache proxy.
|
| Modifier and Type | Method and Description |
|---|---|
protected IgniteCache<K,V> |
IgniteCacheProxy.createAsyncInstance()
Creates component with asynchronous mode enabled.
|
<K1,V1> IgniteCache<K1,V1> |
IgniteCacheProxy.keepBinary()
Creates projection that will operate with binary objects.
|
IgniteCache<K,V> |
IgniteCacheProxy.skipStore() |
IgniteCache<K,V> |
IgniteCacheProxy.withDataCenterId(byte dataCenterId) |
IgniteCache<K,V> |
IgniteCacheProxy.withExpiryPolicy(javax.cache.expiry.ExpiryPolicy plc)
Returns cache with the specified expired policy set.
|
<K1,V1> IgniteCache<K1,V1> |
IgniteCacheProxy.withKeepBinary()
Returns cache that will operate with binary objects.
|
IgniteCache<K,V> |
IgniteCacheProxy.withNoRetries() |
IgniteCache<K,V> |
IgniteCacheProxy.withPartitionRecover()
Gets an instance of
IgniteCache that will be allowed to execute cache operations (read, write)
regardless of partition loss policy. |
IgniteCache<K,V> |
IgniteCacheProxy.withSkipStore() |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> void |
GridCacheUtils.inTx(Ignite ignite,
IgniteCache<K,V> cache,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
IgniteInClosureX<IgniteCache<K,V>> clo)
Execute closure inside cache transaction.
|
static <K,V> void |
GridCacheUtils.invalidate(IgniteCache<K,V> cache,
K key)
Invalidate entry in cache.
|
| Modifier and Type | Method and Description |
|---|---|
static <K,V> void |
GridCacheUtils.inTx(Ignite ignite,
IgniteCache<K,V> cache,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
IgniteInClosureX<IgniteCache<K,V>> clo)
Execute closure inside cache transaction.
|
| Modifier and Type | Method and Description |
|---|---|
void |
DataStreamerImpl.IsolatedUpdater.receive(IgniteCache<KeyCacheObject,CacheObject> cache,
Collection<Map.Entry<KeyCacheObject,CacheObject>> entries)
Updates cache with batch of entries.
|
protected static <K,V> void |
DataStreamerCacheUpdaters.updateAll(IgniteCache<K,V> cache,
Set<K> rmvCol,
Map<K,V> putMap)
Updates cache.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteDrDataStreamerCacheUpdater.receive(IgniteCache<KeyCacheObject,CacheObject> cache0,
Collection<Map.Entry<KeyCacheObject,CacheObject>> col)
Updates cache with batch of entries.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteCache |
PlatformCache.rawCache() |
| Constructor and Description |
|---|
PlatformCache(PlatformContext platformCtx,
IgniteCache cache,
boolean keepBinary)
Constructor.
|
PlatformCache(PlatformContext platformCtx,
IgniteCache cache,
boolean keepBinary,
PlatformCacheExtension[] exts)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformStreamReceiverImpl.receive(IgniteCache<Object,Object> cache,
Collection<Map.Entry<Object,Object>> collection)
Updates cache with batch of entries.
|
| Modifier and Type | Method and Description |
|---|---|
void |
StreamTransformer.receive(IgniteCache<K,V> cache,
Collection<Map.Entry<K,V>> entries)
Updates cache with batch of entries.
|
void |
StreamVisitor.receive(IgniteCache<K,V> cache,
Collection<Map.Entry<K,V>> entries)
Updates cache with batch of entries.
|
void |
StreamReceiver.receive(IgniteCache<K,V> cache,
Collection<Map.Entry<K,V>> entries)
Updates cache with batch of entries.
|
| Modifier and Type | Method and Description |
|---|---|
static <K,V> StreamVisitor<K,V> |
StreamVisitor.from(IgniteBiInClosure<IgniteCache<K,V>,Map.Entry<K,V>> c)
Creates a new visitor based on instance of
IgniteBiInClosure. |
Follow @ApacheIgnite
Ignite Fabric : ver. 2.0.0 Release Date : April 30 2017