在记录写入hdfs之前,是否可以指定flume的采样率?是否有一些FlumeFlume配置这样做,或我们需要写我们自己的Flume截取采样?我在apacheflume用户指南页面上找不到任何文档。
t30tvxxf1#
是的,您可以通过在hdfs sink中指定批大小来实现:
hdfs.batchSize = 100 // 100 is the default.
您还应该确保指定的通道容量也足够大。
1条答案
按热度按时间t30tvxxf1#
是的,您可以通过在hdfs sink中指定批大小来实现:
您还应该确保指定的通道容量也足够大。