org.apache.pulsar.io.twitter.data

类 TwitterRecord

java.lang.Object

org.apache.pulsar.io.twitter.data.TwitterRecord

所有已实现的接口:

org.apache.pulsar.functions.api.Record<TweetData>

public class TwitterRecord
extends Object
implements org.apache.pulsar.functions.api.Record<TweetData>

Twitter Record object.

构造器概要

构造器

构造器和说明
TwitterRecord(TweetData tweet, boolean guestimateTweetTime)

方法概要

限定符和类型	方法和说明
Optional<Long>	getEventTime()
Optional<String>	getKey()
TweetData	getValue()

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

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

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

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

构造器详细资料

TwitterRecord

public TwitterRecord(TweetData tweet,
                     boolean guestimateTweetTime)

方法详细资料

getKey

public Optional<String> getKey()

指定者:

getKey 在接口中 org.apache.pulsar.functions.api.Record<TweetData>

getEventTime

public Optional<Long> getEventTime()

指定者:

getEventTime 在接口中 org.apache.pulsar.functions.api.Record<TweetData>

getValue

public TweetData getValue()

指定者:

getValue 在接口中 org.apache.pulsar.functions.api.Record<TweetData>