Uses of Class
com.hazelcast.cluster.Address
Packages that use 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
Methods in com.hazelcast.cluster that return AddressModifier and TypeMethodDescriptionstatic Address
Address.createUnresolvedAddress
(String host, int port) Creates an unresolved address.Member.getAddress()
Returns the Address of this Member.Methods in com.hazelcast.cluster that return types with arguments of type AddressConstructors in com.hazelcast.cluster with parameters of type Address -
Uses of Address in com.hazelcast.cp
Methods in com.hazelcast.cp that return Address -
Uses of Address in com.hazelcast.cp.session
Methods in com.hazelcast.cp.session that return Address -
Uses of Address in com.hazelcast.jet.core
Fields in com.hazelcast.jet.core declared as AddressModifier 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
Methods in com.hazelcast.jet.core that return AddressModifier 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.Methods in com.hazelcast.jet.core that return types with arguments of type AddressModifier 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.Methods in com.hazelcast.jet.core with parameters of type AddressModifier 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
.Method parameters in com.hazelcast.jet.core with type arguments of type AddressModifier 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
.Constructors in com.hazelcast.jet.core with parameters of type AddressModifierConstructorDescriptionprotected
SpecificMemberPms
(ProcessorSupplier supplier, Address memberAddress) -
Uses of Address in com.hazelcast.jet.core.test
Methods in com.hazelcast.jet.core.test that return types with arguments of type AddressMethod parameters in com.hazelcast.jet.core.test with type arguments of type AddressModifier 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
Methods in com.hazelcast.partition that return AddressModifier and TypeMethodDescriptionPartitionLostEvent.getEventSource()
Returns the address of the node that dispatches the event -
Uses of Address in com.hazelcast.replicatedmap
Constructors in com.hazelcast.replicatedmap with parameters of type Address -
Uses of Address in com.hazelcast.security
Methods in com.hazelcast.security with parameters of type AddressModifier and TypeMethodDescriptiondefault Credentials
ICredentialsFactory.newCredentials
(Address address) Creates newCredentials
object for given targetAddress
. -
Uses of Address in com.hazelcast.spi.discovery
Methods in com.hazelcast.spi.discovery that return AddressModifier 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()
Methods in com.hazelcast.spi.discovery that return types with arguments of type AddressModifier and TypeMethodDescriptionDiscoveryStrategy.getUnhealthyEndpoints()
Fetches a set ofAddress
marked as unhealthy by the underlying implementation.Methods in com.hazelcast.spi.discovery with parameters of type AddressModifier 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.Constructors in com.hazelcast.spi.discovery with parameters of type AddressModifierConstructorDescriptionSimpleDiscoveryNode
(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
Methods in com.hazelcast.spi.discovery.integration that return types with arguments of type AddressModifier and TypeMethodDescriptionDiscoveryService.getUnhealthyEndpoints()
Fetches a set ofAddress
marked as unhealthy by the underlyingDiscoveryStrategy
.Methods in com.hazelcast.spi.discovery.integration with parameters of type AddressModifier 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
Constructors in com.hazelcast.spi.exception with parameters of type AddressModifierConstructorDescriptionCallerNotMemberException
(Address thisAddress, Address caller, int partitionId, String operationName, String serviceName) PartitionMigratingException
(Address thisAddress, int partitionId, String operationName, String serviceName)