Updated Branches: refs/heads/trunk eaee4225a -> be6c13bdd
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/be6c13bd Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/be6c13bd Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/be6c13bd Branch: refs/heads/trunk Commit: be6c13bdd3384d04001b234b2bb5d1e1e28aec52 Parents: eaee422 Author: Jarek Jarcec Cecho <[email protected]> Authored: Fri Aug 3 16:00:40 2012 -0700 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Fri Aug 3 16:00:40 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/be6c13bd/flume-ng-doc/sphinx/FlumeDeveloperGuide.rst ---------------------------------------------------------------------- diff --git a/flume-ng-doc/sphinx/FlumeDeveloperGuide.rst b/flume-ng-doc/sphinx/FlumeDeveloperGuide.rst index 8cd67c3..5fd1def 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);
