org.apache.pulsar.io.twitter

类 TwitterFireHoseConfig

java.lang.Object

org.apache.pulsar.io.twitter.TwitterFireHoseConfig

所有已实现的接口:

Serializable

public class TwitterFireHoseConfig
extends Object
implements Serializable

Configuration object for the Twitter Firehose Connector.

另请参阅:

序列化表格

构造器概要

构造器

构造器和说明
TwitterFireHoseConfig()

方法概要

限定符和类型	方法和说明
List<Long>	getFollowings()
List<String>	getTrackTerms()
static TwitterFireHoseConfig	load(Map<String,Object> map)
static TwitterFireHoseConfig	load(String yamlFile)
void	validate()

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

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

构造器详细资料

TwitterFireHoseConfig

public TwitterFireHoseConfig()

方法详细资料

load

public static TwitterFireHoseConfig load(String yamlFile)
                                  throws IOException

抛出:

IOException

load

public static TwitterFireHoseConfig load(Map<String,Object> map)
                                  throws IOException

抛出:

IOException

validate

public void validate()
              throws IllegalArgumentException

抛出:

IllegalArgumentException

getFollowings

public List<Long> getFollowings()

getTrackTerms

public List<String> getTrackTerms()