flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From esam...@apache.org
Subject svn commit: r1156907 - in /incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node: NodeConfiguration.java nodemanager/NodeConfigurationAware.java
Date Fri, 12 Aug 2011 00:48:22 GMT
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);
+
+}



Mime
View raw message