2015-03-19 3 views
0

Я изучаю flume.While я пытаюсь прочитать файл журнала из моей системы. Я использовал следующий код .. загружался из Интернета.Что означает агент agent.sources.tailSrc.command?

agent.sources = tailSrc 
agent.channels = memoryChannel 
agent.sinks = hdfsSink 
agent.sources.tailSrc.type = exec 
agent.sources.tailSrc.command = tail -f /home/kumar/hadoop-2.5.1/logs/hadoop-kumar-namenode-admin.log 
agent.sources.tailSrc.channels = memoryChannel 
agent.sinks.hdfsSink.type = hdfs 
agent.sinks.hdfsSink.hdfs.path = hdfs://localhost:50000/flume 
agent.sinks.hdfsSink.channel = memoryChannel 
agent.channels.memoryChannel.type = memory 
agent.channels.memoryChannel.capacity = 100 

Здесь, в приведенном выше коде я не понимаю, что это среднее tailSrc.commands.I знать источник конфигурирует внутри агента и получить событие (данные) от внешнего источника.

ответ

0

в вашем коде agent.sources.tailSrc.command is exec-source.just ссылается на ссылку.

https://flume.apache.org/FlumeUserGuide.html#exec-source

хвост команда Unix, по умолчанию, хвост будет выводить последние 10 строк входных данных. вы можете дать любую команду или циклы вместо хвоста. Эти команды выполняются и дают результат в качестве источника для агента потока.

http://en.wikipedia.org/wiki/Tail_%28Unix%29

+0

спасибо, sravan! .усмотрите его – senthilkumar

Смежные вопросы