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 |
---|---|
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. |
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. |
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 |
---|---|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setPartitionAssignment(Map<Address,int[]> partitionAssignment)
Sets the partition assignment.
|
TestProcessorSupplierContext |
TestProcessorSupplierContext.setPartitionAssignment(Map<Address,int[]> partitionAssignment) |
TestProcessorContext |
TestProcessorContext.setPartitionAssignment(Map<Address,int[]> partitionAssignment) |
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 |
---|---|
abstract Address |
DiscoveryNode.getPrivateAddress()
Returns the private address of the discovered node.
|
Address |
SimpleDiscoveryNode.getPrivateAddress() |
abstract Address |
DiscoveryNode.getPublicAddress()
Returns the public address of the discovered node if available.
|
Address |
SimpleDiscoveryNode.getPublicAddress() |
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 © 2021 Hazelcast, Inc.. All rights reserved.