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).
|
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.
|
Modifier and Type | Method and Description |
---|---|
static Address |
PolyglotUtil.polyglotAddressToSdkAddress(Address address) |
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
KeyBy.apply(Address address) |
static Address |
PolyglotUtil.sdkAddressToPolyglotAddress(Address sdkAddress) |
Modifier and Type | Method and Description |
---|---|
Address |
Message.source() |
Address |
Message.target() |
Modifier and Type | Method and Description |
---|---|
Message |
MessageFactory.from(Address from,
Address to,
java.lang.Object payload) |
Modifier and Type | Method and Description |
---|---|
void |
State.setCurrentKey(Address address) |
void |
FlinkState.setCurrentKey(Address address) |
Modifier and Type | Method and Description |
---|---|
Address |
Context.self()
Returns the
Address of the function being bootstrapped. |
Modifier and Type | Method and Description |
---|---|
Address |
TaggedBootstrapData.getTarget() |
Modifier and Type | Method and Description |
---|---|
void |
TaggedBootstrapData.setTarget(Address target) |
Constructor and Description |
---|
TaggedBootstrapData(Address target,
java.lang.Object payload,
int unionIndex) |
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. |
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. |
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 . |
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.
|
Modifier and Type | Method and Description |
---|---|
java.util.Map<Address,java.util.List<java.lang.Object>> |
FunctionTestHarness.invoke(Address from,
java.lang.Object message) |
Modifier and Type | Method and Description |
---|---|
static MatchersByAddress |
StatefulFunctionMatchers.messagesTo(Address to,
org.hamcrest.Matcher<?> matcher,
org.hamcrest.Matcher<?>... matchers) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
MessagesSentToAddress.matchesSafely(java.util.Map<Address,java.util.List<java.lang.Object>> item) |
protected boolean |
SentNothingMatcher.matchesSafely(java.util.Map<Address,java.util.List<java.lang.Object>> item) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.