Flume Agent内部原理-Flink进阶认识

转:

Flume Agent内部原理-Flink进阶认识

Flume Agent内部原理

Flume Agent内部原理-Flink进阶认识

重要组件:

1 ChannelSelector

ChannelSelector的作用就是选出Event将要被发往哪个Channel。其共有两种类型,分别是Replicating(复制)和Multiplexing(多路复用)。
ReplicatingSelector会将同一个Event发往所有的Channel,Multiplexing会根据相应的原则,将不同的Event发往不同的Channel。

2 SinkProcessor

SinkProcessor共有三种类型,分别是DefaultSinkProcessor、LoadBalancingSinkProcessor和FailoverSinkProcessor
DefaultSinkProcessor对应的是单个的Sink,LoadBalancingSinkProcessor和FailoverSinkProcessor对应的是Sink Group,LoadBalancingSinkProcessor可以实现负载均衡的功能,FailoverSinkProcessor可以实现故障转移的功能。

转:

Flume Agent内部原理-Flink进阶认识

Flume Agent内部原理-Flink进阶认识

上一篇:小程序api-01-abcdefg


下一篇:js contains() 判断某个节点是否包含某个节点