Uses of Class
com.hazelcast.cluster.Address
Package
Description
This package contains the cluster functionality.
Contains public APIs of CP Subsystem
Contains session abstractions of CP Subsystem
Jet's Core API.
Utilities for writing tests of Core API Processors.
Contains the partition logic for Hazelcast.
Classes for replicated map.
Provides interfaces/classes for Hazelcast security implementation.
This package contains the public SPI for vendors and users to implement their
custom node / IP discovery strategy.
This package contains the public part of the integrators SPI and is meant for
people that integrate Hazelcast into their own systems or frameworks and cannot
use the default discovery service implementation (for example using a different
DiscoveryStrategy
lookup strategy like OSGi).Contains exceptions for Hazelcast SPI.
-
Uses of Address in com.hazelcast.cluster
Modifier and TypeMethodDescriptionstatic Address
Address.createUnresolvedAddress
(String host, int port) Creates an unresolved address.Member.getAddress()
Returns the Address of this Member. -
Uses of Address in com.hazelcast.cp
-
Uses of Address in com.hazelcast.cp.session
-
Uses of Address in com.hazelcast.jet.core
Modifier and TypeFieldDescriptionstatic final Address
Edge.DISTRIBUTE_TO_ALL
An address returned byEdge.getDistributedTo()
denoting an edge that distributes the items among all members.protected Address
ProcessorMetaSupplier.SpecificMemberPms.memberAddress
Modifier and TypeMethodDescriptionEdge.getDistributedTo()
Possible return values: null - route only to local members (after aEdge.local()
call) "255.255.255.255:0 - route to all members (after aEdge.distributed()
call) else - route to specific member (after aEdge.distributeTo(com.hazelcast.cluster.Address)
call)static Address
ProcessorMetaSupplier.getOwnerAddress
(ProcessorMetaSupplier.Context context, Object partitionKey) Since the partition owner may not participate in job execution, alwaysProcessorMetaSupplier.Context.partitionAssignment()
should be used to find the "actual" owner.Modifier and TypeMethodDescriptionFunction<? super Address,
? extends ProcessorSupplier> Called to create a mapping from memberAddress
to theProcessorSupplier
that will be sent to that member.Function<? super Address,
? extends ProcessorSupplier> Function<? super Address,
? extends ProcessorSupplier> ProcessorMetaSupplier.Context.partitionAssignment()
Returns the partition assignment used by this job.Modifier and TypeMethodDescriptionEdge.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 providedProcessorSupplier
into a meta-supplier that will only use the givenProcessorSupplier
on a node with the givenAddress
.Modifier and TypeMethodDescriptionFunction<? super Address,
? extends ProcessorSupplier> Called to create a mapping from memberAddress
to theProcessorSupplier
that will be sent to that member.Function<? super Address,
? extends ProcessorSupplier> Function<? super Address,
? extends ProcessorSupplier> static ProcessorMetaSupplier
ProcessorMetaSupplier.of
(int preferredLocalParallelism, FunctionEx<? super Address, ? extends ProcessorSupplier> addressToSupplier) Factory method that creates aProcessorMetaSupplier
from the supplied function that maps a cluster member address to aProcessorSupplier
.static ProcessorMetaSupplier
ProcessorMetaSupplier.of
(FunctionEx<? super Address, ? extends ProcessorSupplier> addressToSupplier) Factory method that creates aProcessorMetaSupplier
from the supplied function that maps a cluster member address to aProcessorSupplier
.ModifierConstructorDescriptionprotected
SpecificMemberPms
(ProcessorSupplier supplier, Address memberAddress) -
Uses of Address in com.hazelcast.jet.core.test
Modifier and TypeMethodDescriptionTestProcessorContext.setPartitionAssignment
(Map<Address, int[]> partitionAssignment) TestProcessorMetaSupplierContext.setPartitionAssignment
(Map<Address, int[]> partitionAssignment) Sets the partition assignment.TestProcessorSupplierContext.setPartitionAssignment
(Map<Address, int[]> partitionAssignment) -
Uses of Address in com.hazelcast.partition
Modifier and TypeMethodDescriptionPartitionLostEvent.getEventSource()
Returns the address of the node that dispatches the event -
Uses of Address in com.hazelcast.replicatedmap
-
Uses of Address in com.hazelcast.security
Modifier and TypeMethodDescriptiondefault Credentials
ICredentialsFactory.newCredentials
(Address address) Creates newCredentials
object for given targetAddress
. -
Uses of Address in com.hazelcast.spi.discovery
Modifier and TypeMethodDescriptionabstract Address
DiscoveryNode.getPrivateAddress()
Returns the private address of the discovered node.SimpleDiscoveryNode.getPrivateAddress()
abstract Address
DiscoveryNode.getPublicAddress()
Returns the public address of the discovered node if available.SimpleDiscoveryNode.getPublicAddress()
Modifier and TypeMethodDescriptionDiscoveryStrategy.getUnhealthyEndpoints()
Fetches a set ofAddress
marked as unhealthy by the underlying implementation.Modifier and TypeMethodDescriptiondefault void
DiscoveryStrategy.markEndpointAsUnhealthy
(Address address) Marks the passedAddress
as unhealthy, which prevents it from being offered as a viable endpoint in someDiscoveryStrategy
implementations, usually prompting this endpoint to be periodically probed for liveliness.ModifierConstructorDescriptionSimpleDiscoveryNode
(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.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. -
Uses of Address in com.hazelcast.spi.discovery.integration
Modifier and TypeMethodDescriptionDiscoveryService.getUnhealthyEndpoints()
Fetches a set ofAddress
marked as unhealthy by the underlyingDiscoveryStrategy
.Modifier and TypeMethodDescriptiondefault void
DiscoveryService.markEndpointAsUnhealthy
(Address address) Marks the passedAddress
as unhealthy, which prevents it from being offered as a viable endpoint in someDiscoveryStrategy
implementations, usually prompting this endpoint to be periodically probed for liveliness. -
Uses of Address in com.hazelcast.spi.exception
ModifierConstructorDescriptionCallerNotMemberException
(Address thisAddress, Address caller, int partitionId, String operationName, String serviceName) PartitionMigratingException
(Address thisAddress, int partitionId, String operationName, String serviceName)