Package | Description |
---|---|
org.apache.flink.statefun.sdk.java.storage | |
org.apache.flink.statefun.sdk.reqreply.generated |
Modifier and Type | Method and Description |
---|---|
void |
ConcurrentAddressScopedStorage.addMutations(java.util.function.Consumer<FromFunction.PersistedValueMutation> consumer) |
Modifier and Type | Method and Description |
---|---|
FromFunction.PersistedValueMutation |
FromFunction.PersistedValueMutation.Builder.build() |
FromFunction.PersistedValueMutation |
FromFunction.PersistedValueMutation.Builder.buildPartial() |
static FromFunction.PersistedValueMutation |
FromFunction.PersistedValueMutation.getDefaultInstance() |
FromFunction.PersistedValueMutation |
FromFunction.PersistedValueMutation.getDefaultInstanceForType() |
FromFunction.PersistedValueMutation |
FromFunction.PersistedValueMutation.Builder.getDefaultInstanceForType() |
FromFunction.PersistedValueMutation |
FromFunction.InvocationResponseOrBuilder.getStateMutations(int index)
repeated .io.statefun.sdk.reqreply.FromFunction.PersistedValueMutation state_mutations = 1; |
FromFunction.PersistedValueMutation |
FromFunction.InvocationResponse.getStateMutations(int index)
repeated .io.statefun.sdk.reqreply.FromFunction.PersistedValueMutation state_mutations = 1; |
FromFunction.PersistedValueMutation |
FromFunction.InvocationResponse.Builder.getStateMutations(int index)
repeated .io.statefun.sdk.reqreply.FromFunction.PersistedValueMutation state_mutations = 1; |
static FromFunction.PersistedValueMutation |
FromFunction.PersistedValueMutation.parseDelimitedFrom(java.io.InputStream input) |
static FromFunction.PersistedValueMutation |
FromFunction.PersistedValueMutation.parseDelimitedFrom(java.io.InputStream input,
ExtensionRegistryLite extensionRegistry) |
static FromFunction.PersistedValueMutation |
FromFunction.PersistedValueMutation.parseFrom(byte[] data) |
static FromFunction.PersistedValueMutation |
FromFunction.PersistedValueMutation.parseFrom(byte[] data,
ExtensionRegistryLite extensionRegistry) |
static FromFunction.PersistedValueMutation |
FromFunction.PersistedValueMutation.parseFrom(java.nio.ByteBuffer data) |
static FromFunction.PersistedValueMutation |
FromFunction.PersistedValueMutation.parseFrom(java.nio.ByteBuffer data,
ExtensionRegistryLite extensionRegistry) |
static FromFunction.PersistedValueMutation |
FromFunction.PersistedValueMutation.parseFrom(ByteString data) |
static FromFunction.PersistedValueMutation |
FromFunction.PersistedValueMutation.parseFrom(ByteString data,
ExtensionRegistryLite extensionRegistry) |
static FromFunction.PersistedValueMutation |
FromFunction.PersistedValueMutation.parseFrom(CodedInputStream input) |
static FromFunction.PersistedValueMutation |
FromFunction.PersistedValueMutation.parseFrom(CodedInputStream input,
ExtensionRegistryLite extensionRegistry) |
static FromFunction.PersistedValueMutation |
FromFunction.PersistedValueMutation.parseFrom(java.io.InputStream input) |
static FromFunction.PersistedValueMutation |
FromFunction.PersistedValueMutation.parseFrom(java.io.InputStream input,
ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
Parser<FromFunction.PersistedValueMutation> |
FromFunction.PersistedValueMutation.getParserForType() |
java.util.List<FromFunction.PersistedValueMutation> |
FromFunction.InvocationResponseOrBuilder.getStateMutationsList()
repeated .io.statefun.sdk.reqreply.FromFunction.PersistedValueMutation state_mutations = 1; |
java.util.List<FromFunction.PersistedValueMutation> |
FromFunction.InvocationResponse.getStateMutationsList()
repeated .io.statefun.sdk.reqreply.FromFunction.PersistedValueMutation state_mutations = 1; |
java.util.List<FromFunction.PersistedValueMutation> |
FromFunction.InvocationResponse.Builder.getStateMutationsList()
repeated .io.statefun.sdk.reqreply.FromFunction.PersistedValueMutation state_mutations = 1; |
static Parser<FromFunction.PersistedValueMutation> |
FromFunction.PersistedValueMutation.parser() |
Modifier and Type | Method and Description |
---|---|
FromFunction.InvocationResponse.Builder |
FromFunction.InvocationResponse.Builder.addStateMutations(FromFunction.PersistedValueMutation value)
repeated .io.statefun.sdk.reqreply.FromFunction.PersistedValueMutation state_mutations = 1; |
FromFunction.InvocationResponse.Builder |
FromFunction.InvocationResponse.Builder.addStateMutations(int index,
FromFunction.PersistedValueMutation value)
repeated .io.statefun.sdk.reqreply.FromFunction.PersistedValueMutation state_mutations = 1; |
FromFunction.PersistedValueMutation.Builder |
FromFunction.PersistedValueMutation.Builder.mergeFrom(FromFunction.PersistedValueMutation other) |
static FromFunction.PersistedValueMutation.Builder |
FromFunction.PersistedValueMutation.newBuilder(FromFunction.PersistedValueMutation prototype) |
FromFunction.InvocationResponse.Builder |
FromFunction.InvocationResponse.Builder.setStateMutations(int index,
FromFunction.PersistedValueMutation value)
repeated .io.statefun.sdk.reqreply.FromFunction.PersistedValueMutation state_mutations = 1; |
Modifier and Type | Method and Description |
---|---|
FromFunction.InvocationResponse.Builder |
FromFunction.InvocationResponse.Builder.addAllStateMutations(java.lang.Iterable<? extends FromFunction.PersistedValueMutation> values)
repeated .io.statefun.sdk.reqreply.FromFunction.PersistedValueMutation state_mutations = 1; |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.