| Package | Description | 
|---|---|
| com.hazelcast.cluster | 
 This package contains the cluster functionality. 
 | 
| com.hazelcast.cp | 
 Contains public APIs of CP Subsystem 
 | 
| com.hazelcast.cp.session | 
 Contains session abstractions of CP Subsystem 
 | 
| com.hazelcast.jet.core | 
 Jet's Core API. 
 | 
| com.hazelcast.jet.core.test | 
 Utilities for writing tests of Core API Processors. 
 | 
| com.hazelcast.partition | 
 Contains the partition logic for Hazelcast. 
 | 
| com.hazelcast.replicatedmap | 
 Classes for replicated map. 
 | 
| com.hazelcast.security | 
 Provides interfaces/classes for Hazelcast security implementation. 
 | 
| com.hazelcast.spi.discovery | 
 This package contains the public SPI for vendors and users to implement their
 custom node / IP discovery strategy. 
 | 
| com.hazelcast.spi.exception | 
 Contains exceptions for Hazelcast SPI. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static Address | 
Address.createUnresolvedAddress(String host,
                       int port)
Creates an unresolved address. 
 | 
Address | 
Member.getAddress()
Returns the Address of this Member. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Map<com.hazelcast.instance.EndpointQualifier,Address> | 
Member.getAddressMap()  | 
| Constructor and Description | 
|---|
Address(Address address)  | 
| Modifier and Type | Method and Description | 
|---|---|
Address | 
CPMember.getAddress()
Returns the address of this CP member. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Address | 
CPSession.endpoint()
Returns the endpoint that has created this session 
 | 
| Modifier and Type | Field and Description | 
|---|---|
static Address | 
Edge.DISTRIBUTE_TO_ALL
An address returned by  
Edge.getDistributedTo() denoting an edge that
 distributes the items among all members. | 
| Modifier and Type | Method and Description | 
|---|---|
Address | 
Edge.getDistributedTo()
Possible return values:
     null - route only to local members (after a  
Edge.local()
          call)
     "255.255.255.255:0 - route to all members (after a Edge.distributed() call)
     else - route to specific member (after a Edge.distributeTo(com.hazelcast.cluster.Address)
          call)
  | 
| Modifier and Type | Method and Description | 
|---|---|
Function<? super Address,? extends ProcessorSupplier> | 
ProcessorMetaSupplier.get(List<Address> addresses)
Called to create a mapping from member  
Address to the
 ProcessorSupplier that will be sent to that member. | 
Function<? super Address,? extends ProcessorSupplier> | 
ProcessorMetaSupplier.SpecificMemberPms.get(List<Address> addresses)  | 
Function<? super Address,? extends ProcessorSupplier> | 
ProcessorMetaSupplier.RandomMemberPms.get(List<Address> addresses)  | 
Map<Address,int[]> | 
ProcessorMetaSupplier.Context.partitionAssignment()
Returns the partition assignment used by this job. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Edge | 
Edge.distributeTo(Address targetMember)
Declares that all items sent over this edge will be delivered to the
 specified member. 
 | 
static ProcessorMetaSupplier | 
ProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier supplier,
                        Address memberAddress)
Wraps the provided  
ProcessorSupplier into a meta-supplier that
 will only use the given ProcessorSupplier on a node with the
 given Address. | 
| Modifier and Type | Method and Description | 
|---|---|
Function<? super Address,? extends ProcessorSupplier> | 
ProcessorMetaSupplier.get(List<Address> addresses)
Called to create a mapping from member  
Address to the
 ProcessorSupplier that will be sent to that member. | 
Function<? super Address,? extends ProcessorSupplier> | 
ProcessorMetaSupplier.SpecificMemberPms.get(List<Address> addresses)  | 
Function<? super Address,? extends ProcessorSupplier> | 
ProcessorMetaSupplier.RandomMemberPms.get(List<Address> addresses)  | 
static ProcessorMetaSupplier | 
ProcessorMetaSupplier.of(FunctionEx<? super Address,? extends ProcessorSupplier> addressToSupplier)
Factory method that creates a  
ProcessorMetaSupplier from the
 supplied function that maps a cluster member address to a ProcessorSupplier. | 
static ProcessorMetaSupplier | 
ProcessorMetaSupplier.of(int preferredLocalParallelism,
  FunctionEx<? super Address,? extends ProcessorSupplier> addressToSupplier)
Factory method that creates a  
ProcessorMetaSupplier from the
 supplied function that maps a cluster member address to a ProcessorSupplier. | 
| Modifier and Type | Method and Description | 
|---|---|
Map<Address,int[]> | 
TestProcessorMetaSupplierContext.partitionAssignment()  | 
| Modifier and Type | Method and Description | 
|---|---|
TestProcessorSupplierContext | 
TestProcessorSupplierContext.setPartitionAssignment(Map<Address,int[]> partitionAssignment)  | 
TestProcessorContext | 
TestProcessorContext.setPartitionAssignment(Map<Address,int[]> partitionAssignment)  | 
TestProcessorMetaSupplierContext | 
TestProcessorMetaSupplierContext.setPartitionAssignment(Map<Address,int[]> partitionAssignment)
Sets the partition assignment. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Address | 
PartitionLostEvent.getEventSource()
Returns the address of the node that dispatches the event 
 | 
| Constructor and Description | 
|---|
ReplicatedMapCantBeCreatedOnLiteMemberException(Address address)  | 
| Modifier and Type | Method and Description | 
|---|---|
default Credentials | 
ICredentialsFactory.newCredentials(Address address)
Creates new  
Credentials object for given target Address. | 
| Modifier and Type | Method and Description | 
|---|---|
Address | 
SimpleDiscoveryNode.getPrivateAddress()  | 
abstract Address | 
DiscoveryNode.getPrivateAddress()
Returns the private address of the discovered node. 
 | 
Address | 
SimpleDiscoveryNode.getPublicAddress()  | 
abstract Address | 
DiscoveryNode.getPublicAddress()
Returns the public address of the discovered node if available. 
 | 
| Constructor and Description | 
|---|
SimpleDiscoveryNode(Address privateAddress)
This constructor will set private and public addresses to the same value and no properties
 are available. 
 | 
SimpleDiscoveryNode(Address privateAddress,
                   Address publicAddress)
This constructor will set private and public addresses separately and no properties are available. 
 | 
SimpleDiscoveryNode(Address privateAddress,
                   Address publicAddress,
                   Map<String,String> properties)
This constructor will set private and public addresses separately. 
 | 
SimpleDiscoveryNode(Address privateAddress,
                   Map<String,String> properties)
This constructor will set private and public addresses to the same value. 
 | 
| Constructor and Description | 
|---|
CallerNotMemberException(Address thisAddress,
                        Address caller,
                        int partitionId,
                        String operationName,
                        String serviceName)  | 
PartitionMigratingException(Address thisAddress,
                           int partitionId,
                           String operationName,
                           String serviceName)  | 
Copyright © 2023 Hazelcast, Inc.. All rights reserved.