You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by al...@apache.org on 2016/05/19 20:08:11 UTC
[1/2] nifi git commit: NIFI-1898 Fixed Flume processor @OnScheduled
methods to accept ProcessContext
Repository: nifi
Updated Branches:
refs/heads/0.x ee8b2aaaa -> 663a03541
refs/heads/master 1bd2cf0d0 -> d6674fbb8
NIFI-1898 Fixed Flume processor @OnScheduled methods to accept ProcessContext
This closes #455.
Signed-off-by: Aldrin Piri <al...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/663a0354
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/663a0354
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/663a0354
Branch: refs/heads/0.x
Commit: 663a03541e8d974e23ecbfb465a3aa511678b4ea
Parents: ee8b2aa
Author: Oleg Zhurakousky <ol...@suitcase.io>
Authored: Thu May 19 10:10:21 2016 -0400
Committer: Aldrin Piri <al...@apache.org>
Committed: Thu May 19 16:07:41 2016 -0400
----------------------------------------------------------------------
.../java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java | 3 +--
.../java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java | 3 +--
2 files changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/663a0354/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java
index f93b215..e40608d 100644
--- a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java
+++ b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java
@@ -35,7 +35,6 @@ import org.apache.nifi.processor.ProcessContext;
import org.apache.nifi.processor.ProcessSession;
import org.apache.nifi.processor.ProcessorInitializationContext;
import org.apache.nifi.processor.Relationship;
-import org.apache.nifi.processor.SchedulingContext;
import org.apache.nifi.processor.exception.ProcessException;
import org.apache.nifi.processor.util.StandardValidators;
@@ -107,7 +106,7 @@ public class ExecuteFlumeSink extends AbstractFlumeProcessor {
}
@OnScheduled
- public void onScheduled(final SchedulingContext context) {
+ public void onScheduled(final ProcessContext context) {
try {
channel = new NifiSinkSessionChannel(SUCCESS, FAILURE);
channel.start();
http://git-wip-us.apache.org/repos/asf/nifi/blob/663a0354/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java
index 3aad6b7..3ef72ff 100644
--- a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java
+++ b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java
@@ -41,7 +41,6 @@ import org.apache.nifi.processor.ProcessSession;
import org.apache.nifi.processor.ProcessSessionFactory;
import org.apache.nifi.processor.ProcessorInitializationContext;
import org.apache.nifi.processor.Relationship;
-import org.apache.nifi.processor.SchedulingContext;
import org.apache.nifi.processor.exception.ProcessException;
import org.apache.nifi.processor.util.StandardValidators;
@@ -117,7 +116,7 @@ public class ExecuteFlumeSource extends AbstractFlumeProcessor {
}
@OnScheduled
- public void onScheduled(final SchedulingContext context) {
+ public void onScheduled(final ProcessContext context) {
try {
source = SOURCE_FACTORY.create(
context.getProperty(SOURCE_NAME).getValue(),
[2/2] nifi git commit: NIFI-1898 Fixed Flume processor @OnScheduled
methods to accept ProcessContext
Posted by al...@apache.org.
NIFI-1898 Fixed Flume processor @OnScheduled methods to accept ProcessContext
This closes #455.
Signed-off-by: Aldrin Piri <al...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/d6674fbb
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/d6674fbb
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/d6674fbb
Branch: refs/heads/master
Commit: d6674fbb8e20ce6daeeac8cd7b07271963744bde
Parents: 1bd2cf0
Author: Oleg Zhurakousky <ol...@suitcase.io>
Authored: Thu May 19 10:10:21 2016 -0400
Committer: Aldrin Piri <al...@apache.org>
Committed: Thu May 19 16:07:57 2016 -0400
----------------------------------------------------------------------
.../java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java | 3 +--
.../java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java | 3 +--
2 files changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/d6674fbb/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java
index f93b215..e40608d 100644
--- a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java
+++ b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java
@@ -35,7 +35,6 @@ import org.apache.nifi.processor.ProcessContext;
import org.apache.nifi.processor.ProcessSession;
import org.apache.nifi.processor.ProcessorInitializationContext;
import org.apache.nifi.processor.Relationship;
-import org.apache.nifi.processor.SchedulingContext;
import org.apache.nifi.processor.exception.ProcessException;
import org.apache.nifi.processor.util.StandardValidators;
@@ -107,7 +106,7 @@ public class ExecuteFlumeSink extends AbstractFlumeProcessor {
}
@OnScheduled
- public void onScheduled(final SchedulingContext context) {
+ public void onScheduled(final ProcessContext context) {
try {
channel = new NifiSinkSessionChannel(SUCCESS, FAILURE);
channel.start();
http://git-wip-us.apache.org/repos/asf/nifi/blob/d6674fbb/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java
index 3aad6b7..3ef72ff 100644
--- a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java
+++ b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java
@@ -41,7 +41,6 @@ import org.apache.nifi.processor.ProcessSession;
import org.apache.nifi.processor.ProcessSessionFactory;
import org.apache.nifi.processor.ProcessorInitializationContext;
import org.apache.nifi.processor.Relationship;
-import org.apache.nifi.processor.SchedulingContext;
import org.apache.nifi.processor.exception.ProcessException;
import org.apache.nifi.processor.util.StandardValidators;
@@ -117,7 +116,7 @@ public class ExecuteFlumeSource extends AbstractFlumeProcessor {
}
@OnScheduled
- public void onScheduled(final SchedulingContext context) {
+ public void onScheduled(final ProcessContext context) {
try {
source = SOURCE_FACTORY.create(
context.getProperty(SOURCE_NAME).getValue(),