org.apache.pulsar.io.kinesis

类 KinesisRecord

java.lang.Object

org.apache.pulsar.io.kinesis.KinesisRecord

所有已实现的接口:

org.apache.pulsar.functions.api.Record<byte[]>

public class KinesisRecord
extends Object
implements org.apache.pulsar.functions.api.Record<byte[]>

字段概要

字段

限定符和类型	字段和说明
static String	ARRIVAL_TIMESTAMP
static String	ENCRYPTION_TYPE
static String	PARTITION_KEY
static String	SEQUENCE_NUMBER

构造器概要

构造器

构造器和说明
KinesisRecord(software.amazon.kinesis.retrieval.KinesisClientRecord record)

方法概要

限定符和类型	方法和说明
Optional<String>	getKey()
Map<String,String>	getProperties()
byte[]	getValue()
void	setProperty(String key, String value)

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

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

从接口继承的方法 org.apache.pulsar.functions.api.Record

ack, fail, getDestinationTopic, getEventTime, getMessage, getPartitionId, getRecordSequence, getSchema, getTopicName

字段详细资料

ARRIVAL_TIMESTAMP

public static final String ARRIVAL_TIMESTAMP

另请参阅:

常量字段值

ENCRYPTION_TYPE

public static final String ENCRYPTION_TYPE

另请参阅:

常量字段值

PARTITION_KEY

public static final String PARTITION_KEY

另请参阅:

常量字段值

SEQUENCE_NUMBER

public static final String SEQUENCE_NUMBER

另请参阅:

常量字段值

构造器详细资料

KinesisRecord

public KinesisRecord(software.amazon.kinesis.retrieval.KinesisClientRecord record)

方法详细资料

getKey

public Optional<String> getKey()

指定者:

getKey 在接口中 org.apache.pulsar.functions.api.Record<byte[]>

getValue

public byte[] getValue()

指定者:

getValue 在接口中 org.apache.pulsar.functions.api.Record<byte[]>

getProperties

public Map<String,String> getProperties()

指定者:

getProperties 在接口中 org.apache.pulsar.functions.api.Record<byte[]>

setProperty

public void setProperty(String key,
                        String value)