Data flow using Flume