类的使用
org.apache.pulsar.io.kinesis.KinesisRecord

使用KinesisRecord的程序包

程序包	说明
org.apache.pulsar.io.kinesis

org.apache.pulsar.io.kinesis中KinesisRecord的使用

返回KinesisRecord的org.apache.pulsar.io.kinesis中的方法

限定符和类型	方法和说明
KinesisRecord	KinesisSource.read()

类型变量类型为KinesisRecord的org.apache.pulsar.io.kinesis中的构造器参数

构造器和说明
KinesisRecordProcessor(LinkedBlockingQueue<KinesisRecord> queue, KinesisSourceConfig config)
KinesisRecordProcessorFactory(LinkedBlockingQueue<KinesisRecord> queue, KinesisSourceConfig kinesisSourceConfig)