org.apache.pulsar.io.kinesis

类 Utils

java.lang.Object

org.apache.pulsar.io.kinesis.Utils

public class Utils
extends Object

构造器概要

构造器

构造器和说明
Utils()

方法概要

限定符和类型	方法和说明
static ByteBuffer	serializeRecordToFlatBuffer(com.google.flatbuffers.FlatBufferBuilder builder, org.apache.pulsar.functions.api.Record<byte[]> record)
static ByteBuffer	serializeRecordToFlatBuffer(org.apache.pulsar.functions.api.Record<byte[]> record) Serialize record to flat-buffer. it's not a thread-safe method.
static String	serializeRecordToJson(org.apache.pulsar.functions.api.Record<byte[]> record) Serializes sink-record into json format.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

Utils

public Utils()

方法详细资料

serializeRecordToFlatBuffer

public static ByteBuffer serializeRecordToFlatBuffer(org.apache.pulsar.functions.api.Record<byte[]> record)

Serialize record to flat-buffer. it's not a thread-safe method.

参数:

record -

返回:

serializeRecordToFlatBuffer

public static ByteBuffer serializeRecordToFlatBuffer(com.google.flatbuffers.FlatBufferBuilder builder,
                                                     org.apache.pulsar.functions.api.Record<byte[]> record)

serializeRecordToJson

public static String serializeRecordToJson(org.apache.pulsar.functions.api.Record<byte[]> record)

Serializes sink-record into json format. It encodes encryption-keys, encryption-param and payload in base64 format so, it can be sent in json.

参数:

record -

返回: