Package | Description |
---|---|
org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
org.apache.ignite.cache |
Contains main Data Grid APIs.
|
org.apache.ignite.cache.hibernate |
Contains implementation of Hibernate L2 cache.
|
org.apache.ignite.cache.store.jdbc |
Contains reference JDBC-based cache store implementation.
|
org.apache.ignite.cluster |
Contains cluster-related classes.
|
org.apache.ignite.failure |
Contains Failure handling public API with standard FailureHandler implementations.
|
org.apache.ignite.hadoop.planner |
Ignite Hadoop Accelerator planner classes.
|
org.apache.ignite.messaging |
Contains Topic-based Messaging functionality.
|
org.apache.ignite.ml.dataset |
Base package for machine learning dataset classes.
|
org.apache.ignite.ml.dataset.impl.cache |
Base package for cache based implementation of machine learning dataset.
|
org.apache.ignite.ml.dataset.impl.cache.util |
Contains util classes used in cache based implementation of dataset.
|
org.apache.ignite.ml.genetic |
Root GA package (GA Grid)
|
org.apache.ignite.ml.genetic.utils |
Contains utils for GA Grid
|
org.apache.ignite.ml.pipeline |
Contains Pipeline API.
|
org.apache.ignite.ml.preprocessing |
Base package for machine learning preprocessing classes.
|
org.apache.ignite.ml.selection.cv |
Root package for cross-validation algorithms.
|
org.apache.ignite.ml.trainers |
Contains model trainers.
|
org.apache.ignite.osgi |
Contains OSGi related classes.
|
org.apache.ignite.plugin |
Contains plugins management API.
|
org.apache.ignite.sink.flink |
IgniteSink -- streaming connector integration with Apache Flink.
|
org.apache.ignite.spi |
Contains common classes and interfaces for SPI implementations.
|
org.apache.ignite.spi.communication.tcp |
Contains default TCP/IP-based implementation for communication SPI.
|
org.apache.ignite.spi.discovery.tcp |
Contains default TCP/IP implementation for discovery SPI.
|
org.apache.ignite.spi.discovery.tcp.ipfinder |
Contains IP finder interface and adapter.
|
org.apache.ignite.spi.encryption.keystore |
Contains encryption SPI implementation based on standard jdk keystore.
|
org.apache.ignite.springdata.repository.support |
Package contains supporting files required by Spring Data framework.
|
org.apache.ignite.springdata20.repository.support |
Package contains supporting files required by Spring Data framework.
|
org.apache.ignite.stream |
Contains Ignite Streamer classes.
|
org.apache.ignite.stream.kafka.connect |
Contains implementation of Kafka Streamer Connector.
|
org.apache.ignite.stream.storm |
StormStreamer -- integration with Apache Storm.
|
org.apache.ignite.tensorflow.cluster |
TensorFlow integration API that allows to start and maintain TensorFlow cluster using infrastructure tools from
package
org.apache.ignite.tensorflow.core . |
org.apache.ignite.tensorflow.cluster.spec |
Contains specifications that describes TensorFlow cluster configuration.
|
org.apache.ignite.tensorflow.cluster.tfrunning |
Additional "running" layer on top of Python running layer of infrastructure.
|
org.apache.ignite.tensorflow.cluster.util |
Util components that are used in TensorFlow cluster package.
|
org.apache.ignite.tensorflow.core.longrunning |
The part of TensorFlow integration infrastructure that allows to start and maintain abstract long-running processes.
|
org.apache.ignite.tensorflow.core.nativerunning |
The part of TensorFlow integration infrastructure that allows to start and maintain abstract native processes.
|
org.apache.ignite.tensorflow.core.util |
Util classes used in other
org.apache.ignite.tensorflow.core classes. |
org.apache.ignite.tensorflow.submitter.command |
This package contains commands that command line tool provides.
|
Modifier and Type | Class and Description |
---|---|
class |
IgniteSpringBean
Ignite Spring bean allows to bypass
Ignition methods. |
Modifier and Type | Method and Description |
---|---|
static Ignite |
Ignition.getOrStart(IgniteConfiguration cfg)
Gets or starts new grid instance if it hasn't been started yet.
|
static Ignite |
Ignition.ignite()
Gets an instance of default no-name grid.
|
static Ignite |
Ignition.ignite(@Nullable String name)
Gets a named Ignite instance.
|
static Ignite |
Ignition.ignite(UUID locNodeId)
Gets a grid instance for given local node ID.
|
static Ignite |
Ignition.localIgnite()
This method is used to address a local
Ignite instance, principally from closure. |
static Ignite |
Ignition.start()
Starts grid with default configuration.
|
static Ignite |
IgniteSpring.start(@Nullable org.springframework.context.ApplicationContext springCtx)
Starts grid with default configuration.
|
static Ignite |
Ignition.start(IgniteConfiguration cfg)
Starts grid with given configuration.
|
static Ignite |
IgniteSpring.start(IgniteConfiguration cfg,
@Nullable org.springframework.context.ApplicationContext springCtx)
Starts grid with given configuration.
|
static Ignite |
Ignition.start(InputStream springCfgStream)
Starts all grids specified within given Spring XML configuration input stream.
|
static Ignite |
Ignition.start(String springCfgPath)
Starts all grids specified within given Spring XML configuration file.
|
static Ignite |
IgniteSpring.start(String springCfgPath,
@Nullable org.springframework.context.ApplicationContext springCtx)
Starts all grids specified within given Spring XML configuration file.
|
static Ignite |
Ignition.start(URL springCfgUrl)
Starts all grids specified within given Spring XML configuration file URL.
|
static Ignite |
IgniteSpring.start(URL springCfgUrl,
@Nullable org.springframework.context.ApplicationContext springCtx)
Starts all grids specified within given Spring XML configuration file URL.
|
Modifier and Type | Method and Description |
---|---|
static List<Ignite> |
Ignition.allGrids()
Gets a list of all grids started so far.
|
Modifier and Type | Method and Description |
---|---|
javax.cache.CacheManager |
CachingProvider.findManager(Ignite ignite) |
Modifier and Type | Field and Description |
---|---|
protected Ignite |
HibernateRegion.ignite
Grid instance.
|
protected Ignite |
HibernateAccessStrategyAdapter.ignite
Grid.
|
Modifier and Type | Method and Description |
---|---|
Ignite |
HibernateAccessStrategyFactory.node() |
Modifier and Type | Method and Description |
---|---|
static void |
HibernateAccessStrategyAdapter.evict(Ignite ignite,
HibernateCacheProxy cache,
Object key)
Called to remove object from cache without regard to transaction.
|
Modifier and Type | Field and Description |
---|---|
protected Ignite |
CacheAbstractJdbcStore.ignite
Auto injected ignite instance.
|
Modifier and Type | Method and Description |
---|---|
protected Ignite |
CacheAbstractJdbcStore.ignite() |
Modifier and Type | Method and Description |
---|---|
Ignite |
ClusterGroup.ignite()
Gets instance of grid.
|
Modifier and Type | Method and Description |
---|---|
protected abstract boolean |
AbstractFailureHandler.handle(Ignite ignite,
FailureContext failureCtx)
Actual failure handling.
|
protected boolean |
StopNodeOrHaltFailureHandler.handle(Ignite ignite,
FailureContext failureCtx)
Actual failure handling.
|
protected boolean |
RestartProcessFailureHandler.handle(Ignite ignite,
FailureContext failureCtx)
Actual failure handling.
|
boolean |
StopNodeFailureHandler.handle(Ignite ignite,
FailureContext failureCtx)
Actual failure handling.
|
protected boolean |
NoOpFailureHandler.handle(Ignite ignite,
FailureContext failureCtx)
Actual failure handling.
|
boolean |
AbstractFailureHandler.onFailure(Ignite ignite,
FailureContext failureCtx)
Handles failure occurred on
ignite instance. |
boolean |
FailureHandler.onFailure(Ignite ignite,
FailureContext failureCtx)
Handles failure occurred on
ignite instance. |
Modifier and Type | Field and Description |
---|---|
protected Ignite |
HadoopAbstractMapReducePlanner.ignite
Injected grid.
|
Modifier and Type | Method and Description |
---|---|
protected Ignite |
MessagingListenActor.ignite()
Gets grid instance associated with this actor.
|
Modifier and Type | Method and Description |
---|---|
static <K,V,C extends Serializable,D extends AutoCloseable> |
DatasetFactory.create(Ignite ignite,
IgniteCache<K,V> upstreamCache,
PartitionContextBuilder<K,V,C> partCtxBuilder,
PartitionDataBuilder<K,V,C,D> partDataBuilder)
Creates a new instance of distributed dataset using the specified
partCtxBuilder and
partDataBuilder . |
static <K,V> SimpleDataset<EmptyContext> |
DatasetFactory.createSimpleDataset(Ignite ignite,
IgniteCache<K,V> upstreamCache,
IgniteBiFunction<K,V,Vector> featureExtractor)
Creates a new instance of distributed
SimpleDataset using the specified featureExtractor . |
static <K,V,C extends Serializable> |
DatasetFactory.createSimpleDataset(Ignite ignite,
IgniteCache<K,V> upstreamCache,
PartitionContextBuilder<K,V,C> partCtxBuilder,
IgniteBiFunction<K,V,Vector> featureExtractor)
Creates a new instance of distributed
SimpleDataset using the specified partCtxBuilder and
featureExtractor . |
static <K,V> SimpleLabeledDataset<EmptyContext> |
DatasetFactory.createSimpleLabeledDataset(Ignite ignite,
IgniteCache<K,V> upstreamCache,
IgniteBiFunction<K,V,Vector> featureExtractor,
IgniteBiFunction<K,V,double[]> lbExtractor)
Creates a new instance of distributed
SimpleLabeledDataset using the specified featureExtractor
and lbExtractor . |
static <K,V,C extends Serializable> |
DatasetFactory.createSimpleLabeledDataset(Ignite ignite,
IgniteCache<K,V> upstreamCache,
PartitionContextBuilder<K,V,C> partCtxBuilder,
IgniteBiFunction<K,V,Vector> featureExtractor,
IgniteBiFunction<K,V,double[]> lbExtractor)
Creates a new instance of distributed
SimpleLabeledDataset using the specified partCtxBuilder ,
featureExtractor and lbExtractor . |
Constructor and Description |
---|
CacheBasedDataset(Ignite ignite,
IgniteCache<K,V> upstreamCache,
IgniteBiPredicate<K,V> filter,
IgniteCache<Integer,C> datasetCache,
PartitionDataBuilder<K,V,C,D> partDataBuilder,
UUID datasetId)
Constructs a new instance of dataset based on Ignite Cache, which is used as
upstream and as reliable storage for
partition context as well. |
CacheBasedDatasetBuilder(Ignite ignite,
IgniteCache<K,V> upstreamCache)
Constructs a new instance of cache based dataset builder that makes
CacheBasedDataset with default
predicate that passes all upstream entries to dataset. |
CacheBasedDatasetBuilder(Ignite ignite,
IgniteCache<K,V> upstreamCache,
IgniteBiPredicate<K,V> filter)
Constructs a new instance of cache based dataset builder that makes
CacheBasedDataset . |
Modifier and Type | Method and Description |
---|---|
static <R> Collection<R> |
ComputeUtils.affinityCallWithRetries(Ignite ignite,
Collection<String> cacheNames,
IgniteFunction<Integer,R> fun,
int retries)
Calls the specified
fun function on all partitions so that is't guaranteed that partitions with the same
index of all specified caches will be placed on the same node and will not be moved before computation is
finished. |
static <R> Collection<R> |
ComputeUtils.affinityCallWithRetries(Ignite ignite,
Collection<String> cacheNames,
IgniteFunction<Integer,R> fun,
int retries,
int interval)
Calls the specified
fun function on all partitions so that is't guaranteed that partitions with the same
index of all specified caches will be placed on the same node and will not be moved before computation is
finished. |
static <C extends Serializable> |
ComputeUtils.getContext(Ignite ignite,
String datasetCacheName,
int part)
Extracts partition
context from the Ignite Cache. |
static <K,V,C extends Serializable,D extends AutoCloseable> |
ComputeUtils.getData(Ignite ignite,
String upstreamCacheName,
IgniteBiPredicate<K,V> filter,
String datasetCacheName,
UUID datasetId,
int part,
PartitionDataBuilder<K,V,C,D> partDataBuilder)
Extracts partition
data from the local storage, if it's not found in local storage recovers this data from a partition upstream and context . |
static <K,V,C extends Serializable> |
ComputeUtils.initContext(Ignite ignite,
String upstreamCacheName,
IgniteBiPredicate<K,V> filter,
String datasetCacheName,
PartitionContextBuilder<K,V,C> ctxBuilder,
int retries)
Initializes partition
context by loading it from a partition upstream . |
static <K,V,C extends Serializable> |
ComputeUtils.initContext(Ignite ignite,
String upstreamCacheName,
IgniteBiPredicate<K,V> filter,
String datasetCacheName,
PartitionContextBuilder<K,V,C> ctxBuilder,
int retries,
int interval)
Initializes partition
context by loading it from a partition upstream . |
static void |
ComputeUtils.removeData(Ignite ignite,
UUID datasetId)
Remove data from local cache by Dataset ID.
|
static <C extends Serializable> |
ComputeUtils.saveContext(Ignite ignite,
String datasetCacheName,
int part,
C ctx)
Saves the specified partition
context into the Ignite Cache. |
Constructor and Description |
---|
GAGrid(GAConfiguration cfg,
Ignite ignite) |
Modifier and Type | Method and Description |
---|---|
static List<Chromosome> |
GAGridUtils.getChromosomes(Ignite ignite,
String qry)
Retrieve chromosomes
|
static List<Gene> |
GAGridUtils.getGenesInOrderForChromosome(Ignite ignite,
Chromosome chromosome)
Retrieve genes in order
|
Modifier and Type | Method and Description |
---|---|
PipelineMdl<K,V> |
Pipeline.fit(Ignite ignite,
IgniteCache<K,V> cache)
Fits the pipeline to the input cache.
|
Modifier and Type | Method and Description |
---|---|
default IgniteBiFunction<K,V,R> |
PreprocessingTrainer.fit(Ignite ignite,
IgniteCache<K,V> cache,
IgniteBiFunction<K,V,T> basePreprocessor)
Fits preprocessor.
|
Modifier and Type | Method and Description |
---|---|
double[] |
CrossValidation.score(DatasetTrainer<M,L> trainer,
Metric<L> scoreCalculator,
Ignite ignite,
IgniteCache<K,V> upstreamCache,
IgniteBiFunction<K,V,Vector> featureExtractor,
IgniteBiFunction<K,V,L> lbExtractor,
int cv)
Computes cross-validated metrics.
|
double[] |
CrossValidation.score(DatasetTrainer<M,L> trainer,
Metric<L> scoreCalculator,
Ignite ignite,
IgniteCache<K,V> upstreamCache,
IgniteBiPredicate<K,V> filter,
IgniteBiFunction<K,V,Vector> featureExtractor,
IgniteBiFunction<K,V,L> lbExtractor,
int cv)
Computes cross-validated metrics.
|
CrossValidationResult |
CrossValidation.score(DatasetTrainer<M,L> trainer,
Metric<L> scoreCalculator,
Ignite ignite,
IgniteCache<K,V> upstreamCache,
IgniteBiPredicate<K,V> filter,
IgniteBiFunction<K,V,Vector> featureExtractor,
IgniteBiFunction<K,V,L> lbExtractor,
int cv,
ParamGrid paramGrid)
Computes cross-validated metrics with a passed parameter grid.
|
double[] |
CrossValidation.score(DatasetTrainer<M,L> trainer,
Metric<L> scoreCalculator,
Ignite ignite,
IgniteCache<K,V> upstreamCache,
IgniteBiPredicate<K,V> filter,
IgniteBiFunction<K,V,Vector> featureExtractor,
IgniteBiFunction<K,V,L> lbExtractor,
UniformMapper<K,V> mapper,
int cv)
Computes cross-validated metrics.
|
Modifier and Type | Method and Description |
---|---|
<K,V> M |
DatasetTrainer.fit(Ignite ignite,
IgniteCache<K,V> cache,
IgniteBiFunction<K,V,Vector> featureExtractor,
IgniteBiFunction<K,V,L> lbExtractor)
Trains model based on the specified data.
|
<K,V> M |
DatasetTrainer.fit(Ignite ignite,
IgniteCache<K,V> cache,
IgniteBiPredicate<K,V> filter,
IgniteBiFunction<K,V,Vector> featureExtractor,
IgniteBiFunction<K,V,L> lbExtractor)
Trains model based on the specified data.
|
<K,V> M |
DatasetTrainer.update(M mdl,
Ignite ignite,
IgniteCache<K,V> cache,
IgniteBiFunction<K,V,Vector> featureExtractor,
IgniteBiFunction<K,V,L> lbExtractor)
Gets state of model in arguments, update in according to new data and return new model.
|
<K,V> M |
DatasetTrainer.update(M mdl,
Ignite ignite,
IgniteCache<K,V> cache,
IgniteBiPredicate<K,V> filter,
IgniteBiFunction<K,V,Vector> featureExtractor,
IgniteBiFunction<K,V,L> lbExtractor)
Gets state of model in arguments, update in according to new data and return new model.
|
Modifier and Type | Field and Description |
---|---|
protected Ignite |
IgniteAbstractOsgiContextActivator.ignite
The instance of Ignite started by this Activator.
|
Modifier and Type | Method and Description |
---|---|
protected static Map<Ignite,ClassLoader> |
IgniteOsgiUtils.classloaders()
|
Modifier and Type | Method and Description |
---|---|
Ignite |
PluginContext.grid() |
Ignite |
CachePluginContext.grid() |
Modifier and Type | Field and Description |
---|---|
protected Ignite |
IgniteSink.ignite
Ignite instance.
|
Modifier and Type | Method and Description |
---|---|
Ignite |
IgniteSink.getIgnite()
Gets the Ignite instance.
|
Modifier and Type | Field and Description |
---|---|
protected Ignite |
IgniteSpiAdapter.ignite
Ignite instance.
|
Modifier and Type | Method and Description |
---|---|
Ignite |
IgniteSpiAdapter.ignite()
Gets ignite instance.
|
Modifier and Type | Method and Description |
---|---|
protected void |
IgniteSpiAdapter.injectResources(Ignite ignite)
Inject ignite instance.
|
Modifier and Type | Method and Description |
---|---|
protected void |
TcpCommunicationSpi.injectResources(Ignite ignite)
Injects resources.
|
Modifier and Type | Method and Description |
---|---|
protected void |
TcpDiscoverySpi.injectResources(Ignite ignite)
Inject resources
|
Modifier and Type | Field and Description |
---|---|
protected Ignite |
TcpDiscoveryIpFinderAdapter.ignite
Ignite instance .
|
Modifier and Type | Field and Description |
---|---|
protected Ignite |
KeystoreEncryptionSpi.ignite
Ignite
|
Constructor and Description |
---|
IgniteRepositoryFactory(Ignite ignite)
Creates the factory with initialized
Ignite instance. |
Constructor and Description |
---|
IgniteRepositoryFactory(Ignite ignite)
Creates the factory with initialized
Ignite instance. |
Modifier and Type | Field and Description |
---|---|
protected Ignite |
StreamAdapter.ignite
Ignite.
|
Modifier and Type | Method and Description |
---|---|
Ignite |
StreamAdapter.getIgnite() |
Modifier and Type | Method and Description |
---|---|
void |
StreamAdapter.setIgnite(Ignite ignite) |
Modifier and Type | Method and Description |
---|---|
static Ignite |
IgniteSinkTask.StreamerContext.getIgnite()
Obtains grid instance.
|
Modifier and Type | Method and Description |
---|---|
static Ignite |
StormStreamer.StreamerContext.getIgnite()
Obtains grid instance.
|
Constructor and Description |
---|
TensorFlowClusterGatewayManager(Ignite ignite)
Constructs a new instance of TensorFlow cluster manager with maintenance.
|
TensorFlowClusterManager(Ignite ignite)
Constructs a new instance of TensorFlow cluster manager.
|
Modifier and Type | Method and Description |
---|---|
String |
TensorFlowClusterSpec.format(Ignite ignite)
Formats cluster specification so that TensorFlow accepts it.
|
String |
TensorFlowServerAddressSpec.format(Ignite ignite)
Formats Server Address specification so that TensorFlow accepts it.
|
Modifier and Type | Method and Description |
---|---|
String |
TensorFlowServerScriptFormatter.format(TensorFlowServer srv,
boolean join,
Ignite ignite)
Formats TensorFlow server specification so that it's available to be passed into а python script.
|
Constructor and Description |
---|
TensorFlowServerManager(Ignite ignite)
Constructs a new instance of TensorFlow server manager.
|
Constructor and Description |
---|
ClusterPortManager(Ignite ignite,
String poolName,
int from,
int cnt)
Constructs a new instance of cluster port manager.
|
TensorFlowChiefRunner(Ignite ignite,
ExecutorService executor,
TensorFlowClusterSpec spec,
Consumer<String> out,
Consumer<String> err)
Constructs a new instance of TensorFlow chief runner.
|
TensorFlowClusterResolver(Ignite ignite,
String portPoolName,
int portFrom,
int portCnt)
Constructs a new instance of TensorFlow cluster resolver.
|
TensorFlowUserScriptRunner(Ignite ignite,
ExecutorService executor,
TensorFlowJobArchive jobArchive,
TensorFlowClusterSpec clusterSpec,
Consumer<String> out,
Consumer<String> err)
Constructs a new instance of TensorFlow user script runner.
|
Constructor and Description |
---|
LongRunningProcessManager(Ignite ignite)
Constructs a new instance of long running process manager.
|
Constructor and Description |
---|
NativeProcessManager(Ignite ignite)
Constructs a new native process manager.
|
Constructor and Description |
---|
AsyncNativeProcessRunner(Ignite ignite,
ExecutorService executor)
Constructs a new asynchronous native process runner.
|
Modifier and Type | Method and Description |
---|---|
protected Ignite |
AbstractCommand.getIgnite()
Returns Ignite instance based on configuration specified in
AbstractCommand.cfg field. |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.2 Release Date : February 6 2019