![]() ![]() Parts of the code in flume_types. I am thankful for all the help I can get! Flume is a Flexible, reliable, and scalable platform to transmit data to a centralized store like HDFS. New and existing users are encouraged to use the 1.x releases so as to leverage the performance improvements and configuration flexibilities available in the latest architecture. ![]() This documentation applies to the 1.4.x track. A Flume source consumes events delivered to it by an external source like a web server. Flumes use gravity and the terrain to dictate the direction in which water flows. A Flume agent is a (JVM) process that hosts the components through which events ow from an external source to the next destination (hop). A flume is a water channel built as a means of transport but defers from a trench because its walls are elevated above the surrounding ground. The thrift is used to communicate with the remote flume thrift source. In the choice of protocol, AVRO C + +, although there are Apache open source projects, but currently only support read and write files, but not the use of RPC. The code in flume_types.h and flume_types.c is autogenerated from thrift. Documentation for the 0.9.x track is available at the Flume 0.9.x User Guide. A Flume event is dened as a unit of data ow having a byte payload and an optional set of string attributes. Rage, rewrite the code, use C + + with the remote Java flume docking. ![]() I get the following error at the line in main.c: `GLib-GObject-WARNING **: IA_g_object_new_valist: object class `ThriftFlumeEventType' has no property named `timestamp'` I am trying to create a flume-thrift client in c (c_glib) but have trouble creating the gobject that shall be sent to the server. ![]()
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |