FLUME-1422. Fix "BarSource" Class Signature in Flume Developer Guide.
(Patrick Wendell via Jarek Jarcec Cecho) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/62ee05b7 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/62ee05b7 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/62ee05b7 Branch: refs/heads/cdh-1.2.0+24_intuit Commit: 62ee05b717d26560427dcef30e50544d67e4477d Parents: d8d1e58 Author: Jarek Jarcec Cecho <[email protected]> Authored: Fri Aug 3 16:00:40 2012 -0700 Committer: Hari Shreedharan <[email protected]> Committed: Fri Sep 7 13:09:30 2012 -0700 ---------------------------------------------------------------------- flume-ng-doc/sphinx/FlumeDeveloperGuide.rst | 4 ++-- 1 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/62ee05b7/flume-ng-doc/sphinx/FlumeDeveloperGuide.rst ---------------------------------------------------------------------- diff --git a/flume-ng-doc/sphinx/FlumeDeveloperGuide.rst b/flume-ng-doc/sphinx/FlumeDeveloperGuide.rst index 37cb764..e5b19a7 100644 --- a/flume-ng-doc/sphinx/FlumeDeveloperGuide.rst +++ b/flume-ng-doc/sphinx/FlumeDeveloperGuide.rst @@ -329,13 +329,13 @@ manages the sourceâs lifecycle. The source needs to implement ``start()`` and two types of sources, pollable and event-driven. The runner of pollable source runner invokes a ``process()`` method from the pollable source. The ``process()`` method should check for new data and store it in the channel. The -event driver source needs have its own callback mechanism that captures the new +event driven source needs have its own callback mechanism that captures the new data: .. code-block:: java // bar source - public class BarSource extends AbstractSource implements Configurable, EventDrivenSource{ + public class BarSource extends AbstractSource implements Configurable, PollableSource { @Override public void configure(Context context) { some_Param = context.get("some_param", String.class);
