-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/8596/
-----------------------------------------------------------
(Updated Dec. 16, 2012, 1:33 p.m.)
Review request for Flume.
Changes
-------
Tests are passing. The one major thing I still need to do is I need to port the
avro-client CLI tool to the new interface. Right now the avro-client is
crippled.
Description
-------
Defines EventDeserializer interface and uses it from the spooling source.
Progress is persisted as bytes are read from the underlying file.
This addresses bug FLUME-1632.
https://issues.apache.org/jira/browse/FLUME-1632
Diffs (updated)
-----
flume-ng-clients/flume-ng-forwarder/pom.xml PRE-CREATION
flume-ng-clients/flume-ng-forwarder/src/main/java/org/apache/flume/clients/forwarder/FileClient.java
PRE-CREATION
flume-ng-clients/flume-ng-forwarder/src/main/java/org/apache/flume/clients/forwarder/FlumeTool.java
PRE-CREATION
flume-ng-clients/flume-ng-forwarder/src/main/java/org/apache/flume/clients/forwarder/ToolRegistry.java
PRE-CREATION
flume-ng-clients/flume-ng-forwarder/src/main/java/org/apache/flume/clients/forwarder/ToolRunner.java
PRE-CREATION
flume-ng-clients/flume-ng-forwarder/src/test/java/org/apache/flume/clients/forwarder/Blah2.java
PRE-CREATION
flume-ng-clients/flume-ng-forwarder/src/test/resources/flume-log4jtest.properties
PRE-CREATION
flume-ng-clients/pom.xml 7ea2d1d
flume-ng-core/pom.xml 0224519
flume-ng-core/src/main/avro/TransferStateFileMeta.avsc PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/client/avro/AvroCLIClient.java
37e9ffa
flume-ng-core/src/main/java/org/apache/flume/client/avro/SpoolingFileEventParser.java
PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/client/avro/SpoolingFileLineReader.java
8362299
flume-ng-core/src/main/java/org/apache/flume/serialization/DurablePositionTracker.java
PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/serialization/EventDeserializer.java
PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/serialization/EventDeserializerFactory.java
PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/serialization/EventDeserializerType.java
PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/serialization/EventSerDe.java
PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/serialization/EventSerializer.java
a418935
flume-ng-core/src/main/java/org/apache/flume/serialization/EventSerializerFactory.java
75853a9
flume-ng-core/src/main/java/org/apache/flume/serialization/LineDeserializer.java
PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/serialization/PositionTracker.java
PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/serialization/Resettable.java
PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/serialization/ResettableFileInputStream.java
PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/serialization/ResettableInputStream.java
PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/serialization/Seekable.java
PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/serialization/TransientPositionTracker.java
PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySource.java
61824d8
flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySourceConfigurationConstants.java
806a661
flume-ng-core/src/main/java/org/apache/flume/tools/PlatformDetect.java
PRE-CREATION
flume-ng-core/src/test/java/org/apache/flume/client/avro/TestSpoolingFileLineReader.java
740bc98
flume-ng-core/src/test/java/org/apache/flume/serialization/ResettableTestStringInputStream.java
PRE-CREATION
flume-ng-core/src/test/java/org/apache/flume/serialization/TestDurablePositionTracker.java
PRE-CREATION
flume-ng-core/src/test/java/org/apache/flume/serialization/TestLineDeserializer.java
PRE-CREATION
flume-ng-core/src/test/java/org/apache/flume/serialization/TestResettableFileInputStream.java
PRE-CREATION
flume-ng-core/src/test/java/org/apache/flume/serialization/TestSpoolingFileEventParser.java
PRE-CREATION
flume-ng-core/src/test/java/org/apache/flume/source/TestSpoolDirectorySource.java
6e87b21
flume-ng-core/src/test/resources/TestResettableFileInputStream_1.avro
PRE-CREATION
flume-ng-core/src/test/resources/TestResettableFileInputStream_1.truncated.avro
PRE-CREATION
pom.xml b934c1d
Diff: https://reviews.apache.org/r/8596/diff/
Testing (updated)
-------
Unit tests pass.
Thanks,
Mike Percy
