flume部署安装以及案例运行(29)

a1.sinks.k1.serializer = DELIMITED

a1.sinks.k1.serializer.delimiter = \"\\t\"

a1.sinks.k1.serializer.fieldnames = user_iduser_nameuser_age

a1.sinks.k1.serializer.serdeSeparator = '\\t'

# Use a channel which buffers events in memory

a1.channels.c1.type = memory

a1.channels.c1.capacity = 1000

a1.channels.c1.transactionCapacity = 100

# Bind the source and sink to the channel

a1.sources.r1.channels = c1

a1.sinks.k1.channel = c1

配置概念补充

1.serializer: 负责解析事件中的字段并将它们映射到hive表中的列

推荐阅读