public static final class FromFunction.InvocationResponse.Builder extends com.google.protobuf.GeneratedMessageV3.Builder<FromFunction.InvocationResponse.Builder> implements FromFunction.InvocationResponseOrBuilder
InvocationResponse represents a result of an org.apache.flink.statefun.flink.core.polyglot.ToFunction.InvocationBatchRequest it contains a list of state mutation to preform as a result of computing this batch, and a list of outgoing messages.Protobuf type
org.apache.flink.statefun.flink.core.polyglot.FromFunction.InvocationResponse
Modifier and Type | Method and Description |
---|---|
FromFunction.InvocationResponse.Builder |
addAllDelayedInvocations(java.lang.Iterable<? extends FromFunction.DelayedInvocation> values)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.InvocationResponse.Builder |
addAllOutgoingEgresses(java.lang.Iterable<? extends FromFunction.EgressMessage> values)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
FromFunction.InvocationResponse.Builder |
addAllOutgoingMessages(java.lang.Iterable<? extends FromFunction.Invocation> values)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
FromFunction.InvocationResponse.Builder |
addAllStateMutations(java.lang.Iterable<? extends FromFunction.PersistedValueMutation> values)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
FromFunction.InvocationResponse.Builder |
addDelayedInvocations(FromFunction.DelayedInvocation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.InvocationResponse.Builder |
addDelayedInvocations(FromFunction.DelayedInvocation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.InvocationResponse.Builder |
addDelayedInvocations(int index,
FromFunction.DelayedInvocation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.InvocationResponse.Builder |
addDelayedInvocations(int index,
FromFunction.DelayedInvocation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.DelayedInvocation.Builder |
addDelayedInvocationsBuilder()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.DelayedInvocation.Builder |
addDelayedInvocationsBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.InvocationResponse.Builder |
addOutgoingEgresses(FromFunction.EgressMessage.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
FromFunction.InvocationResponse.Builder |
addOutgoingEgresses(FromFunction.EgressMessage value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
FromFunction.InvocationResponse.Builder |
addOutgoingEgresses(int index,
FromFunction.EgressMessage.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
FromFunction.InvocationResponse.Builder |
addOutgoingEgresses(int index,
FromFunction.EgressMessage value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
FromFunction.EgressMessage.Builder |
addOutgoingEgressesBuilder()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
FromFunction.EgressMessage.Builder |
addOutgoingEgressesBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
FromFunction.InvocationResponse.Builder |
addOutgoingMessages(FromFunction.Invocation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
FromFunction.InvocationResponse.Builder |
addOutgoingMessages(FromFunction.Invocation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
FromFunction.InvocationResponse.Builder |
addOutgoingMessages(int index,
FromFunction.Invocation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
FromFunction.InvocationResponse.Builder |
addOutgoingMessages(int index,
FromFunction.Invocation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
FromFunction.Invocation.Builder |
addOutgoingMessagesBuilder()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
FromFunction.Invocation.Builder |
addOutgoingMessagesBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
FromFunction.InvocationResponse.Builder |
addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
java.lang.Object value) |
FromFunction.InvocationResponse.Builder |
addStateMutations(FromFunction.PersistedValueMutation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
FromFunction.InvocationResponse.Builder |
addStateMutations(FromFunction.PersistedValueMutation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
FromFunction.InvocationResponse.Builder |
addStateMutations(int index,
FromFunction.PersistedValueMutation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
FromFunction.InvocationResponse.Builder |
addStateMutations(int index,
FromFunction.PersistedValueMutation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
FromFunction.PersistedValueMutation.Builder |
addStateMutationsBuilder()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
FromFunction.PersistedValueMutation.Builder |
addStateMutationsBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
FromFunction.InvocationResponse |
build() |
FromFunction.InvocationResponse |
buildPartial() |
FromFunction.InvocationResponse.Builder |
clear() |
FromFunction.InvocationResponse.Builder |
clearDelayedInvocations()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.InvocationResponse.Builder |
clearField(com.google.protobuf.Descriptors.FieldDescriptor field) |
FromFunction.InvocationResponse.Builder |
clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) |
FromFunction.InvocationResponse.Builder |
clearOutgoingEgresses()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
FromFunction.InvocationResponse.Builder |
clearOutgoingMessages()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
FromFunction.InvocationResponse.Builder |
clearStateMutations()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
FromFunction.InvocationResponse.Builder |
clone() |
FromFunction.InvocationResponse |
getDefaultInstanceForType() |
FromFunction.DelayedInvocation |
getDelayedInvocations(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.DelayedInvocation.Builder |
getDelayedInvocationsBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
java.util.List<FromFunction.DelayedInvocation.Builder> |
getDelayedInvocationsBuilderList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
int |
getDelayedInvocationsCount()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
java.util.List<FromFunction.DelayedInvocation> |
getDelayedInvocationsList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.DelayedInvocationOrBuilder |
getDelayedInvocationsOrBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
java.util.List<? extends FromFunction.DelayedInvocationOrBuilder> |
getDelayedInvocationsOrBuilderList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
com.google.protobuf.Descriptors.Descriptor |
getDescriptorForType() |
FromFunction.EgressMessage |
getOutgoingEgresses(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
FromFunction.EgressMessage.Builder |
getOutgoingEgressesBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
java.util.List<FromFunction.EgressMessage.Builder> |
getOutgoingEgressesBuilderList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
int |
getOutgoingEgressesCount()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
java.util.List<FromFunction.EgressMessage> |
getOutgoingEgressesList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
FromFunction.EgressMessageOrBuilder |
getOutgoingEgressesOrBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
java.util.List<? extends FromFunction.EgressMessageOrBuilder> |
getOutgoingEgressesOrBuilderList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
FromFunction.Invocation |
getOutgoingMessages(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
FromFunction.Invocation.Builder |
getOutgoingMessagesBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
java.util.List<FromFunction.Invocation.Builder> |
getOutgoingMessagesBuilderList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
int |
getOutgoingMessagesCount()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
java.util.List<FromFunction.Invocation> |
getOutgoingMessagesList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
FromFunction.InvocationOrBuilder |
getOutgoingMessagesOrBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
java.util.List<? extends FromFunction.InvocationOrBuilder> |
getOutgoingMessagesOrBuilderList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
FromFunction.PersistedValueMutation |
getStateMutations(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
FromFunction.PersistedValueMutation.Builder |
getStateMutationsBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
java.util.List<FromFunction.PersistedValueMutation.Builder> |
getStateMutationsBuilderList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
int |
getStateMutationsCount()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
java.util.List<FromFunction.PersistedValueMutation> |
getStateMutationsList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
FromFunction.PersistedValueMutationOrBuilder |
getStateMutationsOrBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
java.util.List<? extends FromFunction.PersistedValueMutationOrBuilder> |
getStateMutationsOrBuilderList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
FromFunction.InvocationResponse.Builder |
mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
FromFunction.InvocationResponse.Builder |
mergeFrom(FromFunction.InvocationResponse other) |
FromFunction.InvocationResponse.Builder |
mergeFrom(com.google.protobuf.Message other) |
FromFunction.InvocationResponse.Builder |
mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
FromFunction.InvocationResponse.Builder |
removeDelayedInvocations(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.InvocationResponse.Builder |
removeOutgoingEgresses(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
FromFunction.InvocationResponse.Builder |
removeOutgoingMessages(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
FromFunction.InvocationResponse.Builder |
removeStateMutations(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
FromFunction.InvocationResponse.Builder |
setDelayedInvocations(int index,
FromFunction.DelayedInvocation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.InvocationResponse.Builder |
setDelayedInvocations(int index,
FromFunction.DelayedInvocation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3; |
FromFunction.InvocationResponse.Builder |
setField(com.google.protobuf.Descriptors.FieldDescriptor field,
java.lang.Object value) |
FromFunction.InvocationResponse.Builder |
setOutgoingEgresses(int index,
FromFunction.EgressMessage.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
FromFunction.InvocationResponse.Builder |
setOutgoingEgresses(int index,
FromFunction.EgressMessage value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4; |
FromFunction.InvocationResponse.Builder |
setOutgoingMessages(int index,
FromFunction.Invocation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
FromFunction.InvocationResponse.Builder |
setOutgoingMessages(int index,
FromFunction.Invocation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2; |
FromFunction.InvocationResponse.Builder |
setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
int index,
java.lang.Object value) |
FromFunction.InvocationResponse.Builder |
setStateMutations(int index,
FromFunction.PersistedValueMutation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
FromFunction.InvocationResponse.Builder |
setStateMutations(int index,
FromFunction.PersistedValueMutation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1; |
FromFunction.InvocationResponse.Builder |
setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, internalGetMapField, internalGetMutableMapField, isClean, markClean, newBuilderForField, onBuilt, onChanged, setUnknownFieldsProto3
findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toString
addAll, addAll, mergeFrom, newUninitializedMessageException
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable
in class com.google.protobuf.GeneratedMessageV3.Builder<FromFunction.InvocationResponse.Builder>
public FromFunction.InvocationResponse.Builder clear()
clear
in interface com.google.protobuf.Message.Builder
clear
in interface com.google.protobuf.MessageLite.Builder
clear
in class com.google.protobuf.GeneratedMessageV3.Builder<FromFunction.InvocationResponse.Builder>
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
getDescriptorForType
in interface com.google.protobuf.Message.Builder
getDescriptorForType
in interface com.google.protobuf.MessageOrBuilder
getDescriptorForType
in class com.google.protobuf.GeneratedMessageV3.Builder<FromFunction.InvocationResponse.Builder>
public FromFunction.InvocationResponse getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder
public FromFunction.InvocationResponse build()
build
in interface com.google.protobuf.Message.Builder
build
in interface com.google.protobuf.MessageLite.Builder
public FromFunction.InvocationResponse buildPartial()
buildPartial
in interface com.google.protobuf.Message.Builder
buildPartial
in interface com.google.protobuf.MessageLite.Builder
public FromFunction.InvocationResponse.Builder clone()
clone
in interface com.google.protobuf.Message.Builder
clone
in interface com.google.protobuf.MessageLite.Builder
clone
in class com.google.protobuf.GeneratedMessageV3.Builder<FromFunction.InvocationResponse.Builder>
public FromFunction.InvocationResponse.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value)
setField
in interface com.google.protobuf.Message.Builder
setField
in class com.google.protobuf.GeneratedMessageV3.Builder<FromFunction.InvocationResponse.Builder>
public FromFunction.InvocationResponse.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
clearField
in interface com.google.protobuf.Message.Builder
clearField
in class com.google.protobuf.GeneratedMessageV3.Builder<FromFunction.InvocationResponse.Builder>
public FromFunction.InvocationResponse.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
clearOneof
in interface com.google.protobuf.Message.Builder
clearOneof
in class com.google.protobuf.GeneratedMessageV3.Builder<FromFunction.InvocationResponse.Builder>
public FromFunction.InvocationResponse.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value)
setRepeatedField
in interface com.google.protobuf.Message.Builder
setRepeatedField
in class com.google.protobuf.GeneratedMessageV3.Builder<FromFunction.InvocationResponse.Builder>
public FromFunction.InvocationResponse.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value)
addRepeatedField
in interface com.google.protobuf.Message.Builder
addRepeatedField
in class com.google.protobuf.GeneratedMessageV3.Builder<FromFunction.InvocationResponse.Builder>
public FromFunction.InvocationResponse.Builder mergeFrom(com.google.protobuf.Message other)
mergeFrom
in interface com.google.protobuf.Message.Builder
mergeFrom
in class com.google.protobuf.AbstractMessage.Builder<FromFunction.InvocationResponse.Builder>
public FromFunction.InvocationResponse.Builder mergeFrom(FromFunction.InvocationResponse other)
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLiteOrBuilder
isInitialized
in class com.google.protobuf.GeneratedMessageV3.Builder<FromFunction.InvocationResponse.Builder>
public FromFunction.InvocationResponse.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
mergeFrom
in interface com.google.protobuf.Message.Builder
mergeFrom
in interface com.google.protobuf.MessageLite.Builder
mergeFrom
in class com.google.protobuf.AbstractMessage.Builder<FromFunction.InvocationResponse.Builder>
java.io.IOException
public java.util.List<FromFunction.PersistedValueMutation> getStateMutationsList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
getStateMutationsList
in interface FromFunction.InvocationResponseOrBuilder
public int getStateMutationsCount()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
getStateMutationsCount
in interface FromFunction.InvocationResponseOrBuilder
public FromFunction.PersistedValueMutation getStateMutations(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
getStateMutations
in interface FromFunction.InvocationResponseOrBuilder
public FromFunction.InvocationResponse.Builder setStateMutations(int index, FromFunction.PersistedValueMutation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
public FromFunction.InvocationResponse.Builder setStateMutations(int index, FromFunction.PersistedValueMutation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
public FromFunction.InvocationResponse.Builder addStateMutations(FromFunction.PersistedValueMutation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
public FromFunction.InvocationResponse.Builder addStateMutations(int index, FromFunction.PersistedValueMutation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
public FromFunction.InvocationResponse.Builder addStateMutations(FromFunction.PersistedValueMutation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
public FromFunction.InvocationResponse.Builder addStateMutations(int index, FromFunction.PersistedValueMutation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
public FromFunction.InvocationResponse.Builder addAllStateMutations(java.lang.Iterable<? extends FromFunction.PersistedValueMutation> values)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
public FromFunction.InvocationResponse.Builder clearStateMutations()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
public FromFunction.InvocationResponse.Builder removeStateMutations(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
public FromFunction.PersistedValueMutation.Builder getStateMutationsBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
public FromFunction.PersistedValueMutationOrBuilder getStateMutationsOrBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
getStateMutationsOrBuilder
in interface FromFunction.InvocationResponseOrBuilder
public java.util.List<? extends FromFunction.PersistedValueMutationOrBuilder> getStateMutationsOrBuilderList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
getStateMutationsOrBuilderList
in interface FromFunction.InvocationResponseOrBuilder
public FromFunction.PersistedValueMutation.Builder addStateMutationsBuilder()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
public FromFunction.PersistedValueMutation.Builder addStateMutationsBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
public java.util.List<FromFunction.PersistedValueMutation.Builder> getStateMutationsBuilderList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation state_mutations = 1;
public java.util.List<FromFunction.Invocation> getOutgoingMessagesList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
getOutgoingMessagesList
in interface FromFunction.InvocationResponseOrBuilder
public int getOutgoingMessagesCount()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
getOutgoingMessagesCount
in interface FromFunction.InvocationResponseOrBuilder
public FromFunction.Invocation getOutgoingMessages(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
getOutgoingMessages
in interface FromFunction.InvocationResponseOrBuilder
public FromFunction.InvocationResponse.Builder setOutgoingMessages(int index, FromFunction.Invocation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
public FromFunction.InvocationResponse.Builder setOutgoingMessages(int index, FromFunction.Invocation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
public FromFunction.InvocationResponse.Builder addOutgoingMessages(FromFunction.Invocation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
public FromFunction.InvocationResponse.Builder addOutgoingMessages(int index, FromFunction.Invocation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
public FromFunction.InvocationResponse.Builder addOutgoingMessages(FromFunction.Invocation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
public FromFunction.InvocationResponse.Builder addOutgoingMessages(int index, FromFunction.Invocation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
public FromFunction.InvocationResponse.Builder addAllOutgoingMessages(java.lang.Iterable<? extends FromFunction.Invocation> values)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
public FromFunction.InvocationResponse.Builder clearOutgoingMessages()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
public FromFunction.InvocationResponse.Builder removeOutgoingMessages(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
public FromFunction.Invocation.Builder getOutgoingMessagesBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
public FromFunction.InvocationOrBuilder getOutgoingMessagesOrBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
getOutgoingMessagesOrBuilder
in interface FromFunction.InvocationResponseOrBuilder
public java.util.List<? extends FromFunction.InvocationOrBuilder> getOutgoingMessagesOrBuilderList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
getOutgoingMessagesOrBuilderList
in interface FromFunction.InvocationResponseOrBuilder
public FromFunction.Invocation.Builder addOutgoingMessagesBuilder()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
public FromFunction.Invocation.Builder addOutgoingMessagesBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
public java.util.List<FromFunction.Invocation.Builder> getOutgoingMessagesBuilderList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation outgoing_messages = 2;
public java.util.List<FromFunction.DelayedInvocation> getDelayedInvocationsList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
getDelayedInvocationsList
in interface FromFunction.InvocationResponseOrBuilder
public int getDelayedInvocationsCount()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
getDelayedInvocationsCount
in interface FromFunction.InvocationResponseOrBuilder
public FromFunction.DelayedInvocation getDelayedInvocations(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
getDelayedInvocations
in interface FromFunction.InvocationResponseOrBuilder
public FromFunction.InvocationResponse.Builder setDelayedInvocations(int index, FromFunction.DelayedInvocation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
public FromFunction.InvocationResponse.Builder setDelayedInvocations(int index, FromFunction.DelayedInvocation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
public FromFunction.InvocationResponse.Builder addDelayedInvocations(FromFunction.DelayedInvocation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
public FromFunction.InvocationResponse.Builder addDelayedInvocations(int index, FromFunction.DelayedInvocation value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
public FromFunction.InvocationResponse.Builder addDelayedInvocations(FromFunction.DelayedInvocation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
public FromFunction.InvocationResponse.Builder addDelayedInvocations(int index, FromFunction.DelayedInvocation.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
public FromFunction.InvocationResponse.Builder addAllDelayedInvocations(java.lang.Iterable<? extends FromFunction.DelayedInvocation> values)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
public FromFunction.InvocationResponse.Builder clearDelayedInvocations()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
public FromFunction.InvocationResponse.Builder removeDelayedInvocations(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
public FromFunction.DelayedInvocation.Builder getDelayedInvocationsBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
public FromFunction.DelayedInvocationOrBuilder getDelayedInvocationsOrBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
getDelayedInvocationsOrBuilder
in interface FromFunction.InvocationResponseOrBuilder
public java.util.List<? extends FromFunction.DelayedInvocationOrBuilder> getDelayedInvocationsOrBuilderList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
getDelayedInvocationsOrBuilderList
in interface FromFunction.InvocationResponseOrBuilder
public FromFunction.DelayedInvocation.Builder addDelayedInvocationsBuilder()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
public FromFunction.DelayedInvocation.Builder addDelayedInvocationsBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
public java.util.List<FromFunction.DelayedInvocation.Builder> getDelayedInvocationsBuilderList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation delayed_invocations = 3;
public java.util.List<FromFunction.EgressMessage> getOutgoingEgressesList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
getOutgoingEgressesList
in interface FromFunction.InvocationResponseOrBuilder
public int getOutgoingEgressesCount()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
getOutgoingEgressesCount
in interface FromFunction.InvocationResponseOrBuilder
public FromFunction.EgressMessage getOutgoingEgresses(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
getOutgoingEgresses
in interface FromFunction.InvocationResponseOrBuilder
public FromFunction.InvocationResponse.Builder setOutgoingEgresses(int index, FromFunction.EgressMessage value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
public FromFunction.InvocationResponse.Builder setOutgoingEgresses(int index, FromFunction.EgressMessage.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
public FromFunction.InvocationResponse.Builder addOutgoingEgresses(FromFunction.EgressMessage value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
public FromFunction.InvocationResponse.Builder addOutgoingEgresses(int index, FromFunction.EgressMessage value)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
public FromFunction.InvocationResponse.Builder addOutgoingEgresses(FromFunction.EgressMessage.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
public FromFunction.InvocationResponse.Builder addOutgoingEgresses(int index, FromFunction.EgressMessage.Builder builderForValue)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
public FromFunction.InvocationResponse.Builder addAllOutgoingEgresses(java.lang.Iterable<? extends FromFunction.EgressMessage> values)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
public FromFunction.InvocationResponse.Builder clearOutgoingEgresses()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
public FromFunction.InvocationResponse.Builder removeOutgoingEgresses(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
public FromFunction.EgressMessage.Builder getOutgoingEgressesBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
public FromFunction.EgressMessageOrBuilder getOutgoingEgressesOrBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
getOutgoingEgressesOrBuilder
in interface FromFunction.InvocationResponseOrBuilder
public java.util.List<? extends FromFunction.EgressMessageOrBuilder> getOutgoingEgressesOrBuilderList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
getOutgoingEgressesOrBuilderList
in interface FromFunction.InvocationResponseOrBuilder
public FromFunction.EgressMessage.Builder addOutgoingEgressesBuilder()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
public FromFunction.EgressMessage.Builder addOutgoingEgressesBuilder(int index)
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
public java.util.List<FromFunction.EgressMessage.Builder> getOutgoingEgressesBuilderList()
repeated .org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage outgoing_egresses = 4;
public final FromFunction.InvocationResponse.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
setUnknownFields
in interface com.google.protobuf.Message.Builder
setUnknownFields
in class com.google.protobuf.GeneratedMessageV3.Builder<FromFunction.InvocationResponse.Builder>
public final FromFunction.InvocationResponse.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
mergeUnknownFields
in interface com.google.protobuf.Message.Builder
mergeUnknownFields
in class com.google.protobuf.GeneratedMessageV3.Builder<FromFunction.InvocationResponse.Builder>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.