Package | Description |
---|---|
org.apache.flink.statefun.sdk.reqreply.generated |
Modifier and Type | Method and Description |
---|---|
FromFunction.DelayedInvocation.Builder |
FromFunction.InvocationResponse.Builder.addDelayedInvocationsBuilder()
repeated .io.statefun.sdk.reqreply.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.DelayedInvocation.Builder |
FromFunction.InvocationResponse.Builder.addDelayedInvocationsBuilder(int index)
repeated .io.statefun.sdk.reqreply.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.addRepeatedField(Descriptors.FieldDescriptor field,
java.lang.Object value) |
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.clear() |
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.clearArgument()
the invocation argument
|
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.clearCancellationToken()
an optional cancellation token that can be used to request the "unsending" of a delayed message.
|
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.clearDelayInMs()
the amount of milliseconds to wait before sending this message
|
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.clearField(Descriptors.FieldDescriptor field) |
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.clearIsCancellationRequest()
a boolean value (default false) that indicates rather this is a regular delayed message, or (true) a message
cancellation request.
|
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.clearOneof(Descriptors.OneofDescriptor oneof) |
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.clearTarget()
the target address to send this message to
|
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.clone() |
FromFunction.DelayedInvocation.Builder |
FromFunction.InvocationResponse.Builder.getDelayedInvocationsBuilder(int index)
repeated .io.statefun.sdk.reqreply.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.mergeArgument(TypedValue value)
the invocation argument
|
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.mergeFrom(CodedInputStream input,
ExtensionRegistryLite extensionRegistry) |
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.mergeFrom(FromFunction.DelayedInvocation other) |
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.mergeFrom(Message other) |
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.mergeTarget(Address value)
the target address to send this message to
|
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.mergeUnknownFields(UnknownFieldSet unknownFields) |
static FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.newBuilder() |
static FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.newBuilder(FromFunction.DelayedInvocation prototype) |
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.newBuilderForType() |
protected FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.newBuilderForType(GeneratedMessageV3.BuilderParent parent) |
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.setArgument(TypedValue.Builder builderForValue)
the invocation argument
|
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.setArgument(TypedValue value)
the invocation argument
|
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.setCancellationToken(java.lang.String value)
an optional cancellation token that can be used to request the "unsending" of a delayed message.
|
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.setCancellationTokenBytes(ByteString value)
an optional cancellation token that can be used to request the "unsending" of a delayed message.
|
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.setDelayInMs(long value)
the amount of milliseconds to wait before sending this message
|
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.setField(Descriptors.FieldDescriptor field,
java.lang.Object value) |
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.setIsCancellationRequest(boolean value)
a boolean value (default false) that indicates rather this is a regular delayed message, or (true) a message
cancellation request.
|
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.setRepeatedField(Descriptors.FieldDescriptor field,
int index,
java.lang.Object value) |
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.setTarget(Address.Builder builderForValue)
the target address to send this message to
|
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.setTarget(Address value)
the target address to send this message to
|
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.Builder.setUnknownFields(UnknownFieldSet unknownFields) |
FromFunction.DelayedInvocation.Builder |
FromFunction.DelayedInvocation.toBuilder() |
Modifier and Type | Method and Description |
---|---|
java.util.List<FromFunction.DelayedInvocation.Builder> |
FromFunction.InvocationResponse.Builder.getDelayedInvocationsBuilderList()
repeated .io.statefun.sdk.reqreply.FromFunction.DelayedInvocation delayed_invocations = 3; |
Modifier and Type | Method and Description |
---|---|
FromFunction.InvocationResponse.Builder |
FromFunction.InvocationResponse.Builder.addDelayedInvocations(FromFunction.DelayedInvocation.Builder builderForValue)
repeated .io.statefun.sdk.reqreply.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.InvocationResponse.Builder |
FromFunction.InvocationResponse.Builder.addDelayedInvocations(int index,
FromFunction.DelayedInvocation.Builder builderForValue)
repeated .io.statefun.sdk.reqreply.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.InvocationResponse.Builder |
FromFunction.InvocationResponse.Builder.setDelayedInvocations(int index,
FromFunction.DelayedInvocation.Builder builderForValue)
repeated .io.statefun.sdk.reqreply.FromFunction.DelayedInvocation delayed_invocations = 3; |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.