Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-10860 This closes #6704. Deprecated ExecuteFlumeSink and ExecuteFlumeSource 

Signed-off-by: Joe Witt <joewitt@apache.org>
This commit is contained in:
exceptionfactory 2022-11-22 14:16:49 -06:00 committed by Joe Witt
parent ff14ea2aab
commit 5aa7ba9bf9
No known key found for this signature in database
GPG Key ID: 9093BF854F811A1A
2 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java
View File

@ -28,6 +28,7 @@ import org.apache.nifi.annotation.behavior.Restricted;
import org.apache.nifi.annotation.behavior.Restriction; import org.apache.nifi.annotation.behavior.Restriction;
import org.apache.nifi.annotation.behavior.TriggerSerially; import org.apache.nifi.annotation.behavior.TriggerSerially;
import org.apache.nifi.annotation.documentation.CapabilityDescription; import org.apache.nifi.annotation.documentation.CapabilityDescription;
import org.apache.nifi.annotation.documentation.DeprecationNotice;
import org.apache.nifi.annotation.documentation.Tags; import org.apache.nifi.annotation.documentation.Tags;
import org.apache.nifi.annotation.lifecycle.OnScheduled; import org.apache.nifi.annotation.lifecycle.OnScheduled;
import org.apache.nifi.annotation.lifecycle.OnStopped; import org.apache.nifi.annotation.lifecycle.OnStopped;
@ -58,6 +59,7 @@ import java.util.Set;
explanation = "Provides operator the ability to execute arbitrary Flume configurations assuming all permissions that NiFi has.") explanation = "Provides operator the ability to execute arbitrary Flume configurations assuming all permissions that NiFi has.")
} }
) )
@DeprecationNotice(reason = "Apache Flume pipelines should be implemented using Apache NiFi components")
public class ExecuteFlumeSink extends AbstractFlumeProcessor { public class ExecuteFlumeSink extends AbstractFlumeProcessor {
public static final PropertyDescriptor SINK_TYPE = new PropertyDescriptor.Builder() public static final PropertyDescriptor SINK_TYPE = new PropertyDescriptor.Builder()

2
nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java
View File

@ -32,6 +32,7 @@ import org.apache.nifi.annotation.behavior.Restricted;
import org.apache.nifi.annotation.behavior.Restriction; import org.apache.nifi.annotation.behavior.Restriction;
import org.apache.nifi.annotation.behavior.TriggerSerially; import org.apache.nifi.annotation.behavior.TriggerSerially;
import org.apache.nifi.annotation.documentation.CapabilityDescription; import org.apache.nifi.annotation.documentation.CapabilityDescription;
import org.apache.nifi.annotation.documentation.DeprecationNotice;
import org.apache.nifi.annotation.documentation.Tags; import org.apache.nifi.annotation.documentation.Tags;
import org.apache.nifi.annotation.lifecycle.OnScheduled; import org.apache.nifi.annotation.lifecycle.OnScheduled;
import org.apache.nifi.annotation.lifecycle.OnStopped; import org.apache.nifi.annotation.lifecycle.OnStopped;
@ -64,6 +65,7 @@ import java.util.concurrent.atomic.AtomicReference;
explanation = "Provides operator the ability to execute arbitrary Flume configurations assuming all permissions that NiFi has.") explanation = "Provides operator the ability to execute arbitrary Flume configurations assuming all permissions that NiFi has.")
} }
) )
@DeprecationNotice(reason = "Apache Flume pipelines should be implemented using Apache NiFi components")
public class ExecuteFlumeSource extends AbstractFlumeProcessor { public class ExecuteFlumeSource extends AbstractFlumeProcessor {
public static final PropertyDescriptor SOURCE_TYPE = new PropertyDescriptor.Builder() public static final PropertyDescriptor SOURCE_TYPE = new PropertyDescriptor.Builder()