This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new b64870243a NIFI-14842 Deprecated CompressContent, ConvertAvroToParquet
and GetAzureEventHub (#10192)
b64870243a is described below
commit b64870243ac80863071c113593b45e8059d44fe8
Author: dan-s1 <[email protected]>
AuthorDate: Mon Aug 11 17:15:39 2025 -0400
NIFI-14842 Deprecated CompressContent, ConvertAvroToParquet and
GetAzureEventHub (#10192)
Signed-off-by: David Handermann <[email protected]>
---
.../org/apache/nifi/processors/azure/eventhub/GetAzureEventHub.java | 2 ++
.../java/org/apache/nifi/processors/parquet/ConvertAvroToParquet.java | 4 ++++
.../java/org/apache/nifi/processors/standard/CompressContent.java | 2 ++
3 files changed, 8 insertions(+)
diff --git
a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/GetAzureEventHub.java
b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/GetAzureEventHub.java
index 929f61182f..95857f01cc 100644
---
a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/GetAzureEventHub.java
+++
b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/GetAzureEventHub.java
@@ -32,6 +32,7 @@ import
org.apache.nifi.annotation.behavior.InputRequirement.Requirement;
import org.apache.nifi.annotation.behavior.WritesAttribute;
import org.apache.nifi.annotation.behavior.WritesAttributes;
import org.apache.nifi.annotation.documentation.CapabilityDescription;
+import org.apache.nifi.annotation.documentation.DeprecationNotice;
import org.apache.nifi.annotation.documentation.SeeAlso;
import org.apache.nifi.annotation.documentation.Tags;
import org.apache.nifi.annotation.lifecycle.OnScheduled;
@@ -87,6 +88,7 @@ import java.util.concurrent.atomic.AtomicReference;
@WritesAttribute(attribute = "eventhub.property.*", description = "The
application properties of this message. IE: 'application' would be
'eventhub.property.application'")
})
@SeeAlso(ConsumeAzureEventHub.class)
+@DeprecationNotice(classNames =
"org.apache.nifi.processors.azure.eventhub.ConsumeAzureEventHub")
public class GetAzureEventHub extends AbstractProcessor implements
AzureEventHubComponent {
private static final String TRANSIT_URI_FORMAT_STRING =
"amqps://%s/%s/ConsumerGroups/%s/Partitions/%s";
private static final Duration DEFAULT_FETCH_TIMEOUT =
Duration.ofSeconds(60);
diff --git
a/nifi-extension-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/processors/parquet/ConvertAvroToParquet.java
b/nifi-extension-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/processors/parquet/ConvertAvroToParquet.java
index ef5cdf03e1..d007796173 100644
---
a/nifi-extension-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/processors/parquet/ConvertAvroToParquet.java
+++
b/nifi-extension-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/processors/parquet/ConvertAvroToParquet.java
@@ -28,6 +28,7 @@ import org.apache.nifi.annotation.behavior.InputRequirement;
import org.apache.nifi.annotation.behavior.WritesAttribute;
import org.apache.nifi.annotation.behavior.WritesAttributes;
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.components.PropertyDescriptor;
import org.apache.nifi.flowfile.FlowFile;
@@ -65,6 +66,9 @@ import static
org.apache.nifi.parquet.utils.ParquetUtils.createParquetConfig;
@WritesAttribute(attribute = "filename", description = "Sets the
filename to the existing filename with the extension replaced by / added to by
.parquet"),
@WritesAttribute(attribute = "record.count", description = "Sets the
number of records in the parquet file.")
})
+@DeprecationNotice(reason = "ConvertAvroToParquet is no longer needed since
there is the AvroReader which along with ParquetRecordSetWriter can be used in
ConvertRecord to achieve the same thing.",
+ classNames = {"org.apache.nifi.processors.standard.ConvertRecord",
+ "org.apache.nifi.avro.AvroReader",
"org.apache.nifi.parquet.ParquetRecordSetWriter"})
public class ConvertAvroToParquet extends AbstractProcessor {
// Attributes
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CompressContent.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CompressContent.java
index bedbe81638..c24b3075bf 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CompressContent.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CompressContent.java
@@ -38,6 +38,7 @@ import org.apache.nifi.annotation.behavior.SystemResource;
import org.apache.nifi.annotation.behavior.SystemResourceConsideration;
import org.apache.nifi.annotation.behavior.WritesAttribute;
import org.apache.nifi.annotation.documentation.CapabilityDescription;
+import org.apache.nifi.annotation.documentation.DeprecationNotice;
import org.apache.nifi.annotation.documentation.MultiProcessorUseCase;
import org.apache.nifi.annotation.documentation.ProcessorConfiguration;
import org.apache.nifi.annotation.documentation.Tags;
@@ -130,6 +131,7 @@ import java.util.zip.InflaterInputStream;
)
}
)
+@DeprecationNotice(classNames =
{"org.apache.nifi.processors.compress.ModifyCompression"})
public class CompressContent extends AbstractProcessor {
public static final String COMPRESSION_FORMAT_ATTRIBUTE = "use mime.type
attribute";
