Package | Description |
---|---|
com.hazelcast.config |
Provides classes for configuring HazelcastInstance.
|
com.hazelcast.core |
Provides core API interfaces/classes.
|
com.hazelcast.map |
Contains Hazelcast map module classes.
|
com.hazelcast.mapreduce |
This package contains the MapReduce API definition for Hazelcast.
All map reduce operations running in a distributed manner inside the active Hazelcast cluster. |
com.hazelcast.mapreduce.aggregation |
This package contains the aggregation API and the convenience helper classes
to retrieve predefined aggregation implementations.
|
com.hazelcast.ringbuffer |
Contains the API for the
Ringbuffer . |
com.hazelcast.spi |
Provides interfaces/classes for Hazelcast SPI.
|
com.hazelcast.spi.impl |
Contains implementations for Hazelcast SPI.
|
com.hazelcast.topic |
Contains the API for the
ITopic . |
Package | Description |
---|---|
com.hazelcast.mapreduce |
This package contains the MapReduce API definition for Hazelcast.
All map reduce operations running in a distributed manner inside the active Hazelcast cluster. |
Modifier and Type | Class and Description |
---|---|
class |
ReliableTopicConfig
Configuration for a reliable
ITopic . |
class |
RingbufferConfig
Contains the configuration for the
Ringbuffer . |
Modifier and Type | Interface and Description |
---|---|
interface |
AsyncAtomicLong
This interface is an
IAtomicLong interface that exposes its operations using an
ICompletableFuture interface so it can be used in the reactive programming model
approach. |
interface |
AsyncAtomicReference<E>
A
IAtomicReference that exposes its operations using a ICompletableFuture
so it can be used in the reactive programming model approach. |
interface |
ICompletableFuture<V>
A Future where one can asynchronously listen on completion.
|
interface |
ReplicatedMap<K,V>
A ReplicatedMap is a map-like data structure with non-strong consistency
(so-called eventually consistent) and values locally stored on every
node of the cluster.
|
Modifier and Type | Interface and Description |
---|---|
interface |
QueryCache<K,V>
A concurrent, queryable data structure which is used to cache results of a continuous query executed
on an
IMap . |
Modifier and Type | Interface and Description |
---|---|
interface |
Collator<ValueIn,ValueOut>
This interface can be implemented to define a Collator which is executed after calculation
of the MapReduce algorithm on remote cluster nodes but before returning the final result.
Collator can, for example, be used to sum up a final value. |
class |
Combiner<ValueIn,ValueOut>
|
interface |
CombinerFactory<KeyIn,ValueIn,ValueOut>
|
interface |
Context<K,V>
The Context interface is used for emitting keys and values to the intermediate working space of
the MapReduce algorithm.
|
interface |
Job<KeyIn,ValueIn>
This interface describes a mapreduce Job that is build by
JobTracker.newJob(KeyValueSource) .It is used to execute mappings and calculations on the different cluster nodes and reduce or collate these mapped values to results. |
interface |
JobCompletableFuture<V>
This is a special version of ICompletableFuture to return the assigned job
id of the submit operation.
|
interface |
JobPartitionState
An implementation of this interface contains current information about
the status of an process piece while operation is executing.
|
interface |
JobProcessInformation
This interface holds basic information about a running map reduce job, such as the
state of the different partitions and the number of currently processed
records.
The number of processed records is not a real time value, it is updated on a regular basis (after 1000 processed elements per node). |
interface |
JobTracker
The JobTracker interface is used to create instances of
Job s depending
on the given data structure / data source. |
interface |
KeyPredicate<Key>
This interface is used to pre-evaluate keys before spreading the MapReduce task to the cluster.
|
class |
KeyValueSource<K,V>
|
interface |
LifecycleMapper<KeyIn,ValueIn,KeyOut,ValueOut>
The LifecycleMapper interface is a more sophisticated version of
Mapper normally used for more complex
algorithms with a need for initialization and finalization. |
class |
LifecycleMapperAdapter<KeyIn,ValueIn,KeyOut,ValueOut>
The abstract LifecycleMapperAdapter superclass is used to ease building mappers for the
Job . |
interface |
Mapper<KeyIn,ValueIn,KeyOut,ValueOut>
The interface Mapper is used to build mappers for the
Job . |
interface |
MappingJob<EntryKey,KeyIn,ValueIn>
This interface describes a mapping mapreduce Job.
For further information see Job . |
interface |
PartitionIdAware
This interface can be used to mark implementation being aware of the data partition
it is currently working on.
|
class |
Reducer<ValueIn,ValueOut>
The abstract Reducer class is used to build reducers for the
Job .Reducers may be distributed inside of the cluster but there is always only one Reducer per key. |
interface |
ReducerFactory<KeyIn,ValueIn,ValueOut>
A ReducerFactory implementation is used to build
Reducer instances per key.An implementation needs to be serializable by Hazelcast since it might be distributed inside the cluster to do parallel calculations for reducing. |
interface |
ReducingJob<EntryKey,KeyIn,ValueIn>
This interface describes a reducing mapreduce Job.
For further information Job . |
interface |
ReducingSubmittableJob<EntryKey,KeyIn,ValueIn>
This interface describes a submittable mapreduce Job.
For further information Job . |
class |
TopologyChangedException
This exception is thrown when a topology change happens during the
execution of a map reduce job and the
TopologyChangedStrategy
is set to TopologyChangedStrategy.CANCEL_RUNNING_OPERATION . |
class |
TopologyChangedStrategy
This enum class is used to define how a map reduce job behaves
if the job owner recognizes a topology changed event.
When members are leaving the cluster, it might lose processed data chunks that were already send to the reducers on the leaving node. Also, on any topology change, there is a redistribution of the member assigned partitions, which means that a map job might have a problem finishing its currently processed partition. The default behavior is to immediately cancel the running task and throw an TopologyChangedException , but it is possible
to submit the same job configuration again if
JobTracker.getTrackableJob(String)
returns null for the requested job id. |
interface |
TrackableJob<V>
This interface describes a trackable job.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Aggregation<Key,Supplied,Result>
The Aggregation interface combines multiple map-reduce operations steps to a
single operation definition.
|
class |
Aggregations
This class is used to access the Hazelcast predefined set of aggregations in a type-safe
way.
|
interface |
PropertyExtractor<ValueIn,ValueOut>
The PropertyExtractor interface is used in suppliers to retrieve values from
input value types and extract or transform them to some other type to be used
in aggregations.
|
class |
Supplier<KeyIn,ValueIn,ValueOut>
|
Modifier and Type | Class and Description |
---|---|
class |
OverflowPolicy
Using this policy one can control the behavior what should to be done when an item is about to be added to the ringbuffer,
but there is 0 remaining capacity.
|
interface |
ReadResultSet<E>
The result of a
Ringbuffer.readManyAsync(long, int, int, com.hazelcast.core.IFunction) operation. |
interface |
Ringbuffer<E>
A Ringbuffer is a data-structure where the content is stored in a ring like structure.
|
class |
StaleSequenceException
An
RuntimeException that is thrown when accessing an item in the Ringbuffer using a sequence that is smaller
than the current head sequence. |
Modifier and Type | Interface and Description |
---|---|
interface |
StatisticsAwareService
This interface is in BETA stage and is subject to change in upcoming releases.
|
Modifier and Type | Interface and Description |
---|---|
interface |
MutatingOperation
Marker interface for operations that changes map state/data.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ReliableMessageListener<E>
A
MessageListener to better integrate with the reliable topic. |
class |
TopicOverloadException
A
HazelcastException thrown when a publisher wants to write to a topic, but there is not sufficient storage
to deal with the event. |
class |
TopicOverloadPolicy
A policy to deal with an overloaded topic; so topic where there is no place to store new messages.
|
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.