You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by es...@apache.org on 2011/08/12 02:48:14 UTC

svn commit: r1156904 - in /incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume: SinkFactory.java SourceFactory.java

Author: esammer
Date: Fri Aug 12 00:48:13 2011
New Revision: 1156904

URL: http://svn.apache.org/viewvc?rev=1156904&view=rev
Log:
- Added {Source,Sink}Factory interfaces.

Added:
    incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/SinkFactory.java
    incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/SourceFactory.java

Added: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/SinkFactory.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/SinkFactory.java?rev=1156904&view=auto
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/SinkFactory.java (added)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/SinkFactory.java Fri Aug 12 00:48:13 2011
@@ -0,0 +1,15 @@
+package org.apache.flume;
+
+import java.util.Set;
+
+public interface SinkFactory {
+
+  public boolean register(String name, Class<? extends EventSink> sinkClass);
+
+  public boolean unregister(String name);
+
+  public EventSink create(String name) throws InstantiationException;
+
+  public Set<String> getSinkNames();
+
+}

Added: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/SourceFactory.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/SourceFactory.java?rev=1156904&view=auto
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/SourceFactory.java (added)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/SourceFactory.java Fri Aug 12 00:48:13 2011
@@ -0,0 +1,16 @@
+package org.apache.flume;
+
+import java.util.Set;
+
+public interface SourceFactory {
+
+  public boolean register(String sourceName,
+      Class<? extends EventSource> sourceClass);
+
+  public boolean unregister(String sourceName);
+
+  public EventSource create(String sourceName) throws InstantiationException;
+
+  public Set<String> getSourceNames();
+
+}