Package | Description |
---|---|
org.apache.flink.statefun.flink.core.generated | |
org.apache.flink.statefun.flink.core.message |
Modifier and Type | Method and Description |
---|---|
Payload |
Payload.Builder.build() |
Payload |
Payload.Builder.buildPartial() |
static Payload |
Payload.getDefaultInstance() |
Payload |
Payload.getDefaultInstanceForType() |
Payload |
Payload.Builder.getDefaultInstanceForType() |
Payload |
EnvelopeOrBuilder.getPayload()
.org.apache.flink.statefun.flink.core.Payload payload = 3; |
Payload |
Envelope.getPayload()
.org.apache.flink.statefun.flink.core.Payload payload = 3; |
Payload |
Envelope.Builder.getPayload()
.org.apache.flink.statefun.flink.core.Payload payload = 3; |
static Payload |
Payload.parseDelimitedFrom(java.io.InputStream input) |
static Payload |
Payload.parseDelimitedFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Payload |
Payload.parseFrom(byte[] data) |
static Payload |
Payload.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Payload |
Payload.parseFrom(java.nio.ByteBuffer data) |
static Payload |
Payload.parseFrom(java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Payload |
Payload.parseFrom(com.google.protobuf.ByteString data) |
static Payload |
Payload.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Payload |
Payload.parseFrom(com.google.protobuf.CodedInputStream input) |
static Payload |
Payload.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Payload |
Payload.parseFrom(java.io.InputStream input) |
static Payload |
Payload.parseFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<Payload> |
Payload.getParserForType() |
static com.google.protobuf.Parser<Payload> |
Payload.parser() |
Modifier and Type | Method and Description |
---|---|
Payload.Builder |
Payload.Builder.mergeFrom(Payload other) |
Envelope.Builder |
Envelope.Builder.mergePayload(Payload value)
.org.apache.flink.statefun.flink.core.Payload payload = 3; |
static Payload.Builder |
Payload.newBuilder(Payload prototype) |
Envelope.Builder |
Envelope.Builder.setPayload(Payload value)
.org.apache.flink.statefun.flink.core.Payload payload = 3; |
Modifier and Type | Method and Description |
---|---|
Payload |
MessagePayloadSerializerPb.serialize(java.lang.Object what) |
Payload |
MessagePayloadSerializer.serialize(java.lang.Object payloadObject) |
Payload |
MessagePayloadSerializerRaw.serialize(java.lang.Object what) |
Payload |
MessagePayloadSerializerKryo.serialize(java.lang.Object payloadObject) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
MessagePayloadSerializerPb.deserialize(java.lang.ClassLoader targetClassLoader,
Payload payload) |
java.lang.Object |
MessagePayloadSerializer.deserialize(java.lang.ClassLoader targetClassLoader,
Payload payload) |
java.lang.Object |
MessagePayloadSerializerRaw.deserialize(java.lang.ClassLoader targetClassLoader,
Payload payload) |
java.lang.Object |
MessagePayloadSerializerKryo.deserialize(java.lang.ClassLoader targetClassLoader,
Payload payload) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.