Uses of Class
org.apache.flink.statefun.sdk.Address

Packages that use Address

Package	Description
org.apache.flink.statefun.flink.core.backpressure
org.apache.flink.statefun.flink.core.common
org.apache.flink.statefun.flink.core.message
org.apache.flink.statefun.flink.core.reqreply
org.apache.flink.statefun.flink.core.state
org.apache.flink.statefun.flink.state.processor
org.apache.flink.statefun.flink.state.processor.union
org.apache.flink.statefun.sdk
org.apache.flink.statefun.sdk.io
org.apache.flink.statefun.testutils.function
org.apache.flink.statefun.testutils.matchers

Uses of Address in org.apache.flink.statefun.flink.core.backpressure

Methods in org.apache.flink.statefun.flink.core.backpressure with parameters of type Address

Modifier and Type	Method and Description
void	BackPressureValve.blockAddress(Address address) Requests to stop processing any further input for that address, as long as there is an uncompleted async operation (registered by @address).
void	ThresholdBackPressureValve.blockAddress(Address address) Requests to stop processing any further input for that address, as long as there is an uncompleted async operation (registered by @address).
boolean	BackPressureValve.isAddressBlocked(Address address) Checks whether a given address was previously blocked with BackPressureValve.blockAddress(Address).
boolean	ThresholdBackPressureValve.isAddressBlocked(Address address) Checks whether a given address was previously blocked with BackPressureValve.blockAddress(Address).
void	BackPressureValve.notifyAsyncOperationCompleted(Address owningAddress) Notifies when a async operation, registered by @owningAddress was completed.
void	ThresholdBackPressureValve.notifyAsyncOperationCompleted(Address owningAddress) Notifies when a async operation, registered by @owningAddress was completed.

Uses of Address in org.apache.flink.statefun.flink.core.common

Methods in org.apache.flink.statefun.flink.core.common that return Address

Modifier and Type	Method and Description
static Address	PolyglotUtil.polyglotAddressToSdkAddress(Address address)

Methods in org.apache.flink.statefun.flink.core.common with parameters of type Address

Modifier and Type	Method and Description
static java.lang.String	KeyBy.apply(Address address)
static Address	PolyglotUtil.sdkAddressToPolyglotAddress(Address sdkAddress)

Uses of Address in org.apache.flink.statefun.flink.core.message

Methods in org.apache.flink.statefun.flink.core.message that return Address

Modifier and Type	Method and Description
Address	RoutableMessage.source() Gets the address of the sender.
Address	RoutableMessage.target() Gets the target address.

Methods in org.apache.flink.statefun.flink.core.message with parameters of type Address

Modifier and Type	Method and Description
Message	MessageFactory.from(Address from, Address to, java.lang.Object payload)
Message	MessageFactory.from(Address from, Address to, java.lang.Object payload, java.lang.String cancellationToken)
RoutableMessageBuilder	RoutableMessageBuilder.withSourceAddress(Address from)
RoutableMessageBuilder	RoutableMessageBuilder.withTargetAddress(Address target)

Uses of Address in org.apache.flink.statefun.flink.core.reqreply

Constructors in org.apache.flink.statefun.flink.core.reqreply with parameters of type Address

Constructor and Description
ToFunctionRequestSummary(Address address, int totalSizeInBytes, int numberOfStates, int batchSize)

Uses of Address in org.apache.flink.statefun.flink.core.state

Methods in org.apache.flink.statefun.flink.core.state with parameters of type Address

Modifier and Type	Method and Description
void	State.setCurrentKey(Address address)
void	FlinkState.setCurrentKey(Address address)

Uses of Address in org.apache.flink.statefun.flink.state.processor

Methods in org.apache.flink.statefun.flink.state.processor that return Address

Modifier and Type	Method and Description
Address	Context.self() Returns the Address of the function being bootstrapped.

Uses of Address in org.apache.flink.statefun.flink.state.processor.union

Methods in org.apache.flink.statefun.flink.state.processor.union that return Address

Modifier and Type	Method and Description
Address	TaggedBootstrapData.getTarget()

Methods in org.apache.flink.statefun.flink.state.processor.union with parameters of type Address

Modifier and Type	Method and Description
void	TaggedBootstrapData.setTarget(Address target)

Constructors in org.apache.flink.statefun.flink.state.processor.union with parameters of type Address

Constructor and Description
TaggedBootstrapData(Address target, java.lang.Object payload, int unionIndex)

Uses of Address in org.apache.flink.statefun.sdk

Methods in org.apache.flink.statefun.sdk that return Address

Modifier and Type	Method and Description
Address	Context.caller() Returns the Address of the invoking function.
Address	Context.self() Returns the Address of the invoked function.

Methods in org.apache.flink.statefun.sdk with parameters of type Address

Modifier and Type	Method and Description
void	Context.send(Address to, java.lang.Object message) Invokes another function with an input, identified by the target function's Address.
void	Context.sendAfter(java.time.Duration delay, Address to, java.lang.Object message) Invokes another function with an input, identified by the target function's Address, after a given delay.
void	Context.sendAfter(java.time.Duration delay, Address to, java.lang.Object message, java.lang.String cancellationToken) Invokes another function with an input (associated with a cancellationToken), identified by the target function's Address, after a given delay.

Uses of Address in org.apache.flink.statefun.sdk.io

Methods in org.apache.flink.statefun.sdk.io with parameters of type Address

Modifier and Type	Method and Description
void	Router.Downstream.forward(Address to, T message) Forwards the message as an input to a downstream function, addressed by a specified Address.

Uses of Address in org.apache.flink.statefun.testutils.function

Methods in org.apache.flink.statefun.testutils.function that return types with arguments of type Address

Modifier and Type	Method and Description
java.util.Map<Address,java.util.List<java.lang.Object>>	FunctionTestHarness.invoke(Address from, java.lang.Object message)
java.util.Map<Address,java.util.List<java.lang.Object>>	FunctionTestHarness.invoke(java.lang.Object message)
java.util.Map<Address,java.util.List<java.lang.Object>>	FunctionTestHarness.tick(java.time.Duration duration) Advances the internal clock the harness and fires and pending timers.

Methods in org.apache.flink.statefun.testutils.function with parameters of type Address

Modifier and Type	Method and Description
java.util.Map<Address,java.util.List<java.lang.Object>>	FunctionTestHarness.invoke(Address from, java.lang.Object message)

Uses of Address in org.apache.flink.statefun.testutils.matchers

Methods in org.apache.flink.statefun.testutils.matchers with parameters of type Address

Modifier and Type	Method and Description
static MatchersByAddress	StatefulFunctionMatchers.messagesTo(Address to, org.hamcrest.Matcher<?> matcher, org.hamcrest.Matcher<?>... matchers)

Method parameters in org.apache.flink.statefun.testutils.matchers with type arguments of type Address

Modifier and Type	Method and Description
protected boolean	SentNothingMatcher.matchesSafely(java.util.Map<Address,java.util.List<java.lang.Object>> item)
protected boolean	MessagesSentToAddress.matchesSafely(java.util.Map<Address,java.util.List<java.lang.Object>> item)