A custom build adaptor which always send 2 lines in a chunk like this: Timestamp: 1234567890\n Metrics: State: 1 Value: 3
In this case, use nextLine() will get you "Metrcis: State: 1 Value: 3" Someone may have written a custom adaptor to transport fixed message in a chunk. However, this is not exposed as the primary use case in chukwa. Regards, Eric On 2/5/10 3:35 PM, "James Seigel" <ja...@tynt.com> wrote: > Is there any scenario where nextLine() returns a line? > > Cheers > James > > Sent from my mobile. Please excuse the typos. > > On 2010-02-05, at 2:48 PM, "Corbin Hoenes" <cor...@tynt.com> wrote: > >> Thanks Eric... things are looking much more sane now after >> understanding what a recordEntry is. :) >> >> On Feb 5, 2010, at 12:57 PM, Eric Yang wrote: >> >>> Log output by ChukwaLog4J appender has a special property that it >>> will group >>> the same log output statement delimited by ^A character. Hence, >>> the UTF8 >>> adaptor will not break up the structures and send the entire output >>> as one >>> record. When the custom processor get an recordEntry (part of a >>> chunk), it >>> will contain the full output. nextLine function is to get the next >>> record >>> shipped in the same chunk. It should not be rely upon, unless the >>> specially >>> crafted adaptor is shipping multi-records as a chunk and this chunk >>> has no >>> dependency outside. The current UTF8 adaptor is sending multiple >>> records >>> depending on the speed of the tail is happening. UTF8 adaptor >>> should not be >>> rely upon if you want to use nextLine feature to build your parser >>> states. >>> >>> Regards, >>> Eric >>> >>> On 2/5/10 10:48 AM, "Corbin Hoenes" <cor...@tynt.com> wrote: >>> >>>> So I'm implementing a custom processor and my processor get's a >>>> recordEntry >>>> passed to it's parse method. It has more than a single log line >>>> it. Is this >>>> the responsibility of my processor to split it up into lines? The >>>> nextLine() >>>> method in AbstractProcessor made me think that I'd always be >>>> passed a single >>>> line. >>>> >>> >>
