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

a1.sinks.k1.hive.database = flume_test

a1.sinks.k1.hive.table = emp

a1.sinks.k1.serializer = DELIMITED

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

a1.sinks.k1.serializer.fieldnames = empnoenamejobmgrhiredatesalcommdeptno

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

推荐阅读