Base builtin aggregator

A utility class to create basic IAggregatorTResult instances.

An aggregator that calculates the sum of the input values. Does NOT accept null input values. Accepts only BigInteger input values.

an aggregator that counts the input values. Accepts nulls as input values.

A HazelcastException that indicates that a IDistributedObject access was attempted, but the object is destroyed.

DistributedObjectEvent is fired when a IDistributedObject is created or destroyed cluster-wide.

an aggregator that calculates the average of the input values. Does NOT accept null input values.

An aggregator that calculates the sum of the input values extracted from the given attributePath. Does NOT accept null input values nor null extracted values. Accepts only double input values.

Map Entry event.

An aggregator that calculates the sum of the input values extracted from the given attributePath. Does NOT accept null input values nor null extracted values. Accepts float or double input values.

an aggregator that calculates the sum of the input values. Does NOT accept null input values. Accepts float or double input values.

Base Hazelcast exception.

Thrown when IHazelcastInstance is not active during an invocation.

Simple interface for marking aggregators. An aggregator implementain must support hazelcast serialization and have a counterpart on server side.

A event that is send when a IInitialMembershipListener registers itself on a ICluster . For more information see the IInitialMembershipListener .

an aggregator that calculates the average of the input values extracted from the given attributePath. Does NOT accept null input values nor null extracted values. Accepts only int input values

an aggregator that calculates the sum of the input values. Does NOT accept null input values. Accepts only int input values.

Marker interface for server side projection implementation. Enables transforming object into other objects. Only 1:1 transformations allowed. Use an Aggregator to perform N:1 or N:M aggregations.
Projection implementations must be hazelcast serializable and must have a counterpart/implementation on server side.

Map Item event.

Lifecycle event fired when IHazelcastInstance's state changes.

an aggregator that calculates the average of the input values. Does NOT accept null input values. Accepts only long input values

an aggregator that calculates the sum of the input values. Does NOT accept null input values. Accepts only long input values.

an aggregator that calculates the max of the input values. Accepts null input values

Membership event fired when a new member is added to the cluster and/or when a member leaves the cluster.

Message for ITopic<E>.

an aggregator that calculates the min of the input values. Accepts null input values

an aggregator that calculates the average of the input values. Does NOT accept null input values nor null extracted values. Accepts float or double input values.

This class is a special Predicate which helps to get a page-by-page result of a query. It can be constructed with a page-size, an inner predicate for filtering, and a comparator for sorting.

A builtin predicate that restricts the execution of a target Predicate to a single Partition.

Helper mothod for creating builtin predicates

Projection that extracts the values of the given attribute and returns it.
The attributePath does not support the [any] operator.

SQL Predicate

An exception that is thrown when accessing an item in the IRingbuffer using a sequence that is smaller than the current head sequence. This means that the and old item is read, but it isn't available anymore in the ringbuffer.

Invoked when an entry is added.

Invoked when an entry is evicted.

Listener which is notified after removal of an entry due to the expiration-based-eviction.

Invoked after WAN replicated entry is merged.

Invoked when an entry is removed.

Invoked when an entry is updated.

IAtomicLong is a redundant and highly available distributed Atomic Long

IClient interface allows to get information about a connected clients socket address, type and uuid.

IClientListener allows to get notified when a IClient is connected to or disconnected from cluster.

IClientService allows to query connected IClient s and attach/detach IClientListener s to listen connection events.

Hazelcast cluster interface.

ICountDownLatch is a backed-up distributed alternative to the .

ICountDownLatch is a cluster-wide synchronization aid that allows one or more threads to wait until a set of operations being performed in other threads completes.

There are a few differences compared to the ICountDownLatch :

1. the ICountDownLatch count can be re-set using TrySetCount(int) after a countdown has finished but not during an active count. This allows the same latch instance to be reused.
2. there is no await() method to do an unbound wait since this is undesirable in a distributed application: it can happen that for example a cluster is split or that the master and replica's all die. So in most cases it is best to configure an explicit timeout so have the ability to deal with these situations.

Base interface for all distributed objects.

IDistributedObjectListener allows to get notified when a IDistributedObject is created or destroyed cluster-wide.

Endpoint represents a peer in the cluster.

Map Entry listener to get notified when a map entry is added, removed, updated or evicted.

IEntryView represents a readonly view of a map entry.

IExecutionCallback allows to asynchronously get notified when the execution is completed, either successfully or with error.

Distributed implementation of ExecutorService. IExecutorService provides additional methods like executing tasks on a specific member, on a member who is owner of a specific key, executing a tasks on multiple members and listening execution result using a callback.

Hazelcast instance.

Used to get IHazelcastInstance reference when submitting a Runnable/Callable using Hazelcast ExecutorService.

Concurrent, distributed, partitioned, listenable collection.

Concurrent, distributed implementation of IListTIList

Concurrent, distributed implementation of ISet

Cluster-wide unique id generator.

The InitializingMembershipListener is a IMembershipListener that will first receives a InitialMembershipEvent when it is registered so it immediately knows which members are available. After that event has been received, it will receive the normal MembershipEvents. When the InitializingMembershipListener already is registered on a ICluster and is registered again on the same ICluster instance, it will not receive an additional MembershipInitializeEvent. So this is a once only event.

Item listener for IQueueT , IHSetT and IHListT

Listener object for lisntening lifecycle events of hazelcast instance

ILifecycleService allows you to shutdown, terminate and listen to LifecycleEvent 's on IHazelcastInstance.

Distributed implementation of Lock

Container managed context, such as Spring, Guice and etc.

Concurrent, distributed, observable and queryable map.

Cluster member interface.

ICluster membership listener.

Message listener for ITopic<E> .

IMultiExecutionCallback allows to get notified when an execution is completed on each member which task is submitted to.

A specialized Concurrent, distributed map whose keys can be associated with multiple values.

Virtual partition instance.

IPartitionAware allows implementing keys to be located on the same member or implementing tasks to be executed on IPartitionAware<T>.GetPartitionKey() 's owner member. This makes related data to be stored in the same location. (See data-affinity.)

IPartitioningStrategy allows keys to be located on the same member This makes related data to be stored in the same location.

Concurrent, blocking, distributed, observable queue.

A ReplicatedMap is a map-like data structure with weak consistency and values locally stored on every node of the cluster.

A Ringbuffer is a data-structure where the content is stored in a ring like structure.

ISemaphore is a backed-up distributed alternative to the System.Threading.Semaphore .

Hazelcast provides distribution mechanism for publishing messages that are delivered to multiple subscribers which is also known as publish/subscribe (pub/sub) messaging model.

Transactional implementation of IHList<E>

Transactional implementation of Map

Transactional implementation of MultiMap

Transactional implementation of Queue

Transactional implementation of IHSet<E> .

Invoked when all entries are removed.

Invoked when all entries are evicted.

Type of a client.

Type of entry event.

Type of item event.

lifecycle states

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.

Represent Time units