You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by pv...@apache.org on 2025/08/07 10:52:22 UTC
(nifi) branch main updated: NIFI-14821 Implemented PMD rule MissingOverride.
This is an automated email from the ASF dual-hosted git repository.
pvillard 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 8bb5726c89 NIFI-14821 Implemented PMD rule MissingOverride.
8bb5726c89 is described below
commit 8bb5726c89beb12431459a2ef0239f42421bdd07
Author: dan-s1 <ds...@gmail.com>
AuthorDate: Wed Aug 6 18:04:47 2025 +0000
NIFI-14821 Implemented PMD rule MissingOverride.
Signed-off-by: Pierre Villard <pi...@gmail.com>
This closes #10173.
---
.../differentiators/WholeConfigDifferentiator.java | 1 +
.../service/PeriodicStatusReporterManager.java | 1 +
.../minifi/bootstrap/util/ByteBufferInputStream.java | 2 ++
.../nifi/minifi/c2/FileBasedOperationQueueDAO.java | 3 +++
.../nifi/minifi/bootstrap/BootstrapListener.java | 1 +
.../org/apache/nifi/minifi/StandardMiNiFiServer.java | 1 +
.../nifi/minifi/toolkit/schema/ConfigSchema.java | 1 +
.../minifi/toolkit/schema/ProcessGroupSchema.java | 1 +
.../nifi/minifi/toolkit/schema/ReportingSchema.java | 1 +
.../schema/common/BaseSchemaWithIdAndName.java | 1 +
.../toolkit/schema/v2/ProcessGroupSchemaV2.java | 1 +
.../src/main/java/org/apache/nifi/sql/NiFiTable.java | 2 ++
.../provenance/StandardProvenanceEventRecord.java | 1 +
.../nifi/hl7/query/evaluator/BooleanEvaluator.java | 1 +
.../nifi/hl7/query/evaluator/IntegerEvaluator.java | 1 +
.../nifi/hl7/query/evaluator/StringEvaluator.java | 1 +
.../hl7/query/evaluator/message/FieldEvaluator.java | 2 ++
.../query/evaluator/message/MessageEvaluator.java | 2 ++
.../query/evaluator/message/SegmentEvaluator.java | 2 ++
.../java/org/apache/nifi/util/NiFiProperties.java | 1 +
.../krb/UsernamePasswordCallbackHandler.java | 1 +
.../security/ssl/StandardX509ExtendedKeyManager.java | 2 ++
.../apache/nifi/remote/util/StandardDataPacket.java | 3 +++
.../nifi/stream/io/MinimumLengthInputStream.java | 1 +
.../org/apache/nifi/wali/LengthDelimitedJournal.java | 1 +
.../nifi/controller/asana/StandardAsanaClient.java | 1 +
.../processors/aws/v2/AbstractAwsAsyncProcessor.java | 1 +
.../processors/aws/v2/AbstractAwsSyncProcessor.java | 2 ++
.../strategies/AbstractCredentialsStrategy.java | 2 ++
.../stream/pause/StandardRecordProcessorBlocker.java | 1 +
.../aws/ml/translate/StartAwsTranslateJob.java | 1 +
.../aws/cloudwatch/MockPutCloudWatchMetric.java | 1 +
.../azure/AbstractAzureBlobProcessor_v12.java | 2 ++
.../azure/storage/PutAzureBlobStorage_v12.java | 1 +
.../storage/utils/BlobServiceClientFactory.java | 1 +
.../storage/utils/ClientSideEncryptionMethod.java | 1 +
.../storage/utils/DataLakeServiceClientFactory.java | 1 +
.../org/apache/nifi/cdc/event/BaseEventInfo.java | 2 ++
.../org/apache/nifi/cdc/event/BaseRowEventInfo.java | 1 +
.../apache/nifi/cdc/event/BaseTableEventInfo.java | 5 +++++
.../nifi/cdc/mysql/event/BaseBinlogEventInfo.java | 3 +++
.../event/io/AbstractBinlogTableEventWriter.java | 1 +
.../mysql/event/io/BeginTransactionEventWriter.java | 1 +
.../mysql/event/io/CommitTransactionEventWriter.java | 1 +
.../cipher/io/ChannelStreamCallbackTest.java | 1 +
.../org/apache/nifi/processors/TestGeoEnrichIP.java | 1 +
.../nifi/processor/util/bin/EvictionReason.java | 1 +
.../processor/util/listen/event/StandardEvent.java | 1 +
.../event/transport/message/ByteArrayMessage.java | 2 ++
.../transport/netty/NettyEventSenderFactory.java | 1 +
.../nifi/processor/util/file/transfer/FileInfo.java | 2 ++
.../org/apache/nifi/json/JsonSchemaInference.java | 2 +-
.../inference/HierarchicalSchemaInference.java | 1 +
.../nifi/processors/gcp/bigquery/PutBigQuery.java | 2 ++
.../strategies/AbstractCredentialsStrategy.java | 1 +
.../service/GCPCredentialsControllerService.java | 1 +
.../nifi/processors/graph/ExecuteGraphQuery.java | 1 +
.../groovyx/flow/GroovyProcessSessionWrap.java | 1 +
.../nifi/processors/groovyx/flow/SessionFile.java | 1 +
.../org/apache/nifi/processors/groovyx/sql/OSql.java | 1 +
.../nifi/processors/hadoop/GetHDFSFileInfo.java | 1 +
.../nifi/processors/jolt/JoltTransformJSON.java | 1 +
.../ConsumeKafkaInjectMetadataRecordIT.java | 3 +++
.../processors/ConsumeKafkaWrapperRecordIT.java | 3 +++
.../producer/header/AttributesHeadersFactory.java | 1 +
.../service/api/producer/KafkaProducerService.java | 1 +
.../org/apache/nifi/processors/mqtt/PublishMQTT.java | 1 +
.../nifi/py4j/StandardPythonProcessorBridge.java | 1 +
.../org/apache/nifi/py4j/client/CommandBuilder.java | 1 +
.../apache/nifi/py4j/server/NiFiGatewayServer.java | 1 +
.../nifi/python/processor/StandardInputFlowFile.java | 5 +++++
.../record/script/AbstractScriptedRecordFactory.java | 1 +
.../apache/nifi/record/script/ScriptedReader.java | 2 ++
.../nifi/record/sink/script/ScriptedRecordSink.java | 2 ++
.../apache/nifi/script/impl/BaseScriptRunner.java | 1 +
.../apache/nifi/processors/shopify/GetShopify.java | 1 +
.../processors/slack/consume/SlackTimestamp.java | 1 +
.../java/org/apache/nifi/smb/common/SmbClient.java | 2 ++
.../apache/nifi/snmp/logging/SLF4JLogAdapter.java | 17 +++++++++++++++--
.../org/apache/nifi/snmp/processors/GetSNMP.java | 1 +
.../org/apache/nifi/snmp/processors/SetSNMP.java | 1 +
.../snmp/processors/properties/PrivacyProtocol.java | 3 +++
.../processors/properties/UsmUserInputMethod.java | 3 +++
.../service/SnowflakeComputingConnectionPool.java | 1 +
.../processors/splunk/QuerySplunkIndexingStatus.java | 2 ++
.../sql/datasources/JvmMetricsDataSource.java | 1 +
.../standard/AbstractDatabaseFetchProcessor.java | 1 +
.../processors/standard/CalculateRecordStats.java | 1 +
.../standard/enrichment/WrapperJoinStrategy.java | 1 +
.../standard/ftp/commands/FtpCommandHELP.java | 1 +
.../standard/ftp/filesystem/VirtualPath.java | 1 +
.../apache/nifi/dbcp/HadoopDBCPConnectionPool.java | 1 +
.../org/apache/nifi/avro/NonCachingDatumReader.java | 1 +
.../java/org/apache/nifi/json/JsonTreeReader.java | 1 +
.../apache/nifi/record/sink/TestHttpRecordSink.java | 1 +
.../LoginIdentityProviderConfigurationContext.java | 3 +++
.../provenance/index/lucene/LuceneEventIndex.java | 1 +
.../nifi/provenance/store/RecordWriterLease.java | 1 +
.../org/apache/nifi/questdb/DatabaseManager.java | 1 +
.../nifi/web/api/dto/ComponentReferenceDTO.java | 4 ++++
.../web/api/dto/SystemDiagnosticsSnapshotDTO.java | 1 +
.../nifi/web/api/entity/AccessPolicyEntity.java | 2 ++
.../api/entity/ComponentValidationResultEntity.java | 2 ++
.../apache/nifi/web/api/entity/ConnectionEntity.java | 2 ++
.../api/entity/ControllerConfigurationEntity.java | 10 ++++++----
.../nifi/web/api/entity/ControllerServiceEntity.java | 2 ++
.../api/entity/ControllerServiceRunStatusEntity.java | 4 ++--
.../api/entity/FlowAnalysisRuleRunStatusEntity.java | 4 ++--
.../web/api/entity/FlowRegistryClientEntity.java | 2 ++
.../org/apache/nifi/web/api/entity/FunnelEntity.java | 2 ++
.../org/apache/nifi/web/api/entity/LabelEntity.java | 2 ++
.../api/entity/ParameterContextReferenceEntity.java | 7 +++++--
.../entity/ParameterProviderConfigurationEntity.java | 7 +++++--
.../nifi/web/api/entity/PortRunStatusEntity.java | 4 ++--
.../api/entity/ProcessGroupReplaceRequestEntity.java | 1 +
.../apache/nifi/web/api/entity/ProcessorEntity.java | 2 ++
.../web/api/entity/ProcessorRunStatusEntity.java | 1 +
.../web/api/entity/RemotePortRunStatusEntity.java | 4 ++--
.../web/api/entity/RemoteProcessGroupEntity.java | 2 ++
.../web/api/entity/ReportingTaskRunStatusEntity.java | 4 ++--
.../org/apache/nifi/web/api/entity/UserEntity.java | 2 ++
.../apache/nifi/web/api/entity/UserGroupEntity.java | 2 ++
.../api/entity/VersionedFlowUpdateRequestEntity.java | 2 ++
.../repository/RepositoryRecordSerdeFactory.java | 1 +
.../StandardAuthorizerInitializationContext.java | 1 +
.../coordination/node/NodeClusterCoordinator.java | 3 ++-
.../cluster/manager/AccessPolicyEntityMerger.java | 1 +
.../nifi/cluster/manager/UserEntityMerger.java | 1 +
.../nifi/cluster/manager/UserGroupEntityMerger.java | 1 +
.../flowanalysis/AbstractFlowAnalysisRuleNode.java | 1 +
.../repository/metrics/StandardFlowFileEvent.java | 1 +
.../service/StandardControllerServiceNode.java | 1 +
.../service/StandardControllerServiceProvider.java | 1 +
.../nifi/groups/DefaultComponentScheduler.java | 2 ++
.../org/apache/nifi/groups/StandardDataValve.java | 1 +
.../org/apache/nifi/groups/StandardProcessGroup.java | 1 +
.../nifi/components/validation/ValidationState.java | 1 +
.../org/apache/nifi/connectable/Connectable.java | 1 +
.../nifi/controller/AbstractComponentNode.java | 2 ++
.../org/apache/nifi/controller/AbstractPort.java | 1 +
.../controller/service/ControllerServiceNode.java | 1 +
.../nifi/groups/AbstractComponentScheduler.java | 1 +
.../org/apache/nifi/groups/ComponentScheduler.java | 1 +
.../org/apache/nifi/groups/StatelessGroupNode.java | 1 +
.../org/apache/nifi/parameter/ParameterContext.java | 1 +
.../org/apache/nifi/controller/FlowController.java | 1 +
.../apache/nifi/controller/StandardFlowSnippet.java | 3 +++
.../nifi/controller/flow/StandardFlowManager.java | 20 +++++++++++++++++++-
.../nifi/controller/queue/StandardFlowFileQueue.java | 2 ++
.../client/async/nio/NioAsyncLoadBalanceClient.java | 10 +++++++++-
.../reporting/StandardReportingTaskNode.java | 2 ++
.../scheduling/StandardProcessScheduler.java | 5 +++--
.../bootstrap/shell/result/SingleLineResult.java | 1 +
.../framework/ssl/WatchServiceMonitorCommand.java | 1 +
.../apache/nifi/reporting/StandardEventAccess.java | 4 ++++
.../controller/service/mock/MockProcessGroup.java | 2 ++
.../status/history/StandardStatusSnapshot.java | 1 +
.../org/apache/nifi/headless/HeadlessNiFiServer.java | 2 ++
.../nar/AbstractNativeLibHandlingClassLoader.java | 1 +
.../repository/StandardRepositoryRecord.java | 1 +
.../claim/StandardResourceClaimManager.java | 1 +
.../handler/ContextPathRedirectPatternRule.java | 1 +
.../apache/nifi/web/StandardNiFiServiceFacade.java | 1 +
.../concurrent/StandardAsynchronousWebRequest.java | 2 ++
.../nifi/web/dao/impl/StandardInputPortDAO.java | 1 +
.../nifi/web/dao/impl/StandardOutputPortDAO.java | 1 +
.../nifi/web/search/ComponentMatcherFactory.java | 1 +
.../nifi/web/search/query/MapBasedSearchQuery.java | 1 +
.../web/AuthorizedClientExpirationCommand.java | 1 +
.../apache/nifi/provenance/MockProvenanceEvent.java | 1 +
.../java/org/apache/nifi/util/MockEventAccess.java | 4 ++++
.../nifi/util/TestStandardProcessorTestRunner.java | 3 +++
.../java/org/apache/nifi/registry/bucket/Bucket.java | 2 ++
.../StandardAuthorizerInitializationContext.java | 1 +
.../resource/InheritingAuthorizable.java | 2 ++
.../registry/GenerateExtensionManifestSchema.java | 1 +
.../registry/extension/BundleVersionCoordinate.java | 1 +
.../apache/nifi/extensions/NexusExtensionClient.java | 1 +
.../config/PropertiesFileFlowDefinitionParser.java | 2 ++
.../stateless/engine/StandardExecutionProgress.java | 1 +
.../engine/StatelessProcessContextFactory.java | 1 +
.../stateless/flow/TransactionThresholdMeter.java | 1 +
.../StatelessRepositoryContextFactory.java | 1 +
.../nifi/cs/tests/system/FakeControllerService1.java | 1 +
pmd-ruleset.xml | 1 +
185 files changed, 322 insertions(+), 26 deletions(-)
diff --git a/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/configuration/differentiators/WholeConfigDifferentiator.java b/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/configuration/differentiators/WholeConfigDifferentiator.java
index 04486948e3..b152ea6bdf 100644
--- a/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/configuration/differentiators/WholeConfigDifferentiator.java
+++ b/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/configuration/differentiators/WholeConfigDifferentiator.java
@@ -38,6 +38,7 @@ public abstract class WholeConfigDifferentiator {
}
public static class ByteBufferInputDifferentiator extends WholeConfigDifferentiator implements Differentiator<ByteBuffer> {
+ @Override
public boolean isNew(ByteBuffer newFlowConfig) {
AtomicReference<ByteBuffer> currentFlowConfigReference = configurationFileHolder.getConfigFileReference();
ByteBuffer currentFlowConfig = currentFlowConfigReference.get();
diff --git a/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/service/PeriodicStatusReporterManager.java b/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/service/PeriodicStatusReporterManager.java
index 5bf34ac87d..6f6e4e97a8 100644
--- a/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/service/PeriodicStatusReporterManager.java
+++ b/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/service/PeriodicStatusReporterManager.java
@@ -73,6 +73,7 @@ public class PeriodicStatusReporterManager implements QueryableStatusAggregator
}
}
+ @Override
public FlowStatusReport statusReport(String statusRequest) {
MiNiFiStatus status = miNiFiStatusProvider.getStatus(miNiFiParameters.getMiNiFiPort(), miNiFiParameters.getMinifiPid());
diff --git a/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/util/ByteBufferInputStream.java b/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/util/ByteBufferInputStream.java
index d20478ebe3..608d3f0562 100644
--- a/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/util/ByteBufferInputStream.java
+++ b/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/util/ByteBufferInputStream.java
@@ -28,6 +28,7 @@ public class ByteBufferInputStream extends InputStream {
this.buf = buf;
}
+ @Override
public int read() throws IOException {
if (!buf.hasRemaining()) {
return -1;
@@ -35,6 +36,7 @@ public class ByteBufferInputStream extends InputStream {
return buf.get() & 0xFF;
}
+ @Override
public int read(byte[] bytes, int off, int len)
throws IOException {
if (!buf.hasRemaining()) {
diff --git a/minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/main/java/org/apache/nifi/minifi/c2/FileBasedOperationQueueDAO.java b/minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/main/java/org/apache/nifi/minifi/c2/FileBasedOperationQueueDAO.java
index 72f4c55bbd..045b7dc5b3 100644
--- a/minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/main/java/org/apache/nifi/minifi/c2/FileBasedOperationQueueDAO.java
+++ b/minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/main/java/org/apache/nifi/minifi/c2/FileBasedOperationQueueDAO.java
@@ -40,6 +40,7 @@ public class FileBasedOperationQueueDAO implements OperationQueueDAO {
this.objectMapper = objectMapper;
}
+ @Override
public void save(OperationQueue operationQueue) {
LOGGER.info("Saving C2 operations to file");
LOGGER.debug("C2 Operation Queue: {}", operationQueue);
@@ -51,6 +52,7 @@ public class FileBasedOperationQueueDAO implements OperationQueueDAO {
}
}
+ @Override
public Optional<OperationQueue> load() {
LOGGER.info("Reading queued c2 operations from file");
if (requestedOperationsFile.exists()) {
@@ -67,6 +69,7 @@ public class FileBasedOperationQueueDAO implements OperationQueueDAO {
return Optional.empty();
}
+ @Override
public void cleanup() {
if (requestedOperationsFile.exists() && !requestedOperationsFile.delete()) {
LOGGER.error("Failed to delete requested operations file {}, it should be deleted manually", requestedOperationsFile);
diff --git a/minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-runtime/src/main/java/org/apache/nifi/minifi/bootstrap/BootstrapListener.java b/minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-runtime/src/main/java/org/apache/nifi/minifi/bootstrap/BootstrapListener.java
index 8ee9a15629..827e9d3d32 100644
--- a/minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-runtime/src/main/java/org/apache/nifi/minifi/bootstrap/BootstrapListener.java
+++ b/minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-runtime/src/main/java/org/apache/nifi/minifi/bootstrap/BootstrapListener.java
@@ -117,6 +117,7 @@ public class BootstrapListener implements BootstrapCommunicator {
sendCommand(STARTED, new String[] {String.valueOf(status)});
}
+ @Override
public CommandResult sendCommand(String command, String[] args) throws IOException {
try (Socket socket = new Socket()) {
socket.setSoTimeout(60000);
diff --git a/minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-server/src/main/java/org/apache/nifi/minifi/StandardMiNiFiServer.java b/minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-server/src/main/java/org/apache/nifi/minifi/StandardMiNiFiServer.java
index 396931bb14..bc57979bd1 100644
--- a/minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-server/src/main/java/org/apache/nifi/minifi/StandardMiNiFiServer.java
+++ b/minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-server/src/main/java/org/apache/nifi/minifi/StandardMiNiFiServer.java
@@ -104,6 +104,7 @@ public class StandardMiNiFiServer extends HeadlessNiFiServer implements MiNiFiSe
}
}
+ @Override
public FlowStatusReport getStatusReport(String requestString) throws StatusRequestException {
return StatusConfigReporter.getStatus(getFlowController(), requestString, logger);
}
diff --git a/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/ConfigSchema.java b/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/ConfigSchema.java
index 150f1696db..34505efb89 100644
--- a/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/ConfigSchema.java
+++ b/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/ConfigSchema.java
@@ -161,6 +161,7 @@ public class ConfigSchema extends BaseSchema implements WritableSchema, Converta
processGroupSchema.getProcessGroupSchemas().forEach(p -> addProcessGroups(p, result));
}
+ @Override
public Map<String, Object> toMap() {
Map<String, Object> result = mapSupplier.get();
result.put(VERSION, getVersion());
diff --git a/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/ProcessGroupSchema.java b/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/ProcessGroupSchema.java
index 4b644a91bb..164e46421e 100644
--- a/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/ProcessGroupSchema.java
+++ b/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/ProcessGroupSchema.java
@@ -93,6 +93,7 @@ public class ProcessGroupSchema extends BaseSchemaWithIdAndName implements Writa
addIssuesIfNotNull(connections);
}
+ @Override
public Map<String, Object> toMap() {
Map<String, Object> result = mapSupplier.get();
String id = getId();
diff --git a/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/ReportingSchema.java b/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/ReportingSchema.java
index bc6efa7d85..25086f9eeb 100644
--- a/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/ReportingSchema.java
+++ b/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/ReportingSchema.java
@@ -66,6 +66,7 @@ public class ReportingSchema extends BaseSchemaWithIdAndName {
return true;
}
+ @Override
public Map<String, Object> toMap() {
Map<String, Object> result = super.toMap();
result.put(CLASS_KEY, reportingClass);
diff --git a/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/common/BaseSchemaWithIdAndName.java b/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/common/BaseSchemaWithIdAndName.java
index e1cc8ef0e4..2c636e4c80 100644
--- a/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/common/BaseSchemaWithIdAndName.java
+++ b/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/common/BaseSchemaWithIdAndName.java
@@ -39,6 +39,7 @@ public class BaseSchemaWithIdAndName extends BaseSchemaWithId implements Writabl
this.name = name;
}
+ @Override
public String getWrapperName() {
return super.getWrapperName().replace("{name}", StringUtil.isNullOrEmpty(name) ? "unknown" : name);
}
diff --git a/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/v2/ProcessGroupSchemaV2.java b/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/v2/ProcessGroupSchemaV2.java
index 9f44d1a76a..0a7e6459e2 100644
--- a/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/v2/ProcessGroupSchemaV2.java
+++ b/minifi/minifi-toolkit/minifi-toolkit-schema/src/main/java/org/apache/nifi/minifi/toolkit/schema/v2/ProcessGroupSchemaV2.java
@@ -95,6 +95,7 @@ public class ProcessGroupSchemaV2 extends BaseSchemaWithIdAndName implements Wri
addIssuesIfNotNull(connections);
}
+ @Override
public Map<String, Object> toMap() {
Map<String, Object> result = mapSupplier.get();
String id = getId();
diff --git a/nifi-commons/nifi-calcite-utils/src/main/java/org/apache/nifi/sql/NiFiTable.java b/nifi-commons/nifi-calcite-utils/src/main/java/org/apache/nifi/sql/NiFiTable.java
index ad4ce3c891..31bdd327f9 100644
--- a/nifi-commons/nifi-calcite-utils/src/main/java/org/apache/nifi/sql/NiFiTable.java
+++ b/nifi-commons/nifi-calcite-utils/src/main/java/org/apache/nifi/sql/NiFiTable.java
@@ -143,6 +143,7 @@ public class NiFiTable implements Closeable {
return "NiFiTable[name=" + name + "]";
}
+ @Override
public void close() {
for (final NiFiTableEnumerator enumerator : enumerators) {
enumerator.close();
@@ -157,6 +158,7 @@ public class NiFiTable implements Closeable {
this.fields = fields;
}
+ @Override
public Enumerator<Object> enumerator() {
final NiFiTableEnumerator flowFileEnumerator = new NiFiTableEnumerator(dataSource, logger, fields, this::onFinish, enumerators::remove);
enumerators.add(flowFileEnumerator);
diff --git a/nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/StandardProvenanceEventRecord.java b/nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/StandardProvenanceEventRecord.java
index 28ae304edc..0c699f6e22 100644
--- a/nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/StandardProvenanceEventRecord.java
+++ b/nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/StandardProvenanceEventRecord.java
@@ -169,6 +169,7 @@ public class StandardProvenanceEventRecord implements ProvenanceEventRecord {
return allAttrs;
}
+ @Override
public String getAttribute(final String attributeName) {
if (updatedAttributes.containsKey(attributeName)) {
return updatedAttributes.get(attributeName);
diff --git a/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/BooleanEvaluator.java b/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/BooleanEvaluator.java
index 98b077eb54..c6c0fabac2 100644
--- a/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/BooleanEvaluator.java
+++ b/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/BooleanEvaluator.java
@@ -18,6 +18,7 @@ package org.apache.nifi.hl7.query.evaluator;
public abstract class BooleanEvaluator implements Evaluator<Boolean> {
+ @Override
public Class<? extends Boolean> getType() {
return Boolean.class;
}
diff --git a/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/IntegerEvaluator.java b/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/IntegerEvaluator.java
index ed56d80c8b..88653b48a1 100644
--- a/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/IntegerEvaluator.java
+++ b/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/IntegerEvaluator.java
@@ -18,6 +18,7 @@ package org.apache.nifi.hl7.query.evaluator;
public abstract class IntegerEvaluator implements Evaluator<Integer> {
+ @Override
public Class<? extends Integer> getType() {
return Integer.class;
}
diff --git a/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/StringEvaluator.java b/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/StringEvaluator.java
index 53ab004cc4..7a1c6c2851 100644
--- a/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/StringEvaluator.java
+++ b/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/StringEvaluator.java
@@ -18,6 +18,7 @@ package org.apache.nifi.hl7.query.evaluator;
public abstract class StringEvaluator implements Evaluator<String> {
+ @Override
public Class<? extends String> getType() {
return String.class;
}
diff --git a/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/message/FieldEvaluator.java b/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/message/FieldEvaluator.java
index bc8046ed00..4e3e5f3bba 100644
--- a/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/message/FieldEvaluator.java
+++ b/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/message/FieldEvaluator.java
@@ -37,6 +37,7 @@ public class FieldEvaluator implements Evaluator<List> {
this.indexEvaluator = indexEvaluator;
}
+ @Override
public List<HL7Field> evaluate(final Map<String, Object> objectMap) {
final List<HL7Segment> segments = segmentEvaluator.evaluate(objectMap);
if (segments == null) {
@@ -61,6 +62,7 @@ public class FieldEvaluator implements Evaluator<List> {
return fields;
}
+ @Override
public Class<? extends List> getType() {
return List.class;
}
diff --git a/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/message/MessageEvaluator.java b/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/message/MessageEvaluator.java
index cc02315756..c421cc14b8 100644
--- a/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/message/MessageEvaluator.java
+++ b/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/message/MessageEvaluator.java
@@ -23,10 +23,12 @@ import org.apache.nifi.hl7.query.evaluator.Evaluator;
public class MessageEvaluator implements Evaluator<HL7Message> {
+ @Override
public HL7Message evaluate(final Map<String, Object> objectMap) {
return (HL7Message) objectMap.get(MESSAGE_KEY);
}
+ @Override
public Class<? extends HL7Message> getType() {
return HL7Message.class;
}
diff --git a/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/message/SegmentEvaluator.java b/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/message/SegmentEvaluator.java
index ec1ee540d0..afed703a54 100644
--- a/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/message/SegmentEvaluator.java
+++ b/nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/query/evaluator/message/SegmentEvaluator.java
@@ -34,6 +34,7 @@ public class SegmentEvaluator implements Evaluator<List> {
this.segmentTypeEvaluator = segmentTypeEvaluator;
}
+ @Override
public List<HL7Segment> evaluate(final Map<String, Object> objectMap) {
final String segmentType = segmentTypeEvaluator.evaluate(objectMap);
if (segmentType == null) {
@@ -45,6 +46,7 @@ public class SegmentEvaluator implements Evaluator<List> {
return (segments == null) ? Collections.<HL7Segment>emptyList() : segments;
}
+ @Override
public Class<? extends List> getType() {
return List.class;
}
diff --git a/nifi-commons/nifi-properties/src/main/java/org/apache/nifi/util/NiFiProperties.java b/nifi-commons/nifi-properties/src/main/java/org/apache/nifi/util/NiFiProperties.java
index b84ebfcc33..ddf5925563 100644
--- a/nifi-commons/nifi-properties/src/main/java/org/apache/nifi/util/NiFiProperties.java
+++ b/nifi-commons/nifi-properties/src/main/java/org/apache/nifi/util/NiFiProperties.java
@@ -1425,6 +1425,7 @@ public class NiFiProperties extends ApplicationProperties {
return getProperty(MAX_APPENDABLE_CLAIM_SIZE, DEFAULT_MAX_APPENDABLE_CLAIM_SIZE);
}
+ @Override
public String getProperty(final String key, final String defaultValue) {
final String value = getProperty(key);
return (value == null || value.isBlank()) ? defaultValue : value;
diff --git a/nifi-commons/nifi-security-kerberos/src/main/java/org/apache/nifi/security/krb/UsernamePasswordCallbackHandler.java b/nifi-commons/nifi-security-kerberos/src/main/java/org/apache/nifi/security/krb/UsernamePasswordCallbackHandler.java
index 222a6fee07..905fc99d7e 100644
--- a/nifi-commons/nifi-security-kerberos/src/main/java/org/apache/nifi/security/krb/UsernamePasswordCallbackHandler.java
+++ b/nifi-commons/nifi-security-kerberos/src/main/java/org/apache/nifi/security/krb/UsernamePasswordCallbackHandler.java
@@ -40,6 +40,7 @@ public class UsernamePasswordCallbackHandler implements CallbackHandler {
Validate.notBlank(this.password);
}
+ @Override
public void handle(Callback[] callbacks) throws IOException, UnsupportedCallbackException {
for (final Callback callback : callbacks) {
if (callback instanceof NameCallback) {
diff --git a/nifi-commons/nifi-security-ssl/src/main/java/org/apache/nifi/security/ssl/StandardX509ExtendedKeyManager.java b/nifi-commons/nifi-security-ssl/src/main/java/org/apache/nifi/security/ssl/StandardX509ExtendedKeyManager.java
index 3fb0d45f62..c3992d3259 100644
--- a/nifi-commons/nifi-security-ssl/src/main/java/org/apache/nifi/security/ssl/StandardX509ExtendedKeyManager.java
+++ b/nifi-commons/nifi-security-ssl/src/main/java/org/apache/nifi/security/ssl/StandardX509ExtendedKeyManager.java
@@ -62,6 +62,7 @@ public class StandardX509ExtendedKeyManager extends X509ExtendedKeyManager imple
return keyManagerRef.get().chooseClientAlias(keyType, issuers, socket);
}
+ @Override
public String chooseEngineClientAlias(final String[] keyType, final Principal[] issuers, final SSLEngine engine) {
return keyManagerRef.get().chooseEngineClientAlias(keyType, issuers, engine);
}
@@ -76,6 +77,7 @@ public class StandardX509ExtendedKeyManager extends X509ExtendedKeyManager imple
return keyManagerRef.get().chooseServerAlias(keyType, issuers, socket);
}
+ @Override
public String chooseEngineServerAlias(final String keyType, final Principal[] issuers, final SSLEngine engine) {
return keyManagerRef.get().chooseEngineServerAlias(keyType, issuers, engine);
}
diff --git a/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/util/StandardDataPacket.java b/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/util/StandardDataPacket.java
index 70bb32464d..83c19f6515 100644
--- a/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/util/StandardDataPacket.java
+++ b/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/util/StandardDataPacket.java
@@ -35,14 +35,17 @@ public class StandardDataPacket implements DataPacket {
this.size = size;
}
+ @Override
public Map<String, String> getAttributes() {
return attributes;
}
+ @Override
public InputStream getData() {
return stream;
}
+ @Override
public long getSize() {
return size;
}
diff --git a/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/MinimumLengthInputStream.java b/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/MinimumLengthInputStream.java
index 44e9c2e075..aa94a39473 100644
--- a/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/MinimumLengthInputStream.java
+++ b/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/MinimumLengthInputStream.java
@@ -53,6 +53,7 @@ public class MinimumLengthInputStream extends FilterInputStream {
return read(b, 0, b.length);
}
+ @Override
public int read(byte[] b, int off, int len) throws IOException {
final int num = super.read(b, off, len);
diff --git a/nifi-commons/nifi-write-ahead-log/src/main/java/org/apache/nifi/wali/LengthDelimitedJournal.java b/nifi-commons/nifi-write-ahead-log/src/main/java/org/apache/nifi/wali/LengthDelimitedJournal.java
index 61af2b0c32..1d3eadbebf 100644
--- a/nifi-commons/nifi-write-ahead-log/src/main/java/org/apache/nifi/wali/LengthDelimitedJournal.java
+++ b/nifi-commons/nifi-write-ahead-log/src/main/java/org/apache/nifi/wali/LengthDelimitedJournal.java
@@ -95,6 +95,7 @@ public class LengthDelimitedJournal<T> implements WriteAheadJournal<T> {
this.maxInHeapSerializationBytes = maxInHeapSerializationBytes;
}
+ @Override
public void dispose() {
logger.debug("Deleting Journal {} because it is now encapsulated in the latest Snapshot", journalFile.getName());
if (!journalFile.delete() && journalFile.exists()) {
diff --git a/nifi-extension-bundles/nifi-asana-bundle/nifi-asana-services/src/main/java/org/apache/nifi/controller/asana/StandardAsanaClient.java b/nifi-extension-bundles/nifi-asana-bundle/nifi-asana-services/src/main/java/org/apache/nifi/controller/asana/StandardAsanaClient.java
index 1bb5cf9a91..b5216d8e66 100644
--- a/nifi-extension-bundles/nifi-asana-bundle/nifi-asana-services/src/main/java/org/apache/nifi/controller/asana/StandardAsanaClient.java
+++ b/nifi-extension-bundles/nifi-asana-bundle/nifi-asana-services/src/main/java/org/apache/nifi/controller/asana/StandardAsanaClient.java
@@ -89,6 +89,7 @@ public class StandardAsanaClient implements AsanaClient {
}
}
+ @Override
public Stream<ProjectMembership> getProjectMemberships(Project project) {
try {
return collectionRequestToStream(
diff --git a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/v2/AbstractAwsAsyncProcessor.java b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/v2/AbstractAwsAsyncProcessor.java
index c9e3455af0..cf2cf9e367 100644
--- a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/v2/AbstractAwsAsyncProcessor.java
+++ b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/v2/AbstractAwsAsyncProcessor.java
@@ -55,6 +55,7 @@ public abstract class AbstractAwsAsyncProcessor<
* @param context The process context
* @return The created client
*/
+ @Override
public T createClient(final ProcessContext context, final Region region) {
final U clientBuilder = createClientBuilder(context);
this.configureClientBuilder(clientBuilder, region, context);
diff --git a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/v2/AbstractAwsSyncProcessor.java b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/v2/AbstractAwsSyncProcessor.java
index d53db978f5..eba06d5d89 100644
--- a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/v2/AbstractAwsSyncProcessor.java
+++ b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/v2/AbstractAwsSyncProcessor.java
@@ -56,10 +56,12 @@ public abstract class AbstractAwsSyncProcessor<
* @param context The process context
* @return The created client
*/
+ @Override
public T createClient(final ProcessContext context) {
return createClient(context, getRegion(context));
}
+ @Override
public T createClient(final ProcessContext context, final Region region) {
final U clientBuilder = createClientBuilder(context);
this.configureClientBuilder(clientBuilder, region, context);
diff --git a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/credentials/provider/factory/strategies/AbstractCredentialsStrategy.java b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/credentials/provider/factory/strategies/AbstractCredentialsStrategy.java
index f5ed8ab551..bed0770622 100644
--- a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/credentials/provider/factory/strategies/AbstractCredentialsStrategy.java
+++ b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/credentials/provider/factory/strategies/AbstractCredentialsStrategy.java
@@ -80,8 +80,10 @@ public abstract class AbstractCredentialsStrategy implements CredentialsStrategy
return validationFailureResults;
}
+ @Override
public abstract AWSCredentialsProvider getCredentialsProvider(final PropertyContext propertyContext);
+ @Override
public String getName() {
return name;
}
diff --git a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/kinesis/stream/pause/StandardRecordProcessorBlocker.java b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/kinesis/stream/pause/StandardRecordProcessorBlocker.java
index 12a728e21d..44365e4b29 100644
--- a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/kinesis/stream/pause/StandardRecordProcessorBlocker.java
+++ b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/kinesis/stream/pause/StandardRecordProcessorBlocker.java
@@ -46,6 +46,7 @@ public class StandardRecordProcessorBlocker implements RecordProcessorBlocker {
this.timeoutBase = timestampProvider.get();
}
+ @Override
public void await() throws InterruptedException {
final long nowTimestamp = timestampProvider.get();
if (!isAfterTimeout(nowTimestamp)) {
diff --git a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/ml/translate/StartAwsTranslateJob.java b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/ml/translate/StartAwsTranslateJob.java
index db75233b09..2c70f52b94 100644
--- a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/ml/translate/StartAwsTranslateJob.java
+++ b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/ml/translate/StartAwsTranslateJob.java
@@ -54,6 +54,7 @@ public class StartAwsTranslateJob extends AbstractAwsMachineLearningJobStarter<
return StartTextTranslationJobRequest.serializableBuilderClass();
}
+ @Override
protected String getAwsTaskId(final ProcessContext context, final StartTextTranslationJobResponse startTextTranslationJobResponse, final FlowFile flowFile) {
return startTextTranslationJobResponse.jobId();
}
diff --git a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/test/java/org/apache/nifi/processors/aws/cloudwatch/MockPutCloudWatchMetric.java b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/test/java/org/apache/nifi/processors/aws/cloudwatch/MockPutCloudWatchMetric.java
index a19153cde5..60b60c0c09 100644
--- a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/test/java/org/apache/nifi/processors/aws/cloudwatch/MockPutCloudWatchMetric.java
+++ b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/test/java/org/apache/nifi/processors/aws/cloudwatch/MockPutCloudWatchMetric.java
@@ -35,6 +35,7 @@ public class MockPutCloudWatchMetric extends PutCloudWatchMetric {
protected int putMetricDataCallCount = 0;
+ @Override
protected PutMetricDataResponse putMetricData(final ProcessContext context, final PutMetricDataRequest metricDataRequest) {
putMetricDataCallCount++;
actualNamespace = metricDataRequest.namespace();
diff --git a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/AbstractAzureBlobProcessor_v12.java b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/AbstractAzureBlobProcessor_v12.java
index f034ac74f2..78b26f2186 100644
--- a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/AbstractAzureBlobProcessor_v12.java
+++ b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/AbstractAzureBlobProcessor_v12.java
@@ -123,6 +123,8 @@ public abstract class AbstractAzureBlobProcessor_v12 extends AbstractProcessor {
protected void applyBlobMetadata(Map<String, String> attributes, BlobClient blobClient) {
Supplier<BlobProperties> props = new Supplier<>() {
BlobProperties properties;
+
+ @Override
public BlobProperties get() {
if (properties == null) {
properties = blobClient.getProperties();
diff --git a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/PutAzureBlobStorage_v12.java b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/PutAzureBlobStorage_v12.java
index 3ce4ef7c96..6fbf56a58a 100644
--- a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/PutAzureBlobStorage_v12.java
+++ b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/PutAzureBlobStorage_v12.java
@@ -130,6 +130,7 @@ public class PutAzureBlobStorage_v12 extends AbstractAzureBlobProcessor_v12 impl
return PROPERTY_DESCRIPTORS;
}
+ @Override
public void onTrigger(final ProcessContext context, final ProcessSession session) throws ProcessException {
FlowFile flowFile = session.get();
if (flowFile == null) {
diff --git a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/BlobServiceClientFactory.java b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/BlobServiceClientFactory.java
index 9c5ce2282f..fb811f6de2 100644
--- a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/BlobServiceClientFactory.java
+++ b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/BlobServiceClientFactory.java
@@ -37,6 +37,7 @@ public class BlobServiceClientFactory extends AbstractStorageClientFactory<Azure
super(logger, proxyOptions);
}
+ @Override
protected BlobServiceClient createStorageClient(final AzureStorageCredentialsDetails_v12 credentialsDetails, final ProxyOptions proxyOptions) {
final BlobServiceClientBuilder clientBuilder = new BlobServiceClientBuilder();
clientBuilder.endpoint(String.format("https://%s.%s", credentialsDetails.getAccountName(), credentialsDetails.getEndpointSuffix()));
diff --git a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/ClientSideEncryptionMethod.java b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/ClientSideEncryptionMethod.java
index f75754732d..8cbd290e3a 100644
--- a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/ClientSideEncryptionMethod.java
+++ b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/ClientSideEncryptionMethod.java
@@ -43,6 +43,7 @@ public enum ClientSideEncryptionMethod implements DescribedValue {
return this.name();
}
+ @Override
public String getDescription() {
return description;
}
diff --git a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/DataLakeServiceClientFactory.java b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/DataLakeServiceClientFactory.java
index fb43393dcc..bebf1cebd9 100644
--- a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/DataLakeServiceClientFactory.java
+++ b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/DataLakeServiceClientFactory.java
@@ -40,6 +40,7 @@ public class DataLakeServiceClientFactory extends AbstractStorageClientFactory<A
super(logger, proxyOptions);
}
+ @Override
protected DataLakeServiceClient createStorageClient(ADLSCredentialsDetails credentialsDetails, ProxyOptions proxyOptions) {
final String accountName = credentialsDetails.getAccountName();
final String accountKey = credentialsDetails.getAccountKey();
diff --git a/nifi-extension-bundles/nifi-cdc/nifi-cdc-api/src/main/java/org/apache/nifi/cdc/event/BaseEventInfo.java b/nifi-extension-bundles/nifi-cdc/nifi-cdc-api/src/main/java/org/apache/nifi/cdc/event/BaseEventInfo.java
index 13307bbfd0..a47c3c314c 100644
--- a/nifi-extension-bundles/nifi-cdc/nifi-cdc-api/src/main/java/org/apache/nifi/cdc/event/BaseEventInfo.java
+++ b/nifi-extension-bundles/nifi-cdc/nifi-cdc-api/src/main/java/org/apache/nifi/cdc/event/BaseEventInfo.java
@@ -31,10 +31,12 @@ public class BaseEventInfo implements EventInfo {
}
+ @Override
public String getEventType() {
return eventType;
}
+ @Override
public Long getTimestamp() {
return timestamp;
}
diff --git a/nifi-extension-bundles/nifi-cdc/nifi-cdc-api/src/main/java/org/apache/nifi/cdc/event/BaseRowEventInfo.java b/nifi-extension-bundles/nifi-cdc/nifi-cdc-api/src/main/java/org/apache/nifi/cdc/event/BaseRowEventInfo.java
index 1107a91fd9..0bb8347e5a 100644
--- a/nifi-extension-bundles/nifi-cdc/nifi-cdc-api/src/main/java/org/apache/nifi/cdc/event/BaseRowEventInfo.java
+++ b/nifi-extension-bundles/nifi-cdc/nifi-cdc-api/src/main/java/org/apache/nifi/cdc/event/BaseRowEventInfo.java
@@ -31,6 +31,7 @@ public class BaseRowEventInfo<RowEventDataType> extends BaseTableEventInfo imple
this.rows = rows;
}
+ @Override
public List<RowEventDataType> getRows() {
return rows;
}
diff --git a/nifi-extension-bundles/nifi-cdc/nifi-cdc-api/src/main/java/org/apache/nifi/cdc/event/BaseTableEventInfo.java b/nifi-extension-bundles/nifi-cdc/nifi-cdc-api/src/main/java/org/apache/nifi/cdc/event/BaseTableEventInfo.java
index bc34608de8..d165e2358f 100644
--- a/nifi-extension-bundles/nifi-cdc/nifi-cdc-api/src/main/java/org/apache/nifi/cdc/event/BaseTableEventInfo.java
+++ b/nifi-extension-bundles/nifi-cdc/nifi-cdc-api/src/main/java/org/apache/nifi/cdc/event/BaseTableEventInfo.java
@@ -39,22 +39,27 @@ public class BaseTableEventInfo extends BaseEventInfo implements TableEventInfo
}
}
+ @Override
public String getDatabaseName() {
return databaseName;
}
+ @Override
public String getTableName() {
return tableName;
}
+ @Override
public Long getTableId() {
return tableId;
}
+ @Override
public List<ColumnDefinition> getColumns() {
return columns;
}
+ @Override
public ColumnDefinition getColumnByIndex(int i) {
try {
return columns.get(i);
diff --git a/nifi-extension-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/BaseBinlogEventInfo.java b/nifi-extension-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/BaseBinlogEventInfo.java
index 9106e937e0..899ee7023f 100644
--- a/nifi-extension-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/BaseBinlogEventInfo.java
+++ b/nifi-extension-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/BaseBinlogEventInfo.java
@@ -38,14 +38,17 @@ public class BaseBinlogEventInfo extends BaseEventInfo implements BinlogEventInf
this.binlogGtidSet = binlogGtidSet;
}
+ @Override
public String getBinlogFilename() {
return binlogFilename;
}
+ @Override
public Long getBinlogPosition() {
return binlogPosition;
}
+ @Override
public String getBinlogGtidSet() {
return binlogGtidSet;
}
diff --git a/nifi-extension-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/io/AbstractBinlogTableEventWriter.java b/nifi-extension-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/io/AbstractBinlogTableEventWriter.java
index 013b63edf9..eb85926337 100644
--- a/nifi-extension-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/io/AbstractBinlogTableEventWriter.java
+++ b/nifi-extension-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/io/AbstractBinlogTableEventWriter.java
@@ -49,6 +49,7 @@ public abstract class AbstractBinlogTableEventWriter<T extends BinlogTableEventI
}
}
+ @Override
protected void writeJson(T event) throws IOException {
super.writeJson(event);
if (event.getDatabaseName() != null) {
diff --git a/nifi-extension-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/io/BeginTransactionEventWriter.java b/nifi-extension-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/io/BeginTransactionEventWriter.java
index ea1f5d2fc8..2185b8b054 100644
--- a/nifi-extension-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/io/BeginTransactionEventWriter.java
+++ b/nifi-extension-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/io/BeginTransactionEventWriter.java
@@ -25,6 +25,7 @@ import java.io.IOException;
*/
public class BeginTransactionEventWriter extends AbstractBinlogEventWriter<BeginTransactionEventInfo> {
+ @Override
protected void writeJson(BeginTransactionEventInfo event) throws IOException {
super.writeJson(event);
if (event.getDatabaseName() != null) {
diff --git a/nifi-extension-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/io/CommitTransactionEventWriter.java b/nifi-extension-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/io/CommitTransactionEventWriter.java
index 9ed576b023..48e6bbfc88 100644
--- a/nifi-extension-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/io/CommitTransactionEventWriter.java
+++ b/nifi-extension-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/io/CommitTransactionEventWriter.java
@@ -40,6 +40,7 @@ public class CommitTransactionEventWriter extends AbstractBinlogEventWriter<Comm
return sequenceId;
}
+ @Override
protected void writeJson(CommitTransactionEventInfo event) throws IOException {
super.writeJson(event);
if (event.getDatabaseName() != null) {
diff --git a/nifi-extension-bundles/nifi-cipher-bundle/nifi-cipher-processors/src/test/java/org/apache/nifi/processors/cipher/io/ChannelStreamCallbackTest.java b/nifi-extension-bundles/nifi-cipher-bundle/nifi-cipher-processors/src/test/java/org/apache/nifi/processors/cipher/io/ChannelStreamCallbackTest.java
index 0f01d7b861..d01cfaa4f7 100644
--- a/nifi-extension-bundles/nifi-cipher-bundle/nifi-cipher-processors/src/test/java/org/apache/nifi/processors/cipher/io/ChannelStreamCallbackTest.java
+++ b/nifi-extension-bundles/nifi-cipher-bundle/nifi-cipher-processors/src/test/java/org/apache/nifi/processors/cipher/io/ChannelStreamCallbackTest.java
@@ -97,6 +97,7 @@ class ChannelStreamCallbackTest {
super(BUFFER_CAPACITY);
}
+ @Override
protected ReadableByteChannel getReadableChannel(final InputStream inputStream) {
return new BufferRemainingReadableByteChannel();
}
diff --git a/nifi-extension-bundles/nifi-enrich-bundle/nifi-enrich-processors/src/test/java/org/apache/nifi/processors/TestGeoEnrichIP.java b/nifi-extension-bundles/nifi-enrich-bundle/nifi-enrich-processors/src/test/java/org/apache/nifi/processors/TestGeoEnrichIP.java
index cc77dc3821..ec721aedc3 100644
--- a/nifi-extension-bundles/nifi-enrich-bundle/nifi-enrich-processors/src/test/java/org/apache/nifi/processors/TestGeoEnrichIP.java
+++ b/nifi-extension-bundles/nifi-enrich-bundle/nifi-enrich-processors/src/test/java/org/apache/nifi/processors/TestGeoEnrichIP.java
@@ -283,6 +283,7 @@ public class TestGeoEnrichIP {
databaseReaderRef.set(databaseReader);
}
+ @Override
protected void loadDatabaseFile() {
// Do nothing, the mock database reader is used
}
diff --git a/nifi-extension-bundles/nifi-extension-utils/nifi-bin-manager/src/main/java/org/apache/nifi/processor/util/bin/EvictionReason.java b/nifi-extension-bundles/nifi-extension-utils/nifi-bin-manager/src/main/java/org/apache/nifi/processor/util/bin/EvictionReason.java
index e113891800..9895cdaf92 100644
--- a/nifi-extension-bundles/nifi-extension-utils/nifi-bin-manager/src/main/java/org/apache/nifi/processor/util/bin/EvictionReason.java
+++ b/nifi-extension-bundles/nifi-extension-utils/nifi-bin-manager/src/main/java/org/apache/nifi/processor/util/bin/EvictionReason.java
@@ -41,6 +41,7 @@ public enum EvictionReason {
return explanation;
}
+ @Override
public String toString() {
return explanation;
}
diff --git a/nifi-extension-bundles/nifi-extension-utils/nifi-event-listen/src/main/java/org/apache/nifi/processor/util/listen/event/StandardEvent.java b/nifi-extension-bundles/nifi-extension-utils/nifi-event-listen/src/main/java/org/apache/nifi/processor/util/listen/event/StandardEvent.java
index fa3699e275..925cb8f122 100644
--- a/nifi-extension-bundles/nifi-extension-utils/nifi-event-listen/src/main/java/org/apache/nifi/processor/util/listen/event/StandardEvent.java
+++ b/nifi-extension-bundles/nifi-extension-utils/nifi-event-listen/src/main/java/org/apache/nifi/processor/util/listen/event/StandardEvent.java
@@ -45,6 +45,7 @@ public class StandardEvent<C extends SelectableChannel> implements Event<C> {
return data;
}
+ @Override
public ChannelResponder<C> getResponder() {
return responder;
}
diff --git a/nifi-extension-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java b/nifi-extension-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java
index 9c6e53e42f..0241ce42ed 100644
--- a/nifi-extension-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java
+++ b/nifi-extension-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java
@@ -38,10 +38,12 @@ public class ByteArrayMessage implements NetworkEvent {
this(message, sender, null);
}
+ @Override
public byte[] getMessage() {
return message;
}
+ @Override
public String getSender() {
return sender;
}
diff --git a/nifi-extension-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/NettyEventSenderFactory.java b/nifi-extension-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/NettyEventSenderFactory.java
index 90302978da..df06c1af30 100644
--- a/nifi-extension-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/NettyEventSenderFactory.java
+++ b/nifi-extension-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/NettyEventSenderFactory.java
@@ -166,6 +166,7 @@ public class NettyEventSenderFactory<T> extends EventLoopGroupFactory implements
*
* @return Connected Event Sender
*/
+ @Override
public EventSender<T> getEventSender() {
final Bootstrap bootstrap = new Bootstrap();
bootstrap.remoteAddress(new InetSocketAddress(address, port));
diff --git a/nifi-extension-bundles/nifi-extension-utils/nifi-file-transfer/src/main/java/org/apache/nifi/processor/util/file/transfer/FileInfo.java b/nifi-extension-bundles/nifi-extension-utils/nifi-file-transfer/src/main/java/org/apache/nifi/processor/util/file/transfer/FileInfo.java
index a6ed2c265e..b32b4b0bcf 100644
--- a/nifi-extension-bundles/nifi-extension-utils/nifi-file-transfer/src/main/java/org/apache/nifi/processor/util/file/transfer/FileInfo.java
+++ b/nifi-extension-bundles/nifi-extension-utils/nifi-file-transfer/src/main/java/org/apache/nifi/processor/util/file/transfer/FileInfo.java
@@ -80,6 +80,7 @@ public class FileInfo implements Comparable<FileInfo>, Serializable, ListableEnt
return directory;
}
+ @Override
public long getSize() {
return size;
}
@@ -100,6 +101,7 @@ public class FileInfo implements Comparable<FileInfo>, Serializable, ListableEnt
return group;
}
+ @Override
public Record toRecord() {
final Map<String, Object> values = new HashMap<>(8);
values.put(FILENAME, getFileName());
diff --git a/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-json-record-utils/src/main/java/org/apache/nifi/json/JsonSchemaInference.java b/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-json-record-utils/src/main/java/org/apache/nifi/json/JsonSchemaInference.java
index 5998609325..5fc0e8b8b2 100644
--- a/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-json-record-utils/src/main/java/org/apache/nifi/json/JsonSchemaInference.java
+++ b/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-json-record-utils/src/main/java/org/apache/nifi/json/JsonSchemaInference.java
@@ -39,7 +39,7 @@ public class JsonSchemaInference extends HierarchicalSchemaInference<JsonNode> {
this.timeValueInference = timeValueInference;
}
-
+ @Override
protected DataType getDataType(final JsonNode jsonNode) {
if (jsonNode.isTextual()) {
final String text = jsonNode.textValue();
diff --git a/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-schema-inference-utils/src/main/java/org/apache/nifi/schema/inference/HierarchicalSchemaInference.java b/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-schema-inference-utils/src/main/java/org/apache/nifi/schema/inference/HierarchicalSchemaInference.java
index 0167f974d1..49afbee54e 100644
--- a/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-schema-inference-utils/src/main/java/org/apache/nifi/schema/inference/HierarchicalSchemaInference.java
+++ b/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-schema-inference-utils/src/main/java/org/apache/nifi/schema/inference/HierarchicalSchemaInference.java
@@ -37,6 +37,7 @@ import java.util.function.Consumer;
public abstract class HierarchicalSchemaInference<T> implements SchemaInferenceEngine<T> {
+ @Override
public RecordSchema inferSchema(final RecordSource<T> recordSource) throws IOException {
final Map<String, FieldTypeInference> typeMap = new LinkedHashMap<>();
String rootElementName = null;
diff --git a/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/bigquery/PutBigQuery.java b/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/bigquery/PutBigQuery.java
index e7e9ebd649..969826c8e6 100644
--- a/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/bigquery/PutBigQuery.java
+++ b/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/bigquery/PutBigQuery.java
@@ -359,12 +359,14 @@ public class PutBigQuery extends AbstractBigQueryProcessor {
this.appendContext = appendContext;
}
+ @Override
public void onSuccess(AppendRowsResponse response) {
getLogger().info("Append success with offset: {}", appendContext.getOffset());
appendSuccessCount.incrementAndGet();
inflightRequestCount.arriveAndDeregister();
}
+ @Override
public void onFailure(Throwable throwable) {
// If the state is INTERNAL, CANCELLED, or ABORTED, you can retry. For more information,
// see: https://grpc.github.io/grpc-java/javadoc/io/grpc/StatusRuntimeException.html
diff --git a/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/credentials/factory/strategies/AbstractCredentialsStrategy.java b/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/credentials/factory/strategies/AbstractCredentialsStrategy.java
index 50432d18c1..44299dcc67 100644
--- a/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/credentials/factory/strategies/AbstractCredentialsStrategy.java
+++ b/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/credentials/factory/strategies/AbstractCredentialsStrategy.java
@@ -77,6 +77,7 @@ public abstract class AbstractCredentialsStrategy implements CredentialsStrategy
return validationFailureResults;
}
+ @Override
public String getName() {
return name;
}
diff --git a/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/credentials/service/GCPCredentialsControllerService.java b/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/credentials/service/GCPCredentialsControllerService.java
index 2ce8976064..8f6c5f8a4e 100644
--- a/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/credentials/service/GCPCredentialsControllerService.java
+++ b/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/credentials/service/GCPCredentialsControllerService.java
@@ -92,6 +92,7 @@ public class GCPCredentialsControllerService extends AbstractControllerService i
return PROPERTY_DESCRIPTORS;
}
+ @Override
public GoogleCredentials getGoogleCredentials() throws ProcessException {
return googleCredentials;
}
diff --git a/nifi-extension-bundles/nifi-graph-bundle/nifi-graph-processors/src/main/java/org/apache/nifi/processors/graph/ExecuteGraphQuery.java b/nifi-extension-bundles/nifi-graph-bundle/nifi-graph-processors/src/main/java/org/apache/nifi/processors/graph/ExecuteGraphQuery.java
index f3cf611c8c..7b5d9bf816 100644
--- a/nifi-extension-bundles/nifi-graph-bundle/nifi-graph-processors/src/main/java/org/apache/nifi/processors/graph/ExecuteGraphQuery.java
+++ b/nifi-extension-bundles/nifi-graph-bundle/nifi-graph-processors/src/main/java/org/apache/nifi/processors/graph/ExecuteGraphQuery.java
@@ -89,6 +89,7 @@ public class ExecuteGraphQuery extends AbstractGraphExecutor {
private volatile GraphClientService clientService;
@OnScheduled
+ @Override
public void onScheduled(final ProcessContext context) {
super.onScheduled(context);
clientService = context.getProperty(CLIENT_SERVICE).asControllerService(GraphClientService.class);
diff --git a/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/flow/GroovyProcessSessionWrap.java b/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/flow/GroovyProcessSessionWrap.java
index d9a838aab0..ec8bf15fca 100644
--- a/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/flow/GroovyProcessSessionWrap.java
+++ b/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/flow/GroovyProcessSessionWrap.java
@@ -36,6 +36,7 @@ public class GroovyProcessSessionWrap extends ProcessSessionWrap {
/**
* function returns wrapped flow file with session for the simplified script access.
*/
+ @Override
public SessionFile wrap(FlowFile f) {
if (f == null) {
return null;
diff --git a/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/flow/SessionFile.java b/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/flow/SessionFile.java
index b8bb1f7cae..4bb33c6cc2 100644
--- a/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/flow/SessionFile.java
+++ b/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/flow/SessionFile.java
@@ -228,6 +228,7 @@ public abstract class SessionFile implements FlowFile {
}
@SuppressWarnings("NullableProblems")
+ @Override
public int compareTo(FlowFile other) {
if (other instanceof SessionFile) {
other = ((SessionFile) other).flowFile;
diff --git a/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/sql/OSql.java b/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/sql/OSql.java
index 550dbb6cf2..6c34ff6d2b 100644
--- a/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/sql/OSql.java
+++ b/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/sql/OSql.java
@@ -37,6 +37,7 @@ public class OSql extends Sql {
super(connection);
}
+ @Override
protected void setObject(PreparedStatement statement, int i, Object value) throws SQLException {
try {
if (value instanceof InParameter) {
diff --git a/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/GetHDFSFileInfo.java b/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/GetHDFSFileInfo.java
index 2dc43baba9..134062c4dd 100644
--- a/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/GetHDFSFileInfo.java
+++ b/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/GetHDFSFileInfo.java
@@ -661,6 +661,7 @@ public class GetHDFSFileInfo extends AbstractHadoopProcessor {
this.val = val;
}
+ @Override
public String toString() {
return this.val;
}
diff --git a/nifi-extension-bundles/nifi-jolt-bundle/nifi-jolt-processors/src/main/java/org/apache/nifi/processors/jolt/JoltTransformJSON.java b/nifi-extension-bundles/nifi-jolt-bundle/nifi-jolt-processors/src/main/java/org/apache/nifi/processors/jolt/JoltTransformJSON.java
index 0509466179..091766c621 100644
--- a/nifi-extension-bundles/nifi-jolt-bundle/nifi-jolt-processors/src/main/java/org/apache/nifi/processors/jolt/JoltTransformJSON.java
+++ b/nifi-extension-bundles/nifi-jolt-bundle/nifi-jolt-processors/src/main/java/org/apache/nifi/processors/jolt/JoltTransformJSON.java
@@ -209,6 +209,7 @@ public class JoltTransformJSON extends AbstractJoltTransform {
}
@OnScheduled
+ @Override
public void setup(final ProcessContext context) {
super.setup(context);
final int maxStringLength = context.getProperty(MAX_STRING_LENGTH).asDataSize(DataUnit.B).intValue();
diff --git a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/java/org/apache/nifi/kafka/processors/ConsumeKafkaInjectMetadataRecordIT.java b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/java/org/apache/nifi/kafka/processors/ConsumeKafkaInjectMetadataRecordIT.java
index 20707bf279..babcb6124b 100644
--- a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/java/org/apache/nifi/kafka/processors/ConsumeKafkaInjectMetadataRecordIT.java
+++ b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/java/org/apache/nifi/kafka/processors/ConsumeKafkaInjectMetadataRecordIT.java
@@ -79,6 +79,7 @@ class ConsumeKafkaInjectMetadataRecordIT extends AbstractConsumeKafkaIT {
}
static class RecordVerifier extends Verifier {
+ @Override
void verify(final JsonNode jsonNode) {
final ObjectNode key = assertInstanceOf(ObjectNode.class, jsonNode);
assertEquals(2, key.size());
@@ -88,6 +89,7 @@ class ConsumeKafkaInjectMetadataRecordIT extends AbstractConsumeKafkaIT {
}
static class StringVerifier extends Verifier {
+ @Override
void verify(final JsonNode jsonNode) {
final TextNode key = assertInstanceOf(TextNode.class, jsonNode);
assertEquals(MESSAGE_KEY, key.asText());
@@ -95,6 +97,7 @@ class ConsumeKafkaInjectMetadataRecordIT extends AbstractConsumeKafkaIT {
}
static class ByteArrayVerifier extends Verifier {
+ @Override
void verify(final JsonNode jsonNode) {
final ArrayNode key = assertInstanceOf(ArrayNode.class, jsonNode);
assertEquals(MESSAGE_KEY.length(), key.size());
diff --git a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/java/org/apache/nifi/kafka/processors/ConsumeKafkaWrapperRecordIT.java b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/java/org/apache/nifi/kafka/processors/ConsumeKafkaWrapperRecordIT.java
index bd68194451..4a5d491cb3 100644
--- a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/java/org/apache/nifi/kafka/processors/ConsumeKafkaWrapperRecordIT.java
+++ b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/java/org/apache/nifi/kafka/processors/ConsumeKafkaWrapperRecordIT.java
@@ -80,6 +80,7 @@ class ConsumeKafkaWrapperRecordIT extends AbstractConsumeKafkaIT {
}
static class RecordVerifier extends Verifier {
+ @Override
void verify(final JsonNode jsonNode) {
final ObjectNode key = assertInstanceOf(ObjectNode.class, jsonNode);
assertEquals(2, key.size());
@@ -89,6 +90,7 @@ class ConsumeKafkaWrapperRecordIT extends AbstractConsumeKafkaIT {
}
static class StringVerifier extends Verifier {
+ @Override
void verify(final JsonNode jsonNode) {
final TextNode key = assertInstanceOf(TextNode.class, jsonNode);
assertEquals(MESSAGE_KEY, key.asText());
@@ -96,6 +98,7 @@ class ConsumeKafkaWrapperRecordIT extends AbstractConsumeKafkaIT {
}
static class ByteArrayVerifier extends Verifier {
+ @Override
void verify(final JsonNode jsonNode) {
final ArrayNode key = assertInstanceOf(ArrayNode.class, jsonNode);
assertEquals(MESSAGE_KEY.length(), key.size());
diff --git a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/kafka/processors/producer/header/AttributesHeadersFactory.java b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/kafka/processors/producer/header/AttributesHeadersFactory.java
index 401a6c1eea..7aa49fc1fa 100644
--- a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/kafka/processors/producer/header/AttributesHeadersFactory.java
+++ b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/kafka/processors/producer/header/AttributesHeadersFactory.java
@@ -36,6 +36,7 @@ public class AttributesHeadersFactory implements HeadersFactory {
this.messageHeaderCharset = messageHeaderCharset;
}
+ @Override
public List<RecordHeader> getHeaders(final Map<String, String> attributes) {
final List<RecordHeader> headers = new ArrayList<>();
if (attributeNamePattern != null) {
diff --git a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-service-api/src/main/java/org/apache/nifi/kafka/service/api/producer/KafkaProducerService.java b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-service-api/src/main/java/org/apache/nifi/kafka/service/api/producer/KafkaProducerService.java
index b4e33115f7..853b146a90 100644
--- a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-service-api/src/main/java/org/apache/nifi/kafka/service/api/producer/KafkaProducerService.java
+++ b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-service-api/src/main/java/org/apache/nifi/kafka/service/api/producer/KafkaProducerService.java
@@ -43,6 +43,7 @@ public interface KafkaProducerService extends Closeable {
* Signal the Kafka `Producer` to close the producer connection. This allows for graceful handling of
* `ControllerService` misconfiguration issues (NIFI-12194).
*/
+ @Override
void close();
/**
diff --git a/nifi-extension-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/PublishMQTT.java b/nifi-extension-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/PublishMQTT.java
index f59e0c1434..3a6ceb0a43 100644
--- a/nifi-extension-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/PublishMQTT.java
+++ b/nifi-extension-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/PublishMQTT.java
@@ -174,6 +174,7 @@ public class PublishMQTT extends AbstractMQTTProcessor {
}
@OnScheduled
+ @Override
public void onScheduled(final ProcessContext context) {
super.onScheduled(context);
}
diff --git a/nifi-extension-bundles/nifi-py4j-extension-bundle/nifi-py4j-bridge/src/main/java/org/apache/nifi/py4j/StandardPythonProcessorBridge.java b/nifi-extension-bundles/nifi-py4j-extension-bundle/nifi-py4j-bridge/src/main/java/org/apache/nifi/py4j/StandardPythonProcessorBridge.java
index 713d12addb..6a05b237d5 100644
--- a/nifi-extension-bundles/nifi-py4j-extension-bundle/nifi-py4j-bridge/src/main/java/org/apache/nifi/py4j/StandardPythonProcessorBridge.java
+++ b/nifi-extension-bundles/nifi-py4j-extension-bundle/nifi-py4j-bridge/src/main/java/org/apache/nifi/py4j/StandardPythonProcessorBridge.java
@@ -94,6 +94,7 @@ public class StandardPythonProcessorBridge implements PythonProcessorBridge {
Thread.ofVirtual().name(threadName).start(() -> initializePythonSide(true, future));
}
+ @Override
public LoadState getLoadState() {
return loadState;
}
diff --git a/nifi-extension-bundles/nifi-py4j-extension-bundle/nifi-py4j-bridge/src/main/java/org/apache/nifi/py4j/client/CommandBuilder.java b/nifi-extension-bundles/nifi-py4j-extension-bundle/nifi-py4j-bridge/src/main/java/org/apache/nifi/py4j/client/CommandBuilder.java
index fa048b3d1a..cdd1fb5c5b 100644
--- a/nifi-extension-bundles/nifi-py4j-extension-bundle/nifi-py4j-bridge/src/main/java/org/apache/nifi/py4j/client/CommandBuilder.java
+++ b/nifi-extension-bundles/nifi-py4j-extension-bundle/nifi-py4j-bridge/src/main/java/org/apache/nifi/py4j/client/CommandBuilder.java
@@ -113,6 +113,7 @@ public class CommandBuilder {
return boundIds;
}
+ @Override
public String toString() {
return "CommandBuilder[objectId=" + objectId + ", methodName=" + methodName + ", boundIds=" + boundIds.size() + "]";
}
diff --git a/nifi-extension-bundles/nifi-py4j-extension-bundle/nifi-py4j-bridge/src/main/java/org/apache/nifi/py4j/server/NiFiGatewayServer.java b/nifi-extension-bundles/nifi-py4j-extension-bundle/nifi-py4j-bridge/src/main/java/org/apache/nifi/py4j/server/NiFiGatewayServer.java
index ae24d499e0..12369e33e4 100644
--- a/nifi-extension-bundles/nifi-py4j-extension-bundle/nifi-py4j-bridge/src/main/java/org/apache/nifi/py4j/server/NiFiGatewayServer.java
+++ b/nifi-extension-bundles/nifi-py4j-extension-bundle/nifi-py4j-bridge/src/main/java/org/apache/nifi/py4j/server/NiFiGatewayServer.java
@@ -60,6 +60,7 @@ public class NiFiGatewayServer extends GatewayServer {
this.contextClassLoader = getClass().getClassLoader();
}
+ @Override
protected Py4JServerConnection createConnection(final Gateway gateway, final Socket socket) throws IOException {
final NiFiGatewayConnection connection = new NiFiGatewayConnection(this, gateway, socket, authToken, Collections.emptyList(), getListeners());
connection.startConnection();
diff --git a/nifi-extension-bundles/nifi-py4j-extension-bundle/nifi-py4j-bridge/src/main/java/org/apache/nifi/python/processor/StandardInputFlowFile.java b/nifi-extension-bundles/nifi-py4j-extension-bundle/nifi-py4j-bridge/src/main/java/org/apache/nifi/python/processor/StandardInputFlowFile.java
index b227a60d09..e797c9ab88 100644
--- a/nifi-extension-bundles/nifi-py4j-extension-bundle/nifi-py4j-bridge/src/main/java/org/apache/nifi/python/processor/StandardInputFlowFile.java
+++ b/nifi-extension-bundles/nifi-py4j-extension-bundle/nifi-py4j-bridge/src/main/java/org/apache/nifi/python/processor/StandardInputFlowFile.java
@@ -38,6 +38,7 @@ public class StandardInputFlowFile implements InputFlowFile, Closeable {
this.flowFile = flowFile;
}
+ @Override
public byte[] getContentsAsBytes() throws IOException {
if (flowFile.getSize() > Integer.MAX_VALUE) {
throw new IOException("Cannot read FlowFile contents into a byte array because size is " + flowFile.getSize() +
@@ -51,6 +52,7 @@ public class StandardInputFlowFile implements InputFlowFile, Closeable {
}
}
+ @Override
public BufferedReader getContentsAsReader() throws IOException {
close();
@@ -67,14 +69,17 @@ public class StandardInputFlowFile implements InputFlowFile, Closeable {
}
}
+ @Override
public long getSize() {
return flowFile.getSize();
}
+ @Override
public String getAttribute(final String name) {
return flowFile.getAttribute(name);
}
+ @Override
public Map<String, String> getAttributes() {
return flowFile.getAttributes();
}
diff --git a/nifi-extension-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/record/script/AbstractScriptedRecordFactory.java b/nifi-extension-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/record/script/AbstractScriptedRecordFactory.java
index 2805f61ca9..37a3addae4 100644
--- a/nifi-extension-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/record/script/AbstractScriptedRecordFactory.java
+++ b/nifi-extension-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/record/script/AbstractScriptedRecordFactory.java
@@ -29,6 +29,7 @@ public abstract class AbstractScriptedRecordFactory<T> extends AbstractScriptedC
protected final AtomicReference<T> recordFactory = new AtomicReference<>();
+ @Override
public void setup() {
if (scriptNeedsReload.get() || recordFactory.get() == null) {
if (ScriptingComponentHelper.isFile(scriptingComponentHelper.getScriptPath())) {
diff --git a/nifi-extension-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/record/script/ScriptedReader.java b/nifi-extension-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/record/script/ScriptedReader.java
index 23253902b8..8abadfec69 100644
--- a/nifi-extension-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/record/script/ScriptedReader.java
+++ b/nifi-extension-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/record/script/ScriptedReader.java
@@ -62,6 +62,7 @@ import java.util.Map;
public class ScriptedReader extends AbstractScriptedRecordFactory<RecordReaderFactory> implements RecordReaderFactory {
@OnEnabled
+ @Override
public void onEnabled(final ConfigurationContext context) {
synchronized (scriptingComponentHelper.isInitialized) {
if (!scriptingComponentHelper.isInitialized.get()) {
@@ -119,6 +120,7 @@ public class ScriptedReader extends AbstractScriptedRecordFactory<RecordReaderFa
* @param scriptBody An input stream associated with the script content
* @return Whether the script was successfully reloaded
*/
+ @Override
protected boolean reloadScript(final String scriptBody) {
// note we are starting here with a fresh listing of validation
// results since we are (re)loading a new/updated script. any
diff --git a/nifi-extension-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/record/sink/script/ScriptedRecordSink.java b/nifi-extension-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/record/sink/script/ScriptedRecordSink.java
index e74748469f..5efb092cd2 100644
--- a/nifi-extension-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/record/sink/script/ScriptedRecordSink.java
+++ b/nifi-extension-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/record/sink/script/ScriptedRecordSink.java
@@ -108,6 +108,7 @@ public class ScriptedRecordSink extends AbstractScriptedControllerService implem
return scriptingComponentHelper.customValidate(validationContext);
}
+ @Override
public void setup() {
if (scriptNeedsReload.get() || recordSink.get() == null) {
if (ScriptingComponentHelper.isFile(scriptingComponentHelper.getScriptPath())) {
@@ -124,6 +125,7 @@ public class ScriptedRecordSink extends AbstractScriptedControllerService implem
* @param scriptBody An input stream associated with the script content
* @return Whether the script was successfully reloaded
*/
+ @Override
protected boolean reloadScript(final String scriptBody) {
// note we are starting here with a fresh listing of validation
// results since we are (re)loading a new/updated script. any
diff --git a/nifi-extension-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/script/impl/BaseScriptRunner.java b/nifi-extension-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/script/impl/BaseScriptRunner.java
index 59b0f8c2dd..8806420856 100644
--- a/nifi-extension-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/script/impl/BaseScriptRunner.java
+++ b/nifi-extension-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/script/impl/BaseScriptRunner.java
@@ -50,6 +50,7 @@ public abstract class BaseScriptRunner implements ScriptRunner {
return scriptEngine;
}
+ @Override
public String getScript() {
return scriptBody;
}
diff --git a/nifi-extension-bundles/nifi-shopify-bundle/nifi-shopify-processors/src/main/java/org/apache/nifi/processors/shopify/GetShopify.java b/nifi-extension-bundles/nifi-shopify-bundle/nifi-shopify-processors/src/main/java/org/apache/nifi/processors/shopify/GetShopify.java
index 2c950cf7a5..1423712e06 100644
--- a/nifi-extension-bundles/nifi-shopify-bundle/nifi-shopify-processors/src/main/java/org/apache/nifi/processors/shopify/GetShopify.java
+++ b/nifi-extension-bundles/nifi-shopify-bundle/nifi-shopify-processors/src/main/java/org/apache/nifi/processors/shopify/GetShopify.java
@@ -235,6 +235,7 @@ public class GetShopify extends AbstractProcessor {
private volatile String resourceName;
private volatile boolean isResetState;
+ @Override
public void onPropertyModified(final PropertyDescriptor descriptor, final String oldValue, final String newValue) {
if (isConfigurationRestored() && RESET_STATE_PROPERTY_NAMES.contains(descriptor.getName())) {
isResetState = true;
diff --git a/nifi-extension-bundles/nifi-slack-bundle/nifi-slack-processors/src/main/java/org/apache/nifi/processors/slack/consume/SlackTimestamp.java b/nifi-extension-bundles/nifi-slack-bundle/nifi-slack-processors/src/main/java/org/apache/nifi/processors/slack/consume/SlackTimestamp.java
index 52892ca160..ea28ca30bd 100644
--- a/nifi-extension-bundles/nifi-slack-bundle/nifi-slack-processors/src/main/java/org/apache/nifi/processors/slack/consume/SlackTimestamp.java
+++ b/nifi-extension-bundles/nifi-slack-bundle/nifi-slack-processors/src/main/java/org/apache/nifi/processors/slack/consume/SlackTimestamp.java
@@ -72,6 +72,7 @@ public class SlackTimestamp implements Comparable<SlackTimestamp> {
return value;
}
+ @Override
public String toString() {
return normalizedValue;
}
diff --git a/nifi-extension-bundles/nifi-smb-bundle/nifi-smb-smbj-common/src/main/java/org/apache/nifi/smb/common/SmbClient.java b/nifi-extension-bundles/nifi-smb-bundle/nifi-smb-smbj-common/src/main/java/org/apache/nifi/smb/common/SmbClient.java
index 92c173c10e..db3af2256f 100644
--- a/nifi-extension-bundles/nifi-smb-bundle/nifi-smb-smbj-common/src/main/java/org/apache/nifi/smb/common/SmbClient.java
+++ b/nifi-extension-bundles/nifi-smb-bundle/nifi-smb-smbj-common/src/main/java/org/apache/nifi/smb/common/SmbClient.java
@@ -65,10 +65,12 @@ class SmbClient extends SMBClient {
return client;
}
+ @Override
public Connection connect(final String hostname) throws IOException {
return connect(hostname, DEFAULT_PORT);
}
+ @Override
public synchronized Connection connect(final String hostname, final int port) throws IOException {
final Connection connection = super.connect(hostname, port);
diff --git a/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/logging/SLF4JLogAdapter.java b/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/logging/SLF4JLogAdapter.java
index 0e1eca2aad..ebb9236017 100644
--- a/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/logging/SLF4JLogAdapter.java
+++ b/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/logging/SLF4JLogAdapter.java
@@ -35,70 +35,83 @@ public class SLF4JLogAdapter implements LogAdapter {
this.logger = logger;
}
+ @Override
public boolean isDebugEnabled() {
return logger.isDebugEnabled();
}
+ @Override
public boolean isInfoEnabled() {
return logger.isInfoEnabled();
}
+ @Override
public boolean isWarnEnabled() {
return logger.isWarnEnabled();
}
-
+ @Override
public void debug(final Serializable message) {
if (isDebugEnabled()) {
logger.debug("{}", message);
}
}
+ @Override
public void info(final CharSequence message) {
if (isInfoEnabled()) {
logger.info("{}", message);
}
}
+ @Override
public void warn(final Serializable message) {
if (isWarnEnabled()) {
logger.warn("{}", message);
}
}
+ @Override
public void error(final Serializable message) {
logger.error("{}", message);
}
+ @Override
public void error(final CharSequence message, final Throwable t) {
logger.error("{}", message, t);
}
+ @Override
public void fatal(final Object message) {
logger.error("{}", message);
}
+ @Override
public void fatal(final CharSequence message, final Throwable t) {
logger.error("{}", message, t);
}
-
+ @Override
public LogLevel getEffectiveLogLevel() {
return LogLevel.ALL;
}
+ @Override
public Iterator<Handler> getLogHandler() {
throw new UnsupportedOperationException("Log handlers are not supported.");
}
+ @Override
public LogLevel getLogLevel() {
return getEffectiveLogLevel();
}
+ @Override
public String getName() {
return logger.getName();
}
+ @Override
public void setLogLevel(final LogLevel logLevel) {
// no need to set log level
}
diff --git a/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/processors/GetSNMP.java b/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/processors/GetSNMP.java
index db40f42981..b57ac33e3b 100644
--- a/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/processors/GetSNMP.java
+++ b/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/processors/GetSNMP.java
@@ -237,6 +237,7 @@ public class GetSNMP extends AbstractSNMPProcessor {
return PROPERTY_DESCRIPTORS;
}
+ @Override
protected String getTargetHost(final ProcessContext processContext, final FlowFile flowFile) {
return processContext.getProperty(AGENT_HOST).evaluateAttributeExpressions(flowFile).getValue();
}
diff --git a/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/processors/SetSNMP.java b/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/processors/SetSNMP.java
index 5f9546b7ba..60c9bae47e 100644
--- a/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/processors/SetSNMP.java
+++ b/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/processors/SetSNMP.java
@@ -137,6 +137,7 @@ public class SetSNMP extends AbstractSNMPProcessor {
return RELATIONSHIPS;
}
+ @Override
protected String getTargetHost(final ProcessContext processContext, final FlowFile flowFile) {
return processContext.getProperty(AGENT_HOST).evaluateAttributeExpressions(flowFile).getValue();
}
diff --git a/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/processors/properties/PrivacyProtocol.java b/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/processors/properties/PrivacyProtocol.java
index 824bd3094f..0bff99998f 100644
--- a/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/processors/properties/PrivacyProtocol.java
+++ b/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/processors/properties/PrivacyProtocol.java
@@ -53,14 +53,17 @@ public enum PrivacyProtocol implements DescribedValue {
this.oid = oid;
}
+ @Override
public String getValue() {
return value;
}
+ @Override
public String getDisplayName() {
return displayName;
}
+ @Override
public String getDescription() {
return description;
}
diff --git a/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/processors/properties/UsmUserInputMethod.java b/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/processors/properties/UsmUserInputMethod.java
index 6fd13dac54..a45b59690b 100644
--- a/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/processors/properties/UsmUserInputMethod.java
+++ b/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/processors/properties/UsmUserInputMethod.java
@@ -34,14 +34,17 @@ public enum UsmUserInputMethod implements DescribedValue {
this.description = description;
}
+ @Override
public String getValue() {
return value;
}
+ @Override
public String getDisplayName() {
return displayName;
}
+ @Override
public String getDescription() {
return description;
}
diff --git a/nifi-extension-bundles/nifi-snowflake-bundle/nifi-snowflake-services/src/main/java/org/apache/nifi/snowflake/service/SnowflakeComputingConnectionPool.java b/nifi-extension-bundles/nifi-snowflake-bundle/nifi-snowflake-services/src/main/java/org/apache/nifi/snowflake/service/SnowflakeComputingConnectionPool.java
index a7e747e26a..1cea59cd01 100644
--- a/nifi-extension-bundles/nifi-snowflake-bundle/nifi-snowflake-services/src/main/java/org/apache/nifi/snowflake/service/SnowflakeComputingConnectionPool.java
+++ b/nifi-extension-bundles/nifi-snowflake-bundle/nifi-snowflake-services/src/main/java/org/apache/nifi/snowflake/service/SnowflakeComputingConnectionPool.java
@@ -207,6 +207,7 @@ public class SnowflakeComputingConnectionPool extends AbstractDBCPConnectionPool
}
@OnEnabled
+ @Override
public void onConfigured(final ConfigurationContext context) throws InitializationException {
super.onConfigured(context);
accessTokenProvider = context.getProperty(ACCESS_TOKEN_PROVIDER).asControllerService(OAuth2AccessTokenProvider.class);
diff --git a/nifi-extension-bundles/nifi-splunk-bundle/nifi-splunk-processors/src/main/java/org/apache/nifi/processors/splunk/QuerySplunkIndexingStatus.java b/nifi-extension-bundles/nifi-splunk-bundle/nifi-splunk-processors/src/main/java/org/apache/nifi/processors/splunk/QuerySplunkIndexingStatus.java
index 12991f8d4f..958535ea0e 100644
--- a/nifi-extension-bundles/nifi-splunk-bundle/nifi-splunk-processors/src/main/java/org/apache/nifi/processors/splunk/QuerySplunkIndexingStatus.java
+++ b/nifi-extension-bundles/nifi-splunk-bundle/nifi-splunk-processors/src/main/java/org/apache/nifi/processors/splunk/QuerySplunkIndexingStatus.java
@@ -139,6 +139,7 @@ public class QuerySplunkIndexingStatus extends SplunkAPICall {
}
@OnScheduled
+ @Override
public void onScheduled(final ProcessContext context) {
super.onScheduled(context);
maxQuerySize = context.getProperty(MAX_QUERY_SIZE).asInteger();
@@ -146,6 +147,7 @@ public class QuerySplunkIndexingStatus extends SplunkAPICall {
}
@OnStopped
+ @Override
public void onStopped() {
super.onStopped();
maxQuerySize = null;
diff --git a/nifi-extension-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/datasources/JvmMetricsDataSource.java b/nifi-extension-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/datasources/JvmMetricsDataSource.java
index 67d8fa9b86..ddcc91054a 100644
--- a/nifi-extension-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/datasources/JvmMetricsDataSource.java
+++ b/nifi-extension-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/datasources/JvmMetricsDataSource.java
@@ -72,6 +72,7 @@ public class JvmMetricsDataSource implements ResettableDataSource {
return value.replaceAll("[ -.]", "_");
}
+ @Override
public NiFiTableSchema getSchema() {
return schema;
}
diff --git a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AbstractDatabaseFetchProcessor.java b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AbstractDatabaseFetchProcessor.java
index 82de0993a4..38d613d0a1 100644
--- a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AbstractDatabaseFetchProcessor.java
+++ b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AbstractDatabaseFetchProcessor.java
@@ -219,6 +219,7 @@ public abstract class AbstractDatabaseFetchProcessor extends AbstractSessionFact
protected Map<String, String> maxValueProperties;
// A common validation procedure for DB fetch processors, it stores whether the Table Name and/or Max Value Column properties have expression language
+ @Override
protected Collection<ValidationResult> customValidate(ValidationContext validationContext) {
// For backwards-compatibility, keep track of whether the table name and max-value column properties are dynamic (i.e. has expression language)
isDynamicTableName = validationContext.isExpressionLanguagePresent(validationContext.getProperty(TABLE_NAME).getValue());
diff --git a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CalculateRecordStats.java b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CalculateRecordStats.java
index 4999c833fe..c146c1a943 100644
--- a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CalculateRecordStats.java
+++ b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CalculateRecordStats.java
@@ -119,6 +119,7 @@ public class CalculateRecordStats extends AbstractProcessor {
private RecordPathCache cache;
+ @Override
protected PropertyDescriptor getSupportedDynamicPropertyDescriptor(final String propertyDescriptorName) {
return new PropertyDescriptor.Builder()
.name(propertyDescriptorName)
diff --git a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/enrichment/WrapperJoinStrategy.java b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/enrichment/WrapperJoinStrategy.java
index dc23a9e4a3..88a1291432 100644
--- a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/enrichment/WrapperJoinStrategy.java
+++ b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/enrichment/WrapperJoinStrategy.java
@@ -52,6 +52,7 @@ public class WrapperJoinStrategy extends IndexCorrelatedJoinStrategy {
return wrapped;
}
+ @Override
protected RecordSchema createResultSchema(final Record firstOriginalRecord, final Record firstEnrichmentRecord) {
final List<RecordField> fields = new ArrayList<>();
diff --git a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ftp/commands/FtpCommandHELP.java b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ftp/commands/FtpCommandHELP.java
index 4a3f921657..0570ca5eb2 100644
--- a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ftp/commands/FtpCommandHELP.java
+++ b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ftp/commands/FtpCommandHELP.java
@@ -82,6 +82,7 @@ public class FtpCommandHELP extends AbstractCommand {
}
}
+ @Override
public void execute(final FtpIoSession session,
final FtpServerContext context, final FtpRequest request) {
// reset state variables
diff --git a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ftp/filesystem/VirtualPath.java b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ftp/filesystem/VirtualPath.java
index b7247167be..ecd8d1870d 100644
--- a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ftp/filesystem/VirtualPath.java
+++ b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ftp/filesystem/VirtualPath.java
@@ -70,6 +70,7 @@ public class VirtualPath {
return new VirtualPath(path.resolve(otherPath).normalize().toString());
}
+ @Override
public String toString() {
return path.toString();
}
diff --git a/nifi-extension-bundles/nifi-standard-services/nifi-hadoop-dbcp-service-bundle/nifi-hadoop-dbcp-service/src/main/java/org/apache/nifi/dbcp/HadoopDBCPConnectionPool.java b/nifi-extension-bundles/nifi-standard-services/nifi-hadoop-dbcp-service-bundle/nifi-hadoop-dbcp-service/src/main/java/org/apache/nifi/dbcp/HadoopDBCPConnectionPool.java
index 65ddba07b3..46deebfad5 100644
--- a/nifi-extension-bundles/nifi-standard-services/nifi-hadoop-dbcp-service-bundle/nifi-hadoop-dbcp-service/src/main/java/org/apache/nifi/dbcp/HadoopDBCPConnectionPool.java
+++ b/nifi-extension-bundles/nifi-standard-services/nifi-hadoop-dbcp-service-bundle/nifi-hadoop-dbcp-service/src/main/java/org/apache/nifi/dbcp/HadoopDBCPConnectionPool.java
@@ -250,6 +250,7 @@ public class HadoopDBCPConnectionPool extends AbstractDBCPConnectionPool {
* @throws SQLException if there is an error while closing open connections
*/
@OnDisabled
+ @Override
public void shutdown() throws SQLException {
validationResourceHolder.set(null);
foundHadoopDependencies = null;
diff --git a/nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/NonCachingDatumReader.java b/nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/NonCachingDatumReader.java
index fa4ab7d306..11f39ff512 100644
--- a/nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/NonCachingDatumReader.java
+++ b/nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/NonCachingDatumReader.java
@@ -54,6 +54,7 @@ public class NonCachingDatumReader<T> extends GenericDatumReader<T> {
return newInstanceFromString(stringClass, in.readString());
}
+ @Override
protected Class findStringClass(Schema schema) {
final String name = schema.getProp(GenericData.STRING_PROP);
if ("String".equals(name)) {
diff --git a/nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/json/JsonTreeReader.java b/nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/json/JsonTreeReader.java
index bdc649122c..ff3088806b 100644
--- a/nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/json/JsonTreeReader.java
+++ b/nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/json/JsonTreeReader.java
@@ -189,6 +189,7 @@ public class JsonTreeReader extends SchemaRegistryService implements RecordReade
return INFER_SCHEMA;
}
+ @Override
public RecordReader createRecordReader(final Map<String, String> variables, final InputStream in, final long inputLength, final ComponentLog logger)
throws IOException, MalformedRecordException, SchemaNotFoundException {
final RecordSchema schema = getSchema(variables, in, null);
diff --git a/nifi-extension-bundles/nifi-standard-services/nifi-record-sink-service-bundle/nifi-record-sink-service/src/test/java/org/apache/nifi/record/sink/TestHttpRecordSink.java b/nifi-extension-bundles/nifi-standard-services/nifi-record-sink-service-bundle/nifi-record-sink-service/src/test/java/org/apache/nifi/record/sink/TestHttpRecordSink.java
index 5c8bd6cccb..8e33144c48 100644
--- a/nifi-extension-bundles/nifi-standard-services/nifi-record-sink-service-bundle/nifi-record-sink-service/src/test/java/org/apache/nifi/record/sink/TestHttpRecordSink.java
+++ b/nifi-extension-bundles/nifi-standard-services/nifi-record-sink-service-bundle/nifi-record-sink-service/src/test/java/org/apache/nifi/record/sink/TestHttpRecordSink.java
@@ -296,6 +296,7 @@ public class TestHttpRecordSink {
&& active == record.getAsBoolean(ACTIVE);
}
+ @Override
public String toString() {
return ID + "=" + id + ", " + NAME + "=" + name + ", " + ACTIVE + "=" + active;
}
diff --git a/nifi-framework-api/src/main/java/org/apache/nifi/authentication/LoginIdentityProviderConfigurationContext.java b/nifi-framework-api/src/main/java/org/apache/nifi/authentication/LoginIdentityProviderConfigurationContext.java
index 69c1f8737a..df2f0c0f51 100644
--- a/nifi-framework-api/src/main/java/org/apache/nifi/authentication/LoginIdentityProviderConfigurationContext.java
+++ b/nifi-framework-api/src/main/java/org/apache/nifi/authentication/LoginIdentityProviderConfigurationContext.java
@@ -27,6 +27,7 @@ public interface LoginIdentityProviderConfigurationContext extends NonComponentC
/**
* @return identifier for the authority provider
*/
+ @Override
String getIdentifier();
/**
@@ -37,6 +38,7 @@ public interface LoginIdentityProviderConfigurationContext extends NonComponentC
*
* @return Map of all properties
*/
+ @Override
Map<String, String> getProperties();
/**
@@ -45,5 +47,6 @@ public interface LoginIdentityProviderConfigurationContext extends NonComponentC
* @param property the property to retrieve
* @return the current property value (can be null)
*/
+ @Override
String getProperty(String property);
}
diff --git a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/index/lucene/LuceneEventIndex.java b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/index/lucene/LuceneEventIndex.java
index e4dccef4e1..8986b653cf 100644
--- a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/index/lucene/LuceneEventIndex.java
+++ b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/index/lucene/LuceneEventIndex.java
@@ -350,6 +350,7 @@ public class LuceneEventIndex implements EventIndex {
return -1L;
}
+ @Override
public boolean isReindexNecessary() {
// If newest index is defunct, there's no reason to re-index, as it will happen in the background thread
logger.info("Will avoid re-indexing Provenance Events because the newest index is defunct, so it will be re-indexed in the background");
diff --git a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/store/RecordWriterLease.java b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/store/RecordWriterLease.java
index eab4383f3a..137457a3c6 100644
--- a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/store/RecordWriterLease.java
+++ b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/store/RecordWriterLease.java
@@ -126,6 +126,7 @@ public class RecordWriterLease {
}
}
+ @Override
public String toString() {
// Call super.toString() so that we have a unique hash/address added to the toString, but also include the file being written to.
// When comparing the toString() of two different leases, this helps to compare whether or not the two leases are the same object
diff --git a/nifi-framework-bundle/nifi-framework-extensions/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/DatabaseManager.java b/nifi-framework-bundle/nifi-framework-extensions/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/DatabaseManager.java
index ef2124b7fc..1293e3e348 100644
--- a/nifi-framework-bundle/nifi-framework-extensions/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/DatabaseManager.java
+++ b/nifi-framework-bundle/nifi-framework-extensions/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/DatabaseManager.java
@@ -36,5 +36,6 @@ public interface DatabaseManager extends Closeable {
/**
* Finishes maintenance of the database. After calling, manager does not guarantee any connection with the database.
*/
+ @Override
void close();
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/dto/ComponentReferenceDTO.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/dto/ComponentReferenceDTO.java
index 0dccab0474..cac1c89bfb 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/dto/ComponentReferenceDTO.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/dto/ComponentReferenceDTO.java
@@ -37,10 +37,12 @@ public class ComponentReferenceDTO extends ComponentDTO {
*/
@Schema(description = "The id of the component."
)
+ @Override
public String getId() {
return this.id;
}
+ @Override
public void setId(final String id) {
this.id = id;
}
@@ -50,10 +52,12 @@ public class ComponentReferenceDTO extends ComponentDTO {
*/
@Schema(description = "The id of parent process group of this component if applicable."
)
+ @Override
public String getParentGroupId() {
return parentGroupId;
}
+ @Override
public void setParentGroupId(String parentGroupId) {
this.parentGroupId = parentGroupId;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/dto/SystemDiagnosticsSnapshotDTO.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/dto/SystemDiagnosticsSnapshotDTO.java
index 028c2dbd0f..5e5f95dc8c 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/dto/SystemDiagnosticsSnapshotDTO.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/dto/SystemDiagnosticsSnapshotDTO.java
@@ -606,6 +606,7 @@ public class SystemDiagnosticsSnapshotDTO implements Cloneable {
this.writable = writable;
}
+ @Override
public ResourceClaimDetailsDTO clone() {
final ResourceClaimDetailsDTO other = new ResourceClaimDetailsDTO();
other.setContainer(getContainer());
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/AccessPolicyEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/AccessPolicyEntity.java
index 2558b4e5fb..b67691a85b 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/AccessPolicyEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/AccessPolicyEntity.java
@@ -38,10 +38,12 @@ public class AccessPolicyEntity extends ComponentEntity implements Permissible<A
*
* @return The {@link AccessPolicyDTO} object
*/
+ @Override
public AccessPolicyDTO getComponent() {
return component;
}
+ @Override
public void setComponent(AccessPolicyDTO component) {
this.component = component;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ComponentValidationResultEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ComponentValidationResultEntity.java
index bc223b31ae..fccf2f3723 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ComponentValidationResultEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ComponentValidationResultEntity.java
@@ -27,10 +27,12 @@ public class ComponentValidationResultEntity extends ComponentEntity implements
/**
* @return variable referencing components that is being serialized
*/
+ @Override
public ComponentValidationResultDTO getComponent() {
return validationResult;
}
+ @Override
public void setComponent(ComponentValidationResultDTO component) {
this.validationResult = component;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ConnectionEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ConnectionEntity.java
index 5e0507dc85..5b19767a91 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ConnectionEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ConnectionEntity.java
@@ -45,10 +45,12 @@ public class ConnectionEntity extends ComponentEntity implements Permissible<Con
/**
* @return RelationshipDTO that is being serialized
*/
+ @Override
public ConnectionDTO getComponent() {
return component;
}
+ @Override
public void setComponent(ConnectionDTO component) {
this.component = component;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ControllerConfigurationEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ControllerConfigurationEntity.java
index 0221d9d2ab..9aa0f0934e 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ControllerConfigurationEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ControllerConfigurationEntity.java
@@ -56,12 +56,13 @@ public class ControllerConfigurationEntity extends Entity implements Permissible
*
* @return The ControllerConfigurationDTO object
*/
- @Schema(description = "The controller configuration."
- )
+ @Schema(description = "The controller configuration.")
+ @Override
public ControllerConfigurationDTO getComponent() {
return controllerConfiguration;
}
+ @Override
public void setComponent(ControllerConfigurationDTO controllerConfiguration) {
this.controllerConfiguration = controllerConfiguration;
}
@@ -71,12 +72,13 @@ public class ControllerConfigurationEntity extends Entity implements Permissible
*
* @return The permissions
*/
- @Schema(description = "The permissions for this component."
- )
+ @Schema(description = "The permissions for this component.")
+ @Override
public PermissionsDTO getPermissions() {
return permissions;
}
+ @Override
public void setPermissions(PermissionsDTO permissions) {
this.permissions = permissions;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ControllerServiceEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ControllerServiceEntity.java
index 3910671f8b..4b15333d76 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ControllerServiceEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ControllerServiceEntity.java
@@ -50,10 +50,12 @@ public class ControllerServiceEntity extends ComponentEntity implements Permissi
/**
* @return controller service that is being serialized
*/
+ @Override
public ControllerServiceDTO getComponent() {
return component;
}
+ @Override
public void setComponent(ControllerServiceDTO component) {
this.component = component;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ControllerServiceRunStatusEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ControllerServiceRunStatusEntity.java
index 42e6248559..5439d1c8ab 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ControllerServiceRunStatusEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ControllerServiceRunStatusEntity.java
@@ -39,8 +39,8 @@ public class ControllerServiceRunStatusEntity extends ComponentRunStatusEntity {
* @return The run status
*/
@Schema(description = "The run status of the ControllerService.",
- allowableValues = {"ENABLED", "DISABLED"}
- )
+ allowableValues = {"ENABLED", "DISABLED"})
+ @Override
public String getState() {
return super.getState();
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/FlowAnalysisRuleRunStatusEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/FlowAnalysisRuleRunStatusEntity.java
index 6b00f5c6f0..936da36ae8 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/FlowAnalysisRuleRunStatusEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/FlowAnalysisRuleRunStatusEntity.java
@@ -38,8 +38,8 @@ public class FlowAnalysisRuleRunStatusEntity extends ComponentRunStatusEntity {
* @return The state
*/
@Schema(description = "The state of the FlowAnalysisRule.",
- allowableValues = {"ENABLED", "DISABLED"}
- )
+ allowableValues = {"ENABLED", "DISABLED"})
+ @Override
public String getState() {
return super.getState();
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/FlowRegistryClientEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/FlowRegistryClientEntity.java
index 2745064a85..e024803eb1 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/FlowRegistryClientEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/FlowRegistryClientEntity.java
@@ -30,10 +30,12 @@ public class FlowRegistryClientEntity extends ComponentEntity implements Permiss
private FlowRegistryClientDTO registry;
private PermissionsDTO operatePermissions;
+ @Override
public FlowRegistryClientDTO getComponent() {
return registry;
}
+ @Override
public void setComponent(FlowRegistryClientDTO component) {
this.registry = component;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/FunnelEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/FunnelEntity.java
index aa13122676..93c7d834da 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/FunnelEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/FunnelEntity.java
@@ -32,10 +32,12 @@ public class FunnelEntity extends ComponentEntity implements Permissible<FunnelD
*
* @return The FunnelDTO object
*/
+ @Override
public FunnelDTO getComponent() {
return component;
}
+ @Override
public void setComponent(FunnelDTO component) {
this.component = component;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/LabelEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/LabelEntity.java
index b94165e4f6..a31d01fb9a 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/LabelEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/LabelEntity.java
@@ -37,10 +37,12 @@ public class LabelEntity extends ComponentEntity implements Permissible<LabelDTO
*
* @return The LabelDTO object
*/
+ @Override
public LabelDTO getComponent() {
return component;
}
+ @Override
public void setComponent(LabelDTO component) {
this.component = component;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ParameterContextReferenceEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ParameterContextReferenceEntity.java
index d0f8410860..53802b626e 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ParameterContextReferenceEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ParameterContextReferenceEntity.java
@@ -52,12 +52,13 @@ public class ParameterContextReferenceEntity implements Permissible<ParameterCon
*
* @return The permissions
*/
- @Schema(description = "The permissions for this component."
- )
+ @Schema(description = "The permissions for this component.")
+ @Override
public PermissionsDTO getPermissions() {
return permissions;
}
+ @Override
public void setPermissions(PermissionsDTO permissions) {
this.permissions = permissions;
}
@@ -67,10 +68,12 @@ public class ParameterContextReferenceEntity implements Permissible<ParameterCon
*
* @return The ParameterContextReferenceDTO object
*/
+ @Override
public ParameterContextReferenceDTO getComponent() {
return component;
}
+ @Override
public void setComponent(ParameterContextReferenceDTO component) {
this.component = component;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ParameterProviderConfigurationEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ParameterProviderConfigurationEntity.java
index e36a14ecd0..1d46ca8aea 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ParameterProviderConfigurationEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ParameterProviderConfigurationEntity.java
@@ -53,12 +53,13 @@ public class ParameterProviderConfigurationEntity implements Permissible<Paramet
*
* @return The permissions
*/
- @Schema(description = "The permissions for this component."
- )
+ @Schema(description = "The permissions for this component.")
+ @Override
public PermissionsDTO getPermissions() {
return permissions;
}
+ @Override
public void setPermissions(PermissionsDTO permissions) {
this.permissions = permissions;
}
@@ -68,10 +69,12 @@ public class ParameterProviderConfigurationEntity implements Permissible<Paramet
*
* @return The ParameterProviderConfigurationDTO object
*/
+ @Override
public ParameterProviderConfigurationDTO getComponent() {
return component;
}
+ @Override
public void setComponent(ParameterProviderConfigurationDTO component) {
this.component = component;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/PortRunStatusEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/PortRunStatusEntity.java
index 1973f7869b..c416865a7d 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/PortRunStatusEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/PortRunStatusEntity.java
@@ -38,8 +38,8 @@ public class PortRunStatusEntity extends ComponentRunStatusEntity {
* @return The run status
*/
@Schema(description = "The run status of the Port.",
- allowableValues = {"RUNNING", "STOPPED", "DISABLED"}
- )
+ allowableValues = {"RUNNING", "STOPPED", "DISABLED"})
+ @Override
public String getState() {
return super.getState();
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ProcessGroupReplaceRequestEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ProcessGroupReplaceRequestEntity.java
index 109f873b40..70dbc5d401 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ProcessGroupReplaceRequestEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ProcessGroupReplaceRequestEntity.java
@@ -48,6 +48,7 @@ public class ProcessGroupReplaceRequestEntity extends FlowUpdateRequestEntity<Pr
return request;
}
+ @Override
public void setRequest(ProcessGroupReplaceRequestDTO request) {
this.request = request;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ProcessorEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ProcessorEntity.java
index 3012d98599..3d1e5dcdc0 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ProcessorEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ProcessorEntity.java
@@ -39,10 +39,12 @@ public class ProcessorEntity extends ComponentEntity implements Permissible<Proc
*
* @return The ProcessorDTO object
*/
+ @Override
public ProcessorDTO getComponent() {
return component;
}
+ @Override
public void setComponent(ProcessorDTO component) {
this.component = component;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ProcessorRunStatusEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ProcessorRunStatusEntity.java
index 732b5013c1..247aa3378c 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ProcessorRunStatusEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ProcessorRunStatusEntity.java
@@ -38,6 +38,7 @@ public class ProcessorRunStatusEntity extends ComponentRunStatusEntity {
* @return The run status
*/
@Schema(description = "The run status of the Processor.", allowableValues = {"RUNNING", "STOPPED", "DISABLED", "RUN_ONCE"})
+ @Override
public String getState() {
return super.getState();
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/RemotePortRunStatusEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/RemotePortRunStatusEntity.java
index 8ee5f8e4e5..67504dd322 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/RemotePortRunStatusEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/RemotePortRunStatusEntity.java
@@ -38,8 +38,8 @@ public class RemotePortRunStatusEntity extends ComponentRunStatusEntity {
* @return The run status
*/
@Schema(description = "The run status of the RemotePort.",
- allowableValues = {"TRANSMITTING", "STOPPED"}
- )
+ allowableValues = {"TRANSMITTING", "STOPPED"})
+ @Override
public String getState() {
return super.getState();
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/RemoteProcessGroupEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/RemoteProcessGroupEntity.java
index 04d1aaf6f6..2a343cc144 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/RemoteProcessGroupEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/RemoteProcessGroupEntity.java
@@ -42,10 +42,12 @@ public class RemoteProcessGroupEntity extends ComponentEntity implements Permiss
*
* @return The RemoteProcessGroupDTO object
*/
+ @Override
public RemoteProcessGroupDTO getComponent() {
return component;
}
+ @Override
public void setComponent(RemoteProcessGroupDTO component) {
this.component = component;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ReportingTaskRunStatusEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ReportingTaskRunStatusEntity.java
index 9e94f3c330..77cfa3d12e 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ReportingTaskRunStatusEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/ReportingTaskRunStatusEntity.java
@@ -38,8 +38,8 @@ public class ReportingTaskRunStatusEntity extends ComponentRunStatusEntity {
* @return The run status
*/
@Schema(description = "The run status of the ReportingTask.",
- allowableValues = {"RUNNING", "STOPPED"}
- )
+ allowableValues = {"RUNNING", "STOPPED"})
+ @Override
public String getState() {
return super.getState();
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/UserEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/UserEntity.java
index 3b6dcb5238..f880a1906c 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/UserEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/UserEntity.java
@@ -33,10 +33,12 @@ public class UserEntity extends ComponentEntity implements Permissible<UserDTO>
*
* @return The UserDTO object
*/
+ @Override
public UserDTO getComponent() {
return component;
}
+ @Override
public void setComponent(UserDTO component) {
this.component = component;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/UserGroupEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/UserGroupEntity.java
index b4543f6c5b..c269e381a4 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/UserGroupEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/UserGroupEntity.java
@@ -33,10 +33,12 @@ public class UserGroupEntity extends ComponentEntity implements Permissible<User
*
* @return The UserGroupDTO object
*/
+ @Override
public UserGroupDTO getComponent() {
return component;
}
+ @Override
public void setComponent(UserGroupDTO component) {
this.component = component;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/VersionedFlowUpdateRequestEntity.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/VersionedFlowUpdateRequestEntity.java
index 1bf3a23ecb..87fe98e595 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/VersionedFlowUpdateRequestEntity.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/entity/VersionedFlowUpdateRequestEntity.java
@@ -26,6 +26,7 @@ import jakarta.xml.bind.annotation.XmlRootElement;
public class VersionedFlowUpdateRequestEntity extends FlowUpdateRequestEntity<VersionedFlowUpdateRequestDTO> {
@Schema(description = "The Flow Update Request")
+ @Override
public VersionedFlowUpdateRequestDTO getRequest() {
if (request == null) {
request = new VersionedFlowUpdateRequestDTO();
@@ -33,6 +34,7 @@ public class VersionedFlowUpdateRequestEntity extends FlowUpdateRequestEntity<Ve
return request;
}
+ @Override
public void setRequest(VersionedFlowUpdateRequestDTO request) {
this.request = request;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-flowfile-repo-serialization/src/main/java/org/apache/nifi/controller/repository/RepositoryRecordSerdeFactory.java b/nifi-framework-bundle/nifi-framework/nifi-flowfile-repo-serialization/src/main/java/org/apache/nifi/controller/repository/RepositoryRecordSerdeFactory.java
index c0886cd3fd..d84e410c15 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-flowfile-repo-serialization/src/main/java/org/apache/nifi/controller/repository/RepositoryRecordSerdeFactory.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-flowfile-repo-serialization/src/main/java/org/apache/nifi/controller/repository/RepositoryRecordSerdeFactory.java
@@ -19,5 +19,6 @@ package org.apache.nifi.controller.repository;
import org.wali.SerDeFactory;
public interface RepositoryRecordSerdeFactory extends SerDeFactory<SerializedRepositoryRecord> {
+ @Override
Long getRecordIdentifier(SerializedRepositoryRecord record);
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-authorization-providers/src/main/java/org/apache/nifi/authorization/StandardAuthorizerInitializationContext.java b/nifi-framework-bundle/nifi-framework/nifi-framework-authorization-providers/src/main/java/org/apache/nifi/authorization/StandardAuthorizerInitializationContext.java
index 58343e8e4d..b602c9137a 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-authorization-providers/src/main/java/org/apache/nifi/authorization/StandardAuthorizerInitializationContext.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-authorization-providers/src/main/java/org/apache/nifi/authorization/StandardAuthorizerInitializationContext.java
@@ -39,6 +39,7 @@ public class StandardAuthorizerInitializationContext implements AuthorizerInitia
return identifier;
}
+ @Override
public AuthorizerLookup getAuthorizerLookup() {
return authorizerLookup;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/coordination/node/NodeClusterCoordinator.java b/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/coordination/node/NodeClusterCoordinator.java
index a7bd5ed335..30cf38bcf3 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/coordination/node/NodeClusterCoordinator.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/coordination/node/NodeClusterCoordinator.java
@@ -233,7 +233,7 @@ public class NodeClusterCoordinator implements ClusterCoordinator, ProtocolHandl
}
}
-
+ @Override
public void registerEventListener(final ClusterTopologyEventListener eventListener) {
this.eventListeners.add(eventListener);
}
@@ -1050,6 +1050,7 @@ public class NodeClusterCoordinator implements ClusterCoordinator, ProtocolHandl
return future;
}
+ @Override
public void validateHeartbeat(final NodeHeartbeat heartbeat) {
final long localUpdateCount = revisionManager.getRevisionUpdateCount();
final long nodeUpdateCount = heartbeat.getRevisionUpdateCount();
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/AccessPolicyEntityMerger.java b/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/AccessPolicyEntityMerger.java
index 88a0faf709..46fc964f35 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/AccessPolicyEntityMerger.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/AccessPolicyEntityMerger.java
@@ -38,6 +38,7 @@ public class AccessPolicyEntityMerger implements ComponentEntityMerger<AccessPol
* @param clientEntity the entity being returned to the client
* @param entityMap all node responses
*/
+ @Override
public void mergeComponents(final AccessPolicyEntity clientEntity, final Map<NodeIdentifier, AccessPolicyEntity> entityMap) {
final AccessPolicyDTO clientDto = clientEntity.getComponent();
final Map<NodeIdentifier, AccessPolicyDTO> dtoMap = new HashMap<>();
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/UserEntityMerger.java b/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/UserEntityMerger.java
index e1e3fcc417..e1cbf135d6 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/UserEntityMerger.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/UserEntityMerger.java
@@ -40,6 +40,7 @@ public class UserEntityMerger implements ComponentEntityMerger<UserEntity> {
* @param clientEntity the entity being returned to the client
* @param entityMap all node responses
*/
+ @Override
public void mergeComponents(final UserEntity clientEntity, final Map<NodeIdentifier, UserEntity> entityMap) {
final UserDTO clientDto = clientEntity.getComponent();
final Map<NodeIdentifier, UserDTO> dtoMap = new HashMap<>();
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/UserGroupEntityMerger.java b/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/UserGroupEntityMerger.java
index 8142b4515a..679668c8b1 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/UserGroupEntityMerger.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/UserGroupEntityMerger.java
@@ -39,6 +39,7 @@ public class UserGroupEntityMerger implements ComponentEntityMerger<UserGroupEnt
* @param clientEntity the entity being returned to the client
* @param entityMap all node responses
*/
+ @Override
public void mergeComponents(final UserGroupEntity clientEntity, final Map<NodeIdentifier, UserGroupEntity> entityMap) {
final UserGroupDTO clientDto = clientEntity.getComponent();
final Map<NodeIdentifier, UserGroupDTO> dtoMap = new HashMap<>();
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/flowanalysis/AbstractFlowAnalysisRuleNode.java b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/flowanalysis/AbstractFlowAnalysisRuleNode.java
index 52bed5dd1b..258752045a 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/flowanalysis/AbstractFlowAnalysisRuleNode.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/flowanalysis/AbstractFlowAnalysisRuleNode.java
@@ -366,6 +366,7 @@ public abstract class AbstractFlowAnalysisRuleNode extends AbstractComponentNode
return results;
}
+ @Override
public Optional<ProcessGroup> getParentProcessGroup() {
return Optional.empty();
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/repository/metrics/StandardFlowFileEvent.java b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/repository/metrics/StandardFlowFileEvent.java
index d43d5afb1c..c800f63ea8 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/repository/metrics/StandardFlowFileEvent.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/repository/metrics/StandardFlowFileEvent.java
@@ -161,6 +161,7 @@ public final class StandardFlowFileEvent implements FlowFileEvent, Cloneable {
this.sessionCommitNanos = nanos;
}
+ @Override
public long getGargeCollectionMillis() {
return gcMillis;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/service/StandardControllerServiceNode.java b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/service/StandardControllerServiceNode.java
index 28fe1665c4..0904b85665 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/service/StandardControllerServiceNode.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/service/StandardControllerServiceNode.java
@@ -246,6 +246,7 @@ public class StandardControllerServiceNode extends AbstractComponentNode impleme
return processGroup;
}
+ @Override
public Optional<ProcessGroup> getParentProcessGroup() {
return Optional.ofNullable(this.processGroup);
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/service/StandardControllerServiceProvider.java b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/service/StandardControllerServiceProvider.java
index 0629458332..ee9c2400c3 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/service/StandardControllerServiceProvider.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/service/StandardControllerServiceProvider.java
@@ -109,6 +109,7 @@ public class StandardControllerServiceProvider implements ControllerServiceProvi
return scheduleReferencingComponents(serviceNode, null, new DefaultComponentScheduler(this, VersionedComponentStateLookup.IDENTITY_LOOKUP));
}
+ @Override
public Set<ComponentNode> scheduleReferencingComponents(final ControllerServiceNode serviceNode, final Set<ComponentNode> candidates, final ComponentScheduler componentScheduler) {
// find all of the schedulable components (processors, reporting tasks) that refer to this Controller Service,
// or a service that references this controller service, etc.
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/DefaultComponentScheduler.java b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/DefaultComponentScheduler.java
index 89be54a068..77ab6c131a 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/DefaultComponentScheduler.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/DefaultComponentScheduler.java
@@ -62,10 +62,12 @@ public class DefaultComponentScheduler extends AbstractComponentScheduler {
}
}
+ @Override
protected void startNow(final ReportingTaskNode reportingTask) {
reportingTask.start();
}
+ @Override
protected void startNow(final ProcessGroup statelessGroup) {
statelessGroup.startProcessing();
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/StandardDataValve.java b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/StandardDataValve.java
index 2f917bee17..518e73f88a 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/StandardDataValve.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/StandardDataValve.java
@@ -353,6 +353,7 @@ public class StandardDataValve implements DataValve {
}
}
+ @Override
public String toString() {
return "StandardDataValve[group=" + processGroup + "]";
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/StandardProcessGroup.java b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/StandardProcessGroup.java
index 426b30c2cf..cc1928a070 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/StandardProcessGroup.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/StandardProcessGroup.java
@@ -4364,6 +4364,7 @@ public final class StandardProcessGroup implements ProcessGroup {
}
}
+ @Override
public ExecutionEngine getExecutionEngine() {
return executionEngine;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/components/validation/ValidationState.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/components/validation/ValidationState.java
index 0f8f57f958..22aab7099e 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/components/validation/ValidationState.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/components/validation/ValidationState.java
@@ -38,6 +38,7 @@ public class ValidationState {
return validationErrors;
}
+ @Override
public String toString() {
return status.toString();
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/connectable/Connectable.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/connectable/Connectable.java
index 4ee4fa4f1b..e68a79238b 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/connectable/Connectable.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/connectable/Connectable.java
@@ -146,6 +146,7 @@ public interface Connectable extends Triggerable, ComponentAuthorizable, Positio
/**
* @return the ProcessGroup to which this <code>Connectable</code> belongs
*/
+ @Override
ProcessGroup getProcessGroup();
/**
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/AbstractComponentNode.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/AbstractComponentNode.java
index 6185285370..207b563830 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/AbstractComponentNode.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/AbstractComponentNode.java
@@ -379,6 +379,7 @@ public abstract class AbstractComponentNode implements ComponentNode {
return getClassLoaderIsolationKey(validationContext);
}
+ @Override
public void verifyCanUpdateProperties(final Map<String, String> properties) {
verifyModifiable();
@@ -644,6 +645,7 @@ public abstract class AbstractComponentNode implements ComponentNode {
return true;
}
+ @Override
public Map<PropertyDescriptor, PropertyConfiguration> getProperties() {
try (final NarCloseable ignored = NarCloseable.withComponentNarLoader(extensionManager, getComponent().getClass(), getIdentifier())) {
final List<PropertyDescriptor> supported = getComponent().getPropertyDescriptors();
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/AbstractPort.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/AbstractPort.java
index 3d44d0d64f..ae6f8f9071 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/AbstractPort.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/AbstractPort.java
@@ -733,6 +733,7 @@ public abstract class AbstractPort implements Port {
return portFunction.get();
}
+ @Override
public void setPortFunction(final PortFunction portFunction) {
this.portFunction.set(requireNonNull(portFunction));
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/service/ControllerServiceNode.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/service/ControllerServiceNode.java
index b34da76f59..a1d2ee31b1 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/service/ControllerServiceNode.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/service/ControllerServiceNode.java
@@ -44,6 +44,7 @@ public interface ControllerServiceNode extends ComponentNode, VersionedComponent
* @return the Process Group that this Controller Service belongs to, or <code>null</code> if the Controller Service
* does not belong to any Process Group
*/
+ @Override
ProcessGroup getProcessGroup();
/**
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/groups/AbstractComponentScheduler.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/groups/AbstractComponentScheduler.java
index d04c4ab16e..facb6c3015 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/groups/AbstractComponentScheduler.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/groups/AbstractComponentScheduler.java
@@ -215,6 +215,7 @@ public abstract class AbstractComponentScheduler implements ComponentScheduler {
return serviceProvider;
}
+ @Override
public void startReportingTask(final ReportingTaskNode reportingTask) {
if (isPaused()) {
logger.debug("{} called to start {} but paused so will queue it for start later", this, reportingTask);
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/groups/ComponentScheduler.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/groups/ComponentScheduler.java
index 3f6977dcb2..f471d8e6ab 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/groups/ComponentScheduler.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/groups/ComponentScheduler.java
@@ -67,6 +67,7 @@ public interface ComponentScheduler {
public void disableControllerServicesAsync(final Collection<ControllerServiceNode> controllerServices) {
}
+ @Override
public void startReportingTask(final ReportingTaskNode reportingTask) {
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/groups/StatelessGroupNode.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/groups/StatelessGroupNode.java
index 0e361f7406..94ae807704 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/groups/StatelessGroupNode.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/groups/StatelessGroupNode.java
@@ -32,6 +32,7 @@ public interface StatelessGroupNode extends Connectable {
void initialize(StatelessGroupNodeInitializationContext initializationContext);
+ @Override
ProcessGroup getProcessGroup();
void start(ScheduledExecutorService executorService, SchedulingAgentCallback schedulingAgentCallback, LifecycleState lifecycleState);
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/parameter/ParameterContext.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/parameter/ParameterContext.java
index 7177bbbed6..7323db1718 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/parameter/ParameterContext.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/parameter/ParameterContext.java
@@ -28,6 +28,7 @@ public interface ParameterContext extends ParameterLookup, ComponentAuthorizable
/**
* @return the UUID for this Parameter Context
*/
+ @Override
String getIdentifier();
/**
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
index adf9d66243..a937602ba6 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
@@ -1472,6 +1472,7 @@ public class FlowController implements ReportingTaskProvider, FlowAnalysisRulePr
* @return the ExtensionManager used for instantiating Processors,
* Prioritizers, etc.
*/
+ @Override
public ExtensionManager getExtensionManager() {
return extensionManager;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowSnippet.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowSnippet.java
index 6b4770f9c6..2c0a82da56 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowSnippet.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowSnippet.java
@@ -93,6 +93,7 @@ public class StandardFlowSnippet implements FlowSnippet {
this.extensionManager = extensionManager;
}
+ @Override
public void validate(final ProcessGroup group) {
// validate the names of Input Ports
for (final PortDTO port : dto.getInputPorts()) {
@@ -113,6 +114,7 @@ public class StandardFlowSnippet implements FlowSnippet {
SnippetUtils.verifyNoVersionControlConflicts(dto, group);
}
+ @Override
public void verifyComponentTypesInSnippet() {
final Map<String, Set<BundleCoordinate>> processorClasses = new HashMap<>();
for (final ExtensionDefinition extensionDefinition : extensionManager.getExtensions(Processor.class)) {
@@ -152,6 +154,7 @@ public class StandardFlowSnippet implements FlowSnippet {
}
}
+ @Override
public void instantiate(final FlowManager flowManager, final FlowController flowController, final ProcessGroup group) throws ProcessorInstantiationException {
instantiate(flowManager, flowController, group, true);
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/flow/StandardFlowManager.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/flow/StandardFlowManager.java
index 2a0c9bfae1..bdbce0d905 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/flow/StandardFlowManager.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/flow/StandardFlowManager.java
@@ -139,6 +139,7 @@ public class StandardFlowManager extends AbstractFlowManager implements FlowMana
this.isSiteToSiteSecure = Boolean.TRUE.equals(nifiProperties.isSiteToSiteSecure());
}
+ @Override
public Port createPublicInputPort(String id, String name) {
id = requireNonNull(id).intern();
name = requireNonNull(name).intern();
@@ -149,6 +150,7 @@ public class StandardFlowManager extends AbstractFlowManager implements FlowMana
IdentityMappingUtil.getIdentityMappings(nifiProperties));
}
+ @Override
public Port createPublicOutputPort(String id, String name) {
id = requireNonNull(id).intern();
name = requireNonNull(name).intern();
@@ -164,6 +166,7 @@ public class StandardFlowManager extends AbstractFlowManager implements FlowMana
*
* @return input ports
*/
+ @Override
public Set<Port> getPublicInputPorts() {
return getPublicPorts(ProcessGroup::getInputPorts);
}
@@ -173,6 +176,7 @@ public class StandardFlowManager extends AbstractFlowManager implements FlowMana
*
* @return output ports
*/
+ @Override
public Set<Port> getPublicOutputPorts() {
return getPublicPorts(ProcessGroup::getOutputPorts);
}
@@ -214,6 +218,7 @@ public class StandardFlowManager extends AbstractFlowManager implements FlowMana
return Optional.empty();
}
+ @Override
public RemoteProcessGroup createRemoteProcessGroup(final String id, final String uris) {
final String expirationPeriod = nifiProperties.getProperty(NiFiProperties.REMOTE_CONTENTS_CACHE_EXPIRATION, "30 secs");
final long remoteContentsCacheExpirationMillis = FormatUtils.getTimeDuration(expirationPeriod, TimeUnit.MILLISECONDS);
@@ -235,10 +240,12 @@ public class StandardFlowManager extends AbstractFlowManager implements FlowMana
}
}
+ @Override
public Label createLabel(final String id, final String text) {
return new StandardLabel(requireNonNull(id).intern(), text);
}
+ @Override
public Funnel createFunnel(final String id) {
final int maxConcurrentTasks = Integer.parseInt(nifiProperties.getProperty(MAX_CONCURRENT_TASKS_PROP_NAME, "1"));
final int maxBatchSize = Integer.parseInt(nifiProperties.getProperty(MAX_TRANSFERRED_FLOWFILES_PROP_NAME, "10000"));
@@ -246,6 +253,7 @@ public class StandardFlowManager extends AbstractFlowManager implements FlowMana
return new StandardFunnel(id.intern(), maxConcurrentTasks, maxBatchSize);
}
+ @Override
public Port createLocalInputPort(String id, String name) {
id = requireNonNull(id).intern();
name = requireNonNull(name).intern();
@@ -258,6 +266,7 @@ public class StandardFlowManager extends AbstractFlowManager implements FlowMana
return new LocalPort(id, name, ConnectableType.INPUT_PORT, processScheduler, maxConcurrentTasks, maxTransferredFlowFiles, boredYieldDuration);
}
+ @Override
public Port createLocalOutputPort(String id, String name) {
id = requireNonNull(id).intern();
name = requireNonNull(name).intern();
@@ -270,6 +279,7 @@ public class StandardFlowManager extends AbstractFlowManager implements FlowMana
return new LocalPort(id, name, ConnectableType.OUTPUT_PORT, processScheduler, maxConcurrentTasks, maxTransferredFlowFiles, boredYieldDuration);
}
+ @Override
public ProcessGroup createProcessGroup(final String id) {
final StatelessGroupNodeFactory statelessGroupNodeFactory = new StandardStatelessGroupNodeFactory(flowController, sslContext, flowController.createKerberosConfig(nifiProperties));
@@ -282,7 +292,7 @@ public class StandardFlowManager extends AbstractFlowManager implements FlowMana
return group;
}
-
+ @Override
public void instantiateSnippet(final ProcessGroup group, final FlowSnippetDTO dto) throws ProcessorInstantiationException {
requireNonNull(group);
requireNonNull(dto);
@@ -294,6 +304,7 @@ public class StandardFlowManager extends AbstractFlowManager implements FlowMana
group.findAllRemoteProcessGroups().forEach(RemoteProcessGroup::initialize);
}
+ @Override
public FlowFilePrioritizer createPrioritizer(final String type) throws InstantiationException, IllegalAccessException, ClassNotFoundException {
FlowFilePrioritizer prioritizer;
@@ -377,6 +388,7 @@ public class StandardFlowManager extends AbstractFlowManager implements FlowMana
return procNode;
}
+ @Override
public Connection createConnection(final String id, final String name, final Connectable source, final Connectable destination, final Collection<String> relationshipNames) {
return flowController.createConnection(id, name, source, destination, relationshipNames);
}
@@ -464,6 +476,7 @@ public class StandardFlowManager extends AbstractFlowManager implements FlowMana
getExtensionManager().removeInstanceClassLoader(clientNode.getIdentifier());
}
+ @Override
public ReportingTaskNode createReportingTask(final String type, final String id, final BundleCoordinate bundleCoordinate, final Set<URL> additionalUrls,
final boolean firstTimeAdded, final boolean register, final String classloaderIsolationKey) {
requireNonNull(type);
@@ -639,10 +652,12 @@ public class StandardFlowManager extends AbstractFlowManager implements FlowMana
return parameterProviderNode;
}
+ @Override
public Set<ControllerServiceNode> getRootControllerServices() {
return new HashSet<>(rootControllerServices.values());
}
+ @Override
public void addRootControllerService(final ControllerServiceNode serviceNode) {
final ControllerServiceNode existing = rootControllerServices.putIfAbsent(serviceNode.getIdentifier(), serviceNode);
if (existing != null) {
@@ -650,10 +665,12 @@ public class StandardFlowManager extends AbstractFlowManager implements FlowMana
}
}
+ @Override
public ControllerServiceNode getRootControllerService(final String serviceIdentifier) {
return rootControllerServices.get(serviceIdentifier);
}
+ @Override
public void removeRootControllerService(final ControllerServiceNode service) {
final ControllerServiceNode existing = rootControllerServices.get(requireNonNull(service).getIdentifier());
if (existing == null) {
@@ -697,6 +714,7 @@ public class StandardFlowManager extends AbstractFlowManager implements FlowMana
logger.info("{} removed from Flow Controller", service);
}
+ @Override
public ControllerServiceNode createControllerService(final String type, final String id, final BundleCoordinate bundleCoordinate, final Set<URL> additionalUrls, final boolean firstTimeAdded,
final boolean registerLogObserver, final String classloaderIsolationKey) {
// make sure the first reference to LogRepository happens outside of a NarCloseable so that we use the framework's ClassLoader
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/StandardFlowFileQueue.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/StandardFlowFileQueue.java
index 3831c13339..94c7918701 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/StandardFlowFileQueue.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/StandardFlowFileQueue.java
@@ -214,6 +214,7 @@ public class StandardFlowFileQueue extends AbstractFlowFileQueue implements Flow
/**
* Lock the queue so that other threads are unable to interact with the queue
*/
+ @Override
public void lock() {
writeLock.lock();
}
@@ -221,6 +222,7 @@ public class StandardFlowFileQueue extends AbstractFlowFileQueue implements Flow
/**
* Unlock the queue
*/
+ @Override
public void unlock() {
writeLock.unlock("external unlock");
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/clustered/client/async/nio/NioAsyncLoadBalanceClient.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/clustered/client/async/nio/NioAsyncLoadBalanceClient.java
index c62b5a5de0..3ac7cadd4c 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/clustered/client/async/nio/NioAsyncLoadBalanceClient.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/clustered/client/async/nio/NioAsyncLoadBalanceClient.java
@@ -107,6 +107,7 @@ public class NioAsyncLoadBalanceClient implements AsyncLoadBalanceClient {
return nodeIdentifier;
}
+ @Override
public synchronized void register(final String connectionId, final BooleanSupplier emptySupplier, final Supplier<FlowFileRecord> flowFileSupplier,
final TransactionFailureCallback failureCallback, final TransactionCompleteCallback successCallback,
final Supplier<LoadBalanceCompression> compressionSupplier, final BooleanSupplier honorBackpressureSupplier) {
@@ -120,6 +121,7 @@ public class NioAsyncLoadBalanceClient implements AsyncLoadBalanceClient {
partitionQueue.add(partition);
}
+ @Override
public synchronized void unregister(final String connectionId) {
final RegisteredPartition removedPartition = registeredPartitions.remove(connectionId);
@@ -142,6 +144,7 @@ public class NioAsyncLoadBalanceClient implements AsyncLoadBalanceClient {
}
}
+ @Override
public synchronized int getRegisteredConnectionCount() {
return registeredPartitions.size();
}
@@ -150,11 +153,13 @@ public class NioAsyncLoadBalanceClient implements AsyncLoadBalanceClient {
return new HashMap<>(registeredPartitions);
}
+ @Override
public void start() {
running = true;
logger.debug("{} started", this);
}
+ @Override
public void stop() {
running = false;
logger.debug("{} stopped", this);
@@ -182,10 +187,12 @@ public class NioAsyncLoadBalanceClient implements AsyncLoadBalanceClient {
selector = null;
}
+ @Override
public boolean isRunning() {
return running;
}
+ @Override
public boolean isPenalized() {
final long endTimestamp = penalizationEnd.get();
if (endTimestamp == 0) {
@@ -207,7 +214,7 @@ public class NioAsyncLoadBalanceClient implements AsyncLoadBalanceClient {
this.penalizationEnd.set(System.currentTimeMillis() + PENALIZATION_MILLIS);
}
-
+ @Override
public boolean communicate() throws IOException {
if (!running) {
return false;
@@ -301,6 +308,7 @@ public class NioAsyncLoadBalanceClient implements AsyncLoadBalanceClient {
* We don't want to then just push all data to other nodes. We'd rather push the data out to other nodes slowly while waiting for the disconnected
* node to reconnect. And if the node reconnects, we want to keep sending it data.
*/
+ @Override
public void nodeDisconnected() {
if (!loadBalanceSessionLock.tryLock()) {
// If we are not able to obtain the loadBalanceSessionLock, we cannot access the load balance session.
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/reporting/StandardReportingTaskNode.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/reporting/StandardReportingTaskNode.java
index 1f7fffae2f..dfaf634730 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/reporting/StandardReportingTaskNode.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/reporting/StandardReportingTaskNode.java
@@ -112,11 +112,13 @@ public class StandardReportingTaskNode extends AbstractReportingTaskNode impleme
flowController.stopReportingTask(this);
}
+ @Override
public void enable() {
verifyCanEnable();
flowController.enableReportingTask(this);
}
+ @Override
public void disable() {
verifyCanDisable();
flowController.disableReportingTask(this);
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/scheduling/StandardProcessScheduler.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/scheduling/StandardProcessScheduler.java
index 1a7a7dbb57..f7f156c350 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/scheduling/StandardProcessScheduler.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/scheduling/StandardProcessScheduler.java
@@ -163,6 +163,7 @@ public final class StandardProcessScheduler implements ProcessScheduler {
*
* @param task the task to perform
*/
+ @Override
public Future<?> submitFrameworkTask(final Runnable task) {
final CompletableFuture<?> future = new CompletableFuture<>();
@@ -416,7 +417,7 @@ public final class StandardProcessScheduler implements ProcessScheduler {
return future;
}
- @SuppressWarnings("PMD.EmptyCatchBlock")
+ @Override
public synchronized CompletableFuture<Void> startStatelessGroup(final StatelessGroupNode groupNode) {
final LifecycleState lifecycleState = getLifecycleState(requireNonNull(groupNode), true, true);
lifecycleState.setScheduled(true);
@@ -476,7 +477,7 @@ public final class StandardProcessScheduler implements ProcessScheduler {
} catch (final InterruptedException e) {
Thread.currentThread().interrupt();
return;
- } catch (final TimeoutException e) {
+ } catch (final TimeoutException ignored) {
// Controller Services have not yet enabled. Keep waiting.
// We do not want to just wait for the Future.get() to return because we want to check if the desired state has changed.
} catch (final Exception e) {
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/diagnostics/bootstrap/shell/result/SingleLineResult.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/diagnostics/bootstrap/shell/result/SingleLineResult.java
index e26f838e06..4c12cee4c6 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/diagnostics/bootstrap/shell/result/SingleLineResult.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/diagnostics/bootstrap/shell/result/SingleLineResult.java
@@ -34,6 +34,7 @@ public class SingleLineResult implements ShellCommandResult {
this.commandName = commandName;
}
+ @Override
public Collection<String> createResult(final InputStream inputStream) {
final List<String> result = new ArrayList<>();
try (final BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream))) {
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/framework/ssl/WatchServiceMonitorCommand.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/framework/ssl/WatchServiceMonitorCommand.java
index dd649709aa..840d153da8 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/framework/ssl/WatchServiceMonitorCommand.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/framework/ssl/WatchServiceMonitorCommand.java
@@ -46,6 +46,7 @@ public class WatchServiceMonitorCommand implements Runnable {
/**
* Poll Watch Service and process events
*/
+ @Override
public void run() {
final WatchKey watchKey = watchService.poll();
if (watchKey == null) {
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/reporting/StandardEventAccess.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/reporting/StandardEventAccess.java
index 4d1abc0e42..a7ea7a286d 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/reporting/StandardEventAccess.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/reporting/StandardEventAccess.java
@@ -105,6 +105,7 @@ public class StandardEventAccess extends AbstractEventAccess implements UserAwar
* @param user user making request
* @return the component status
*/
+ @Override
public ProcessGroupStatus getGroupStatus(final String groupId, final NiFiUser user, final int recursiveStatusDepth) {
final RepositoryStatusReport repoStatusReport = generateRepositoryStatusReport();
return getGroupStatus(groupId, repoStatusReport, user, recursiveStatusDepth);
@@ -121,6 +122,7 @@ public class StandardEventAccess extends AbstractEventAccess implements UserAwar
* @param user user making request
* @return the component status
*/
+ @Override
public ProcessGroupStatus getGroupStatus(final String groupId, final RepositoryStatusReport statusReport, final NiFiUser user) {
final ProcessGroup group = flowManager.getGroup(groupId);
@@ -136,6 +138,7 @@ public class StandardEventAccess extends AbstractEventAccess implements UserAwar
* @param user user making request
* @return the component status
*/
+ @Override
public ProcessGroupStatus getGroupStatus(final String groupId, final NiFiUser user) {
final RepositoryStatusReport repoStatusReport = generateRepositoryStatusReport();
return getGroupStatus(groupId, repoStatusReport, user);
@@ -152,6 +155,7 @@ public class StandardEventAccess extends AbstractEventAccess implements UserAwar
* @param recursiveStatusDepth the number of levels deep we should recurse and still include the the processors' statuses, the groups' statuses, etc. in the returned ProcessGroupStatus
* @return the component status
*/
+ @Override
public ProcessGroupStatus getGroupStatus(final String groupId, final RepositoryStatusReport statusReport, final NiFiUser user, final int recursiveStatusDepth) {
final ProcessGroup group = flowManager.getGroup(groupId);
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/controller/service/mock/MockProcessGroup.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/controller/service/mock/MockProcessGroup.java
index 9000e35aa3..e6342cba15 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/controller/service/mock/MockProcessGroup.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/controller/service/mock/MockProcessGroup.java
@@ -807,6 +807,7 @@ public class MockProcessGroup implements ProcessGroup {
return new NoOpBatchCounts();
}
+ @Override
public DataValve getDataValve(Port port) {
return null;
}
@@ -861,6 +862,7 @@ public class MockProcessGroup implements ProcessGroup {
return null;
}
+ @Override
public ExecutionEngine getExecutionEngine() {
return ExecutionEngine.STANDARD;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-status-history-shared/src/main/java/org/apache/nifi/controller/status/history/StandardStatusSnapshot.java b/nifi-framework-bundle/nifi-framework/nifi-framework-status-history-shared/src/main/java/org/apache/nifi/controller/status/history/StandardStatusSnapshot.java
index 15f085eebe..402273a71a 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-framework-status-history-shared/src/main/java/org/apache/nifi/controller/status/history/StandardStatusSnapshot.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-framework-status-history-shared/src/main/java/org/apache/nifi/controller/status/history/StandardStatusSnapshot.java
@@ -93,6 +93,7 @@ public class StandardStatusSnapshot implements StatusSnapshot {
counterValues.put(metric, value);
}
+ @Override
public StandardStatusSnapshot withoutCounters() {
if (counterValues == null || counterValues.isEmpty()) {
return this;
diff --git a/nifi-framework-bundle/nifi-framework/nifi-headless-server/src/main/java/org/apache/nifi/headless/HeadlessNiFiServer.java b/nifi-framework-bundle/nifi-framework/nifi-headless-server/src/main/java/org/apache/nifi/headless/HeadlessNiFiServer.java
index 6a1cb93be3..d62594e772 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-headless-server/src/main/java/org/apache/nifi/headless/HeadlessNiFiServer.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-headless-server/src/main/java/org/apache/nifi/headless/HeadlessNiFiServer.java
@@ -91,6 +91,7 @@ public class HeadlessNiFiServer implements NiFiServer {
public HeadlessNiFiServer() {
}
+ @Override
public void start() {
try {
@@ -254,6 +255,7 @@ public class HeadlessNiFiServer implements NiFiServer {
return null;
}
+ @Override
public void stop() {
try {
flowService.stop(false);
diff --git a/nifi-framework-bundle/nifi-framework/nifi-nar-utils/src/main/java/org/apache/nifi/nar/AbstractNativeLibHandlingClassLoader.java b/nifi-framework-bundle/nifi-framework/nifi-nar-utils/src/main/java/org/apache/nifi/nar/AbstractNativeLibHandlingClassLoader.java
index b0ddc5257b..7d71518126 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-nar-utils/src/main/java/org/apache/nifi/nar/AbstractNativeLibHandlingClassLoader.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-nar-utils/src/main/java/org/apache/nifi/nar/AbstractNativeLibHandlingClassLoader.java
@@ -92,6 +92,7 @@ public abstract class AbstractNativeLibHandlingClassLoader extends URLClassLoade
}
}
+ @Override
public String findLibrary(String libname) {
String libLocationString;
diff --git a/nifi-framework-bundle/nifi-framework/nifi-repository-models/src/main/java/org/apache/nifi/controller/repository/StandardRepositoryRecord.java b/nifi-framework-bundle/nifi-framework/nifi-repository-models/src/main/java/org/apache/nifi/controller/repository/StandardRepositoryRecord.java
index f8c2940a61..0aec6d01f3 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-repository-models/src/main/java/org/apache/nifi/controller/repository/StandardRepositoryRecord.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-repository-models/src/main/java/org/apache/nifi/controller/repository/StandardRepositoryRecord.java
@@ -273,6 +273,7 @@ public class StandardRepositoryRecord implements RepositoryRecord {
return startNanos;
}
+ @Override
public boolean isContentModified() {
return contentModified;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-repository-models/src/main/java/org/apache/nifi/controller/repository/claim/StandardResourceClaimManager.java b/nifi-framework-bundle/nifi-framework/nifi-repository-models/src/main/java/org/apache/nifi/controller/repository/claim/StandardResourceClaimManager.java
index 7bddcd5773..ce838e5389 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-repository-models/src/main/java/org/apache/nifi/controller/repository/claim/StandardResourceClaimManager.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-repository-models/src/main/java/org/apache/nifi/controller/repository/claim/StandardResourceClaimManager.java
@@ -203,6 +203,7 @@ public class StandardResourceClaimManager implements ResourceClaimManager {
}
}
+ @Override
public boolean isDestructable(final ResourceClaim claim) {
if (claim == null) {
return false;
diff --git a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-jetty/src/main/java/org/apache/nifi/web/server/handler/ContextPathRedirectPatternRule.java b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-jetty/src/main/java/org/apache/nifi/web/server/handler/ContextPathRedirectPatternRule.java
index 68356d05d7..5a990ab641 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-jetty/src/main/java/org/apache/nifi/web/server/handler/ContextPathRedirectPatternRule.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-jetty/src/main/java/org/apache/nifi/web/server/handler/ContextPathRedirectPatternRule.java
@@ -56,6 +56,7 @@ public class ContextPathRedirectPatternRule extends RedirectPatternRule {
@Override
public Rule.Handler apply(Rule.Handler input) throws IOException {
return new Rule.Handler(input) {
+ @Override
protected boolean handle(Response response, Callback callback) {
final String redirectUri = getRedirectUri(input);
response.setStatus(ContextPathRedirectPatternRule.this.getStatusCode());
diff --git a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/StandardNiFiServiceFacade.java b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/StandardNiFiServiceFacade.java
index 023ea4e491..3bb1a78561 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/StandardNiFiServiceFacade.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/StandardNiFiServiceFacade.java
@@ -4109,6 +4109,7 @@ public class StandardNiFiServiceFacade implements NiFiServiceFacade {
BundleUtils.discoverCompatibleBundles(controllerFacade.getExtensionManager(), versionedGroup);
}
+ @Override
public void discoverCompatibleBundles(final Map<String, ParameterProviderReference> parameterProviders) {
BundleUtils.discoverCompatibleBundles(controllerFacade.getExtensionManager(), parameterProviders);
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/concurrent/StandardAsynchronousWebRequest.java b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/concurrent/StandardAsynchronousWebRequest.java
index 419ee95285..d78c7ef248 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/concurrent/StandardAsynchronousWebRequest.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/concurrent/StandardAsynchronousWebRequest.java
@@ -53,10 +53,12 @@ public class StandardAsynchronousWebRequest<R, T> implements AsynchronousWebRequ
this.request = request;
}
+ @Override
public synchronized UpdateStep getCurrentStep() {
return (updateSteps == null || updateSteps.size() <= currentStepIndex) ? null : updateSteps.get(currentStepIndex);
}
+ @Override
public R getRequest() {
return request;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/dao/impl/StandardInputPortDAO.java b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/dao/impl/StandardInputPortDAO.java
index 401c7d2496..cc84aae59a 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/dao/impl/StandardInputPortDAO.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/dao/impl/StandardInputPortDAO.java
@@ -31,6 +31,7 @@ import java.util.Set;
@Repository
public class StandardInputPortDAO extends AbstractPortDAO implements PortDAO {
+ @Override
protected Port locatePort(final String portId) {
final ProcessGroup rootGroup = flowController.getFlowManager().getRootGroup();
Port port = rootGroup.findInputPort(portId);
diff --git a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/dao/impl/StandardOutputPortDAO.java b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/dao/impl/StandardOutputPortDAO.java
index c54e82a108..67f50489a5 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/dao/impl/StandardOutputPortDAO.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/dao/impl/StandardOutputPortDAO.java
@@ -31,6 +31,7 @@ import java.util.Set;
@Repository
public class StandardOutputPortDAO extends AbstractPortDAO implements PortDAO {
+ @Override
protected Port locatePort(final String portId) {
final ProcessGroup rootGroup = flowController.getFlowManager().getRootGroup();
final Port port = rootGroup.findOutputPort(portId);
diff --git a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/search/ComponentMatcherFactory.java b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/search/ComponentMatcherFactory.java
index 329255143b..c4e6984686 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/search/ComponentMatcherFactory.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/search/ComponentMatcherFactory.java
@@ -73,6 +73,7 @@ public class ComponentMatcherFactory {
private static final String DEFAULT_NAME_PREFIX = "From source ";
private static final String SEPARATOR = ", ";
+ @Override
public String apply(final Connection component) {
String result = null;
diff --git a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/search/query/MapBasedSearchQuery.java b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/search/query/MapBasedSearchQuery.java
index 194b84a459..0fc7ffb436 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/search/query/MapBasedSearchQuery.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/search/query/MapBasedSearchQuery.java
@@ -38,6 +38,7 @@ public class MapBasedSearchQuery implements SearchQuery {
}
+ @Override
public String getTerm() {
return term;
}
diff --git a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/main/java/org/apache/nifi/web/security/oidc/client/web/AuthorizedClientExpirationCommand.java b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/main/java/org/apache/nifi/web/security/oidc/client/web/AuthorizedClientExpirationCommand.java
index e5763aadd2..b616bb1b93 100644
--- a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/main/java/org/apache/nifi/web/security/oidc/client/web/AuthorizedClientExpirationCommand.java
+++ b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/main/java/org/apache/nifi/web/security/oidc/client/web/AuthorizedClientExpirationCommand.java
@@ -49,6 +49,7 @@ public class AuthorizedClientExpirationCommand implements Runnable {
/**
* Run expiration command and send Token Revocation Requests for Refresh Tokens of expired Authorized Clients
*/
+ @Override
public void run() {
logger.debug("Delete Expired Authorized Clients started");
final List<OidcAuthorizedClient> deletedAuthorizedClients = deleteExpired();
diff --git a/nifi-mock/src/main/java/org/apache/nifi/provenance/MockProvenanceEvent.java b/nifi-mock/src/main/java/org/apache/nifi/provenance/MockProvenanceEvent.java
index 31366c3d65..6dbf05a5b2 100644
--- a/nifi-mock/src/main/java/org/apache/nifi/provenance/MockProvenanceEvent.java
+++ b/nifi-mock/src/main/java/org/apache/nifi/provenance/MockProvenanceEvent.java
@@ -151,6 +151,7 @@ public class MockProvenanceEvent implements ProvenanceEventRecord {
return allAttrs;
}
+ @Override
public String getAttribute(final String attributeName) {
if (updatedAttributes.containsKey(attributeName)) {
return updatedAttributes.get(attributeName);
diff --git a/nifi-mock/src/main/java/org/apache/nifi/util/MockEventAccess.java b/nifi-mock/src/main/java/org/apache/nifi/util/MockEventAccess.java
index 4fcdf05bef..f8a944e16d 100644
--- a/nifi-mock/src/main/java/org/apache/nifi/util/MockEventAccess.java
+++ b/nifi-mock/src/main/java/org/apache/nifi/util/MockEventAccess.java
@@ -107,18 +107,22 @@ public class MockEventAccess implements EventAccess {
this.flowChanges.add(action);
}
+ @Override
public long getTotalBytesRead() {
return -1;
}
+ @Override
public long getTotalBytesWritten() {
return -1;
}
+ @Override
public long getTotalBytesSent() {
return -1;
}
+ @Override
public long getTotalBytesReceived() {
return -1;
}
diff --git a/nifi-mock/src/test/java/org/apache/nifi/util/TestStandardProcessorTestRunner.java b/nifi-mock/src/test/java/org/apache/nifi/util/TestStandardProcessorTestRunner.java
index 20d3e6950c..11b9dc0b27 100644
--- a/nifi-mock/src/test/java/org/apache/nifi/util/TestStandardProcessorTestRunner.java
+++ b/nifi-mock/src/test/java/org/apache/nifi/util/TestStandardProcessorTestRunner.java
@@ -330,10 +330,12 @@ public class TestStandardProcessorTestRunner {
private boolean opmCalled = false;
+ @Override
protected List<PropertyDescriptor> getSupportedPropertyDescriptors() {
return List.of(namePropertyDescriptor);
}
+ @Override
public void onPropertyModified(final PropertyDescriptor descriptor, final String oldValue, final String newValue) {
getLogger().info("onPropertyModified called for PD {} with old value {} and new value {}", descriptor.getName(), oldValue, newValue);
opmCalled = true;
@@ -354,6 +356,7 @@ public class TestStandardProcessorTestRunner {
.allowableValues("exampleName", "anotherExampleName")
.build();
+ @Override
protected List<PropertyDescriptor> getSupportedPropertyDescriptors() {
return List.of(namePropertyDescriptor);
}
diff --git a/nifi-registry/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/bucket/Bucket.java b/nifi-registry/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/bucket/Bucket.java
index 492229f704..f209ec4cba 100644
--- a/nifi-registry/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/bucket/Bucket.java
+++ b/nifi-registry/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/bucket/Bucket.java
@@ -49,10 +49,12 @@ public class Bucket extends LinkableEntity implements RevisableEntity {
private RevisionInfo revision;
@Schema(description = "An ID to uniquely identify this object.", accessMode = Schema.AccessMode.READ_ONLY)
+ @Override
public String getIdentifier() {
return identifier;
}
+ @Override
public void setIdentifier(String identifier) {
this.identifier = identifier;
}
diff --git a/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/security/authorization/StandardAuthorizerInitializationContext.java b/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/security/authorization/StandardAuthorizerInitializationContext.java
index d643e91eb5..35d2bf60ed 100644
--- a/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/security/authorization/StandardAuthorizerInitializationContext.java
+++ b/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/security/authorization/StandardAuthorizerInitializationContext.java
@@ -36,6 +36,7 @@ public class StandardAuthorizerInitializationContext implements AuthorizerInitia
return identifier;
}
+ @Override
public AuthorizerLookup getAuthorizerLookup() {
return authorizerLookup;
}
diff --git a/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/security/authorization/resource/InheritingAuthorizable.java b/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/security/authorization/resource/InheritingAuthorizable.java
index b0292296c3..08f7f7640e 100644
--- a/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/security/authorization/resource/InheritingAuthorizable.java
+++ b/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/security/authorization/resource/InheritingAuthorizable.java
@@ -37,6 +37,7 @@ public interface InheritingAuthorizable extends Authorizable {
* @param user user
* @return is authorized
*/
+ @Override
default AuthorizationResult checkAuthorization(Authorizer authorizer, RequestAction action, NiFiUser user, Map<String, String> resourceContext) {
if (user == null) {
throw new AccessDeniedException("Unknown user.");
@@ -61,6 +62,7 @@ public interface InheritingAuthorizable extends Authorizable {
* @param user user
* @param resourceContext resource context
*/
+ @Override
default void authorize(Authorizer authorizer, RequestAction action, NiFiUser user, Map<String, String> resourceContext) throws AccessDeniedException {
if (user == null) {
throw new AccessDeniedException("Unknown user.");
diff --git a/nifi-registry/nifi-registry-core/nifi-registry-framework/src/test/java/org/apache/nifi/registry/GenerateExtensionManifestSchema.java b/nifi-registry/nifi-registry-core/nifi-registry-framework/src/test/java/org/apache/nifi/registry/GenerateExtensionManifestSchema.java
index a73b554981..c0130153bf 100644
--- a/nifi-registry/nifi-registry-core/nifi-registry-framework/src/test/java/org/apache/nifi/registry/GenerateExtensionManifestSchema.java
+++ b/nifi-registry/nifi-registry-core/nifi-registry-framework/src/test/java/org/apache/nifi/registry/GenerateExtensionManifestSchema.java
@@ -42,6 +42,7 @@ public class GenerateExtensionManifestSchema {
public static class MySchemaOutputResolver extends SchemaOutputResolver {
+ @Override
public Result createOutput(String namespaceURI, String suggestedFileName) throws IOException {
File file = new File("./target", suggestedFileName);
StreamResult result = new StreamResult(file);
diff --git a/nifi-registry/nifi-registry-core/nifi-registry-provider-api/src/main/java/org/apache/nifi/registry/extension/BundleVersionCoordinate.java b/nifi-registry/nifi-registry-core/nifi-registry-provider-api/src/main/java/org/apache/nifi/registry/extension/BundleVersionCoordinate.java
index 5dd6146754..e7fc322f11 100644
--- a/nifi-registry/nifi-registry-core/nifi-registry-provider-api/src/main/java/org/apache/nifi/registry/extension/BundleVersionCoordinate.java
+++ b/nifi-registry/nifi-registry-core/nifi-registry-provider-api/src/main/java/org/apache/nifi/registry/extension/BundleVersionCoordinate.java
@@ -51,5 +51,6 @@ public interface BundleVersionCoordinate {
/**
* @return the string representation of the coordinate
*/
+ @Override
String toString();
}
diff --git a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/extensions/NexusExtensionClient.java b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/extensions/NexusExtensionClient.java
index 9121acc43b..ecc9aa1aaa 100644
--- a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/extensions/NexusExtensionClient.java
+++ b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/extensions/NexusExtensionClient.java
@@ -139,6 +139,7 @@ public class NexusExtensionClient implements ExtensionClient {
return sb.toString();
}
+ @Override
public String toString() {
return "NexusExtensionClient[baseUrl=" + baseUrl + "]";
}
diff --git a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/config/PropertiesFileFlowDefinitionParser.java b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/config/PropertiesFileFlowDefinitionParser.java
index 85541992c0..425715ebd4 100644
--- a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/config/PropertiesFileFlowDefinitionParser.java
+++ b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/config/PropertiesFileFlowDefinitionParser.java
@@ -99,12 +99,14 @@ public class PropertiesFileFlowDefinitionParser implements DataflowDefinitionPar
private static final String TRANSACTION_THRESHOLD_TIME = "nifi.stateless.transaction.thresholds.time";
+ @Override
public DataflowDefinition parseFlowDefinition(final File propertiesFile, final StatelessEngineConfiguration engineConfig, final List<ParameterOverride> parameterOverrides)
throws IOException, StatelessConfigurationException {
final Map<String, String> properties = readPropertyValues(propertiesFile);
return parseFlowDefinition(properties, engineConfig, parameterOverrides);
}
+ @Override
public DataflowDefinition parseFlowDefinition(final Map<String, String> properties, final StatelessEngineConfiguration engineConfig,
final List<ParameterOverride> parameterOverrides) throws IOException, StatelessConfigurationException {
diff --git a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/engine/StandardExecutionProgress.java b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/engine/StandardExecutionProgress.java
index 247c4efdc1..185a5cd93a 100644
--- a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/engine/StandardExecutionProgress.java
+++ b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/engine/StandardExecutionProgress.java
@@ -173,6 +173,7 @@ public class StandardExecutionProgress implements ExecutionProgress {
return completionAction;
}
+ @Override
public void enqueueTriggerResult(final Runnable onAcknowledge, final Consumer<Throwable> onFailure) {
if (isCanceled()) {
onFailure.accept(new RuntimeException("Dataflow canceled"));
diff --git a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/engine/StatelessProcessContextFactory.java b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/engine/StatelessProcessContextFactory.java
index f258053e02..8d8d1dd1c1 100644
--- a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/engine/StatelessProcessContextFactory.java
+++ b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/engine/StatelessProcessContextFactory.java
@@ -37,6 +37,7 @@ public class StatelessProcessContextFactory implements ProcessContextFactory {
this.stateManagerProvider = stateManagerProvider;
}
+ @Override
public ProcessContext createProcessContext(final Connectable connectable) {
final StateManager stateManager = stateManagerProvider.getStateManager(connectable.getIdentifier());
diff --git a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/flow/TransactionThresholdMeter.java b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/flow/TransactionThresholdMeter.java
index 3a1001a4fe..120f14ce0c 100644
--- a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/flow/TransactionThresholdMeter.java
+++ b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/flow/TransactionThresholdMeter.java
@@ -71,6 +71,7 @@ public class TransactionThresholdMeter {
return false;
}
+ @Override
public String toString() {
final long millis = TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startNanos);
return "TransactionThresholdMeter[flowFiles=" + flowFiles + ", bytes=" + bytes + ", elapsedTime=" + millis + " millis]";
diff --git a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/repository/StatelessRepositoryContextFactory.java b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/repository/StatelessRepositoryContextFactory.java
index b034d0f82d..161af4033b 100644
--- a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/repository/StatelessRepositoryContextFactory.java
+++ b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/repository/StatelessRepositoryContextFactory.java
@@ -62,6 +62,7 @@ public class StatelessRepositoryContextFactory implements RepositoryContextFacto
return contentRepository;
}
+ @Override
public FlowFileRepository getFlowFileRepository() {
return flowFileRepository;
}
diff --git a/nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions-services/src/main/java/org/apache/nifi/cs/tests/system/FakeControllerService1.java b/nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions-services/src/main/java/org/apache/nifi/cs/tests/system/FakeControllerService1.java
index 4c05b2ffe8..803598b8b2 100644
--- a/nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions-services/src/main/java/org/apache/nifi/cs/tests/system/FakeControllerService1.java
+++ b/nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions-services/src/main/java/org/apache/nifi/cs/tests/system/FakeControllerService1.java
@@ -19,6 +19,7 @@ package org.apache.nifi.cs.tests.system;
import org.apache.nifi.controller.AbstractControllerService;
public class FakeControllerService1 extends AbstractControllerService implements BaseFakeService {
+ @Override
public void foo() {
}
}
diff --git a/pmd-ruleset.xml b/pmd-ruleset.xml
index c3f8fcedc9..e151438fc0 100644
--- a/pmd-ruleset.xml
+++ b/pmd-ruleset.xml
@@ -36,6 +36,7 @@ under the License.
<rule ref="category/java/bestpractices.xml/AvoidReassigningCatchVariables" />
<rule ref="category/java/bestpractices.xml/ExhaustiveSwitchHasDefault" />
<rule ref="category/java/bestpractices.xml/ForLoopCanBeForeach" />
+ <rule ref="category/java/bestpractices.xml/MissingOverride" />
<rule ref="category/java/bestpractices.xml/PrimitiveWrapperInstantiation" />
<rule ref="category/java/bestpractices.xml/SimplifiableTestAssertion" />
<rule ref="category/java/bestpractices.xml/UnusedPrivateField" />