Batch append to Flume via Avro API.

FlumeAppendBatch

appendBatch(SomeDir, Events) ->
   ProtoFile = filename:join(SomeDir, "flume.avpr"),
   {ok, P} = eavro_rpc_fsm:start_link(Host, Port, ProtoFile),
   AvroEvents = encode_events_to_eavro_api_events(Events),
   {ok, Result} = eavro_rpc_fsm:call(Conn, appendBatch, _Args = [ AvroEvents ]).


encode_events_to_eavro_api_events(Events) ->
    [ 
      [ [ {<<"timestamp">>, 
	   list_to_binary(
	     integer_to_list(
	       estd_datetime:timestamp(msec, Ts))) }],
	Body ] || #flume_event{ timestamp = Ts, body = Body} <- Events ].