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:22 UTC

svn commit: r1156907 - in /incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node: NodeConfiguration.java nodemanager/NodeConfigurationAware.java

Author: esammer
Date: Fri Aug 12 00:48:22 2011
New Revision: 1156907

URL: http://svn.apache.org/viewvc?rev=1156907&view=rev
Log:
- Added a NodeConfiguration interface (assumption that impl will be thrift, avro, or pojo). - Added NodeConfigurationAware interface for classes that want to catch config updates.

Added:
    incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/NodeConfiguration.java
    incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/nodemanager/NodeConfigurationAware.java

Added: incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/NodeConfiguration.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/NodeConfiguration.java?rev=1156907&view=auto
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/NodeConfiguration.java (added)
+++ incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/NodeConfiguration.java Fri Aug 12 00:48:22 2011
@@ -0,0 +1,13 @@
+package org.apache.flume.node;
+
+public interface NodeConfiguration {
+
+  public long getVersion();
+
+  public String getName();
+
+  public String getSourceDefinition();
+
+  public String getSinkDefinition();
+
+}

Added: incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/nodemanager/NodeConfigurationAware.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/nodemanager/NodeConfigurationAware.java?rev=1156907&view=auto
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/nodemanager/NodeConfigurationAware.java (added)
+++ incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/nodemanager/NodeConfigurationAware.java Fri Aug 12 00:48:22 2011
@@ -0,0 +1,9 @@
+package org.apache.flume.node.nodemanager;
+
+import org.apache.flume.node.NodeConfiguration;
+
+public interface NodeConfigurationAware {
+
+  public void onNodeConfigurationChanged(NodeConfiguration nodeConfiguration);
+
+}