collectorSource[( port )]

Collector source，監(jiān)聽端口匯聚數(shù)據(jù)

autoCollectorSource

通過master協(xié)調(diào)物理節(jié)點(diǎn)自動(dòng)匯聚數(shù)據(jù)

logicalSource

邏輯source，由master分配端口并監(jiān)聽rpcSink

null

console

監(jiān)聽用戶編輯歷史和快捷鍵輸入，只在node_nowatch模式下可用

stdin

監(jiān)聽標(biāo)準(zhǔn)輸入，只在node_nowatch模式下可用，每行將作為一個(gè)event source

rpcSource( port )

由rpc框架(thrift/avro)監(jiān)聽tcp端口

text(" filename ")

一次性讀取一個(gè)文本，每行為一個(gè)event

tail(" filename "[, startFromEnd =false])

每行為一個(gè)event。監(jiān)聽文件尾部的追加行，如果startFromEnd為true，tail將從文件尾讀取，如果為false，tail將從文件開始讀取全部數(shù)據(jù)

multitail(" filename "[, file2 [, file3 … ] ])

同上，同時(shí)監(jiān)聽多個(gè)文件的末尾

tailDir(" dirname "[, fileregex=".*"[, startFromEnd=false[, recurseDepth=0]]])

監(jiān)聽目錄中的文件末尾，使用正則去選定需要監(jiān)聽的文件（不包含目錄），recurseDepth為遞歸監(jiān)聽其下子目錄的深度

seqfile(" filename ")

監(jiān)聽hdfs的sequencefile，全路徑

syslogUdp( port )

監(jiān)聽Udp端口

syslogTcp( port )

監(jiān)聽Tcp端口

syslogTcp1( port )

只監(jiān)聽Tcp端口的一個(gè)鏈接

execPeriodic(" cmdline ", ms )

周期執(zhí)行指令，監(jiān)聽指令的輸出，整個(gè)輸出都被作為一個(gè)event

execStream(" cmdline ")

執(zhí)行指令，監(jiān)聽指令的輸出，輸出的每一行被作為一個(gè)event

exec(" cmdline "[, aggregate =false[, restart =false[, period =0]]])

執(zhí)行指令，監(jiān)聽指令的輸出，aggregate如果為true，整個(gè)輸出作為一個(gè)event如果為false，則每行作為一個(gè)event。如果restart為true，則按period為周期重新運(yùn)行

synth( msgCount , msgSize )

隨即產(chǎn)生字符串event,msgCount為產(chǎn)生數(shù)量，msgSize為串長度

synthrndsize( msgCount , minSize , maxSize )

同上，minSize – maxSize

nonlsynth( msgCount , msgSize )

asciisynth( msgCount , msgSize )

Ascii碼字符

twitter(" username "," pw "[," url "])

尼瑪twitter的插件啊

irc(" server ", port , " nick "," chan ")

scribe[(+ port )]

Scribe插件

report[(periodMillis)]

生成所有physical node報(bào)告為事件源