Class PubsubMessages.DeserializeBytesIntoPubsubMessagePayloadOnly
java.lang.Object
org.apache.beam.sdk.io.gcp.pubsub.PubsubMessages.DeserializeBytesIntoPubsubMessagePayloadOnly
- All Implemented Interfaces:
Serializable
,ProcessFunction<byte[],
,PubsubMessage> SerializableFunction<byte[],
PubsubMessage>
- Enclosing class:
PubsubMessages
public static class PubsubMessages.DeserializeBytesIntoPubsubMessagePayloadOnly
extends Object
implements SerializableFunction<byte[],PubsubMessage>
- See Also:
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionapply
(byte[] value) Returns the result of invoking this function on the given input.
-
Constructor Details
-
DeserializeBytesIntoPubsubMessagePayloadOnly
public DeserializeBytesIntoPubsubMessagePayloadOnly()
-
-
Method Details
-
apply
Description copied from interface:SerializableFunction
Returns the result of invoking this function on the given input.- Specified by:
apply
in interfaceProcessFunction<byte[],
PubsubMessage> - Specified by:
apply
in interfaceSerializableFunction<byte[],
PubsubMessage>
-