当前位置:网站首页>Flume learning 1
Flume learning 1
2022-06-30 09:52:00 【Keep-upup】
Definition :
flume Is a highly available 、 Highly reliable 、 A distributed , Log collection 、 polymerization 、 The transmission system . Only log type data , Data such as pictures and videos are not good .
effect :
flume The function of is to read data from the local disk and then transfer the data to HDFS Do offline analysis
flume framework : Data sources --->flume---> Where the data goes

flume Components :
source:Source Is responsible for receiving data to Flume Agent The components of .Source Components can handle various types 、 Various Log data in format , Include avro、thrift、exec、jms、spooling directory、netcat、sequence generator、syslog、http、legacy.(flume To accept from wedServer Read data , Dealing with the outside world . Reading documents 、 Port data, etc ) avro For multi tier flume
channel: The function is to play a buffer role , Don't store data , When all data is sent to sink,channel The data will be deleted
sink:Sink Keep polling Channel And remove them in batches , And batch write these events to the storage Or indexing system 、 Or it could be sent to another Flume Agent. Sink Component destinations include hdfs、logger、avro、thrift、ipc、file、HBase、solr、 Self determination The righteous .
agent:Agent It's a JVM process , It sends data from source to destination in the form of events . Agent There are mainly 3 Component composition ,Source、Channel、Sink.
Flume Installation and deployment
flume Official address :https://flume.apache.org/
Document address :https://flume.apache.org/FlumeUserGuide.html
flume Download address :http://archive.apache.org/dist/flume/
After downloading , take apache-flume-1.7.0-bin.tar.gz Upload to linux
Re decompress :
tar -zxf apache-flume-1.7.0-bin.tar.gzYou can decompress the apache-flume-1.7.0-bin Renamed as flume
mv apache-flume-1.7.0-bin flumetake flume/conf Under the flume-env.sh.template Change the file to flume-env.sh, And configuration flumeenv.sh file
mv flume-env.sh.template flume-env.sh vi flume-env.sh stay flume-env.sh Add... To the file export JAVA_HOME= you linux In the virtual machine jdk The path of
have access to echo $JAVA_HOME see jdk The path of
such flume The installation and deployment of is completed !
边栏推荐
- Upgrade log4j2 to 2.17.1 stepped pit
- utils session&rpc
- Microsoft. Bcl. Async usage summary -- in Net framework 4.5 project Net framework version 4.5 and above can use async/await asynchronous feature in C 5
- (zero) most complete JVM knowledge points
- UltraEdit delete empty line method
- qmlplugindump executable not found.It is required to generate the qmltypes file for VTK Qml
- AutoUpdater. Net client custom update file
- utlis 内存池 对象池
- Self service terminal handwritten Chinese character recognition input method library tjfink introduction
- Techtarget: Interpretation of the basic concept of super fusion cloud
猜你喜欢

P. Summary of NP, NPC, NP hard and other issues

Read the difference and connection between hyperfusion and private cloud
![[new book recommendation] cleaning data for effective data science](/img/42/1258694fc55a178a666391669a67ad.png)
[new book recommendation] cleaning data for effective data science

JVM tuning tool introduction and constant pool explanation

Properties of string

仿照微信Oauth2.0接入方案

Principle and implementation of small program hand-held bullet screen (uni APP)

Distributed ID

Cloud native database

Abstract classes and interfaces
随机推荐
NTP of Prometheus monitoring_ exporter
Cftpconnection:: getfile() download FTP server files and related parameter descriptions
[new book recommendation] mongodb performance tuning
Golang magic code
GPT (improving language understanding generative pre training) paper notes
Forrester senior analyst: five important trends in the development of the hyper convergence market
oracle跨数据库复制数据表-dblink
Function simplification principle: save if you can
P. Summary of NP, NPC, NP hard and other issues
Redis docker master-slave mode and sentinel
3.集成eslint、prettier
Techtarget: Interpretation of the basic concept of super fusion cloud
Deberta (decoding enhanced Bert with distinguished attention)
Datatabletomodellist entity class
MySQL index optimization miscellaneous
近期学习遇到的比较问题
Principle and implementation of small program hand-held bullet screen (uni APP)
Self service terminal handwritten Chinese character recognition input method library tjfink introduction
Eight sorts (I)
单片机 MCU 固件打包脚本软件