Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<Slice> |
RequestReplyHandler.handle(Slice input)
Handles a
Stateful Functions invocation. |
java.util.concurrent.CompletableFuture<Slice> |
ConcurrentRequestReplyHandler.handle(Slice requestBytes) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<Slice> |
RequestReplyHandler.handle(Slice input)
Handles a
Stateful Functions invocation. |
java.util.concurrent.CompletableFuture<Slice> |
ConcurrentRequestReplyHandler.handle(Slice requestBytes) |
Modifier and Type | Method and Description |
---|---|
KafkaEgressMessage.Builder |
KafkaEgressMessage.Builder.withKey(Slice slice) |
KinesisEgressMessage.Builder |
KinesisEgressMessage.Builder.withPartitionKey(Slice key) |
KinesisEgressMessage.Builder |
KinesisEgressMessage.Builder.withStream(Slice stream) |
KafkaEgressMessage.Builder |
KafkaEgressMessage.Builder.withTopic(Slice topic) |
KinesisEgressMessage.Builder |
KinesisEgressMessage.Builder.withUtf8ExplicitHashKey(Slice utf8Slice) |
KinesisEgressMessage.Builder |
KinesisEgressMessage.Builder.withValue(Slice value) |
KafkaEgressMessage.Builder |
KafkaEgressMessage.Builder.withValue(Slice slice) |
Modifier and Type | Method and Description |
---|---|
Slice |
EgressMessage.egressMessageValueBytes() |
Slice |
EgressMessageWrapper.egressMessageValueBytes() |
Slice |
Message.rawValue() |
Slice |
MessageWrapper.rawValue() |
Modifier and Type | Method and Description |
---|---|
static Slice |
SliceProtobufUtil.asSlice(ByteString byteString) |
static Slice |
Slices.copyFromUtf8(java.lang.String input) |
Slice |
SliceOutput.copyOf() |
static Slice |
Slices.copyOf(byte[] bytes) |
static Slice |
Slices.copyOf(byte[] bytes,
int offset,
int len) |
static Slice |
Slices.copyOf(java.io.InputStream inputStream,
int expectedStreamSize) |
static Slice |
SliceProtobufUtil.toSlice(Message message) |
Slice |
SliceOutput.view() |
static Slice |
Slices.wrap(byte[] bytes) |
static Slice |
Slices.wrap(byte[] bytes,
int offset,
int len) |
static Slice |
Slices.wrap(java.nio.ByteBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
static ByteString |
SliceProtobufUtil.asByteString(Slice slice) |
static <T> T |
SliceProtobufUtil.parseFrom(Parser<T> parser,
Slice slice) |
void |
SliceOutput.write(Slice slice) |
Modifier and Type | Method and Description |
---|---|
Slice |
TypeSerializer.serialize(T value) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<Slice> |
SliceType.typeSerializer() |
Modifier and Type | Method and Description |
---|---|
T |
TypeSerializer.deserialize(Slice bytes) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.