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);
+
+}