This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new dbc56bd50a1 NIFI-16126 Removed redundant type arguments (#11446)
dbc56bd50a1 is described below
commit dbc56bd50a18df4c84d329db3e22ecef0f3811fb
Author: dan-s1 <[email protected]>
AuthorDate: Mon Jul 20 12:59:16 2026 -0400
NIFI-16126 Removed redundant type arguments (#11446)
Signed-off-by: David Handermann <[email protected]>
---
.../nifi/hl7/query/evaluator/message/SegmentEvaluator.java | 2 +-
.../nifi/processors/aws/kinesis/PollingKinesisClientTest.java | 10 +++++-----
.../java/org/apache/nifi/redis/state/ITRedisStateProvider.java | 2 +-
.../main/java/org/apache/nifi/processors/smb/GetSmbFile.java | 2 +-
.../main/java/org/apache/nifi/processors/smb/PutSmbFile.java | 2 +-
.../java/org/apache/nifi/provenance/IndexConfiguration.java | 2 +-
.../org/apache/nifi/provenance/index/lucene/QueryTask.java | 2 +-
.../nifi/controller/repository/StandardProcessSession.java | 2 +-
.../org/apache/nifi/controller/swap/StandardSwapContents.java | 2 +-
.../org/apache/nifi/controller/swap/StandardSwapSummary.java | 2 +-
.../nifi/controller/repository/StandardRepositoryRecord.java | 2 +-
11 files changed, 15 insertions(+), 15 deletions(-)
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 56b297a303e..68919c4e935 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
@@ -43,7 +43,7 @@ public class SegmentEvaluator implements Evaluator<List> {
final HL7Message message = (HL7Message) objectMap.get(MESSAGE_KEY);
final List<HL7Segment> segments = message.getSegments(segmentType);
- return (segments == null) ? Collections.<HL7Segment>emptyList() :
segments;
+ return (segments == null) ? Collections.emptyList() : segments;
}
@Override
diff --git
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-kinesis/src/test/java/org/apache/nifi/processors/aws/kinesis/PollingKinesisClientTest.java
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-kinesis/src/test/java/org/apache/nifi/processors/aws/kinesis/PollingKinesisClientTest.java
index 0dba001e6c4..b9dabd2a4dc 100644
---
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-kinesis/src/test/java/org/apache/nifi/processors/aws/kinesis/PollingKinesisClientTest.java
+++
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-kinesis/src/test/java/org/apache/nifi/processors/aws/kinesis/PollingKinesisClientTest.java
@@ -227,7 +227,7 @@ class PollingKinesisClientTest {
.millisBehindLatest(0L)
.build();
default -> GetRecordsResponse.builder()
- .records(List.<Record>of())
+ .records(List.of())
.nextShardIterator(request.shardIterator())
.millisBehindLatest(0L)
.build();
@@ -381,7 +381,7 @@ class PollingKinesisClientTest {
}
if (request.shardIterator().startsWith("iter-1")) {
return GetRecordsResponse.builder()
- .records(List.<Record>of())
+ .records(List.of())
.nextShardIterator(request.shardIterator()).millisBehindLatest(0L).build();
}
return GetRecordsResponse.builder()
@@ -447,11 +447,11 @@ class PollingKinesisClientTest {
fetchLoopBlocked.countDown();
unblockFetchLoop.await(10, TimeUnit.SECONDS);
return GetRecordsResponse.builder()
- .records(List.<Record>of())
+ .records(List.of())
.nextShardIterator("iter-1c").millisBehindLatest(0L).build();
}
return GetRecordsResponse.builder()
- .records(List.<Record>of())
+ .records(List.of())
.nextShardIterator(request.shardIterator()).millisBehindLatest(0L).build();
});
@@ -530,7 +530,7 @@ class PollingKinesisClientTest {
.nextShardIterator("iter-2a").millisBehindLatest(0L).build();
}
return GetRecordsResponse.builder()
- .records(List.<Record>of())
+ .records(List.of())
.nextShardIterator(request.shardIterator()).millisBehindLatest(0L).build();
});
diff --git
a/nifi-extension-bundles/nifi-redis-bundle/nifi-redis-extensions/src/test/java/org/apache/nifi/redis/state/ITRedisStateProvider.java
b/nifi-extension-bundles/nifi-redis-bundle/nifi-redis-extensions/src/test/java/org/apache/nifi/redis/state/ITRedisStateProvider.java
index 7968515f416..ffec2ce2489 100644
---
a/nifi-extension-bundles/nifi-redis-bundle/nifi-redis-extensions/src/test/java/org/apache/nifi/redis/state/ITRedisStateProvider.java
+++
b/nifi-extension-bundles/nifi-redis-bundle/nifi-redis-extensions/src/test/java/org/apache/nifi/redis/state/ITRedisStateProvider.java
@@ -176,7 +176,7 @@ public class ITRedisStateProvider {
assertEquals(1, map.size());
assertEquals("value", map.get(key));
- provider.setState(Collections.<String, String>emptyMap(), componentId);
+ provider.setState(Collections.emptyMap(), componentId);
final StateMap stateMap = provider.getState(componentId);
map = stateMap.toMap();
diff --git
a/nifi-extension-bundles/nifi-smb-bundle/nifi-smb-processors/src/main/java/org/apache/nifi/processors/smb/GetSmbFile.java
b/nifi-extension-bundles/nifi-smb-bundle/nifi-smb-processors/src/main/java/org/apache/nifi/processors/smb/GetSmbFile.java
index b5018f5d77b..a06cac1354e 100644
---
a/nifi-extension-bundles/nifi-smb-bundle/nifi-smb-processors/src/main/java/org/apache/nifi/processors/smb/GetSmbFile.java
+++
b/nifi-extension-bundles/nifi-smb-bundle/nifi-smb-processors/src/main/java/org/apache/nifi/processors/smb/GetSmbFile.java
@@ -283,7 +283,7 @@ public class GetSmbFile extends AbstractProcessor {
switch (context.getProperty(SHARE_ACCESS).getValue()) {
case SHARE_ACCESS_NONE:
- sharedAccess = Collections.<SMB2ShareAccess>emptySet();
+ sharedAccess = Collections.emptySet();
break;
case SHARE_ACCESS_READ:
sharedAccess = EnumSet.of(SMB2ShareAccess.FILE_SHARE_READ);
diff --git
a/nifi-extension-bundles/nifi-smb-bundle/nifi-smb-processors/src/main/java/org/apache/nifi/processors/smb/PutSmbFile.java
b/nifi-extension-bundles/nifi-smb-bundle/nifi-smb-processors/src/main/java/org/apache/nifi/processors/smb/PutSmbFile.java
index f3b2025b5b8..25b0ca18b2e 100644
---
a/nifi-extension-bundles/nifi-smb-bundle/nifi-smb-processors/src/main/java/org/apache/nifi/processors/smb/PutSmbFile.java
+++
b/nifi-extension-bundles/nifi-smb-bundle/nifi-smb-processors/src/main/java/org/apache/nifi/processors/smb/PutSmbFile.java
@@ -230,7 +230,7 @@ public class PutSmbFile extends AbstractProcessor {
switch (context.getProperty(SHARE_ACCESS).getValue()) {
case SHARE_ACCESS_NONE:
- sharedAccess = Collections.<SMB2ShareAccess>emptySet();
+ sharedAccess = Collections.emptySet();
break;
case SHARE_ACCESS_READ:
sharedAccess = EnumSet.of(SMB2ShareAccess.FILE_SHARE_READ);
diff --git
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/IndexConfiguration.java
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/IndexConfiguration.java
index 1ae6df71917..a469a20e6bc 100644
---
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/IndexConfiguration.java
+++
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/IndexConfiguration.java
@@ -268,7 +268,7 @@ public class IndexConfiguration {
final Long firstEntryTime = getFirstEntryTime(provenanceLogFile);
if (firstEntryTime == null) {
logger.debug("Found no records in {} so returning no Indices
for it", provenanceLogFile);
- return Collections.<File>emptyList();
+ return Collections.emptyList();
}
boolean foundIndexCreatedLater = false;
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/QueryTask.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/QueryTask.java
index 6efc44a0779..47f6d5db144 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/QueryTask.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/QueryTask.java
@@ -179,7 +179,7 @@ public class QueryTask implements Runnable {
private Tuple<List<ProvenanceEventRecord>, Long> readDocuments(final
TopDocs topDocs, final StoredFields storedFields) {
// If no topDocs is supplied, just provide a Tuple that has no records
and a hit count of 0.
if (topDocs == null || topDocs.totalHits.value() == 0) {
- return new Tuple<>(Collections.<ProvenanceEventRecord>emptyList(),
0L);
+ return new Tuple<>(Collections.emptyList(), 0L);
}
final long start = System.nanoTime();
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java
b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java
index bd60a85b593..28e200d25c5 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java
@@ -2710,7 +2710,7 @@ public class StandardProcessSession implements
ProcessSession, ProvenanceEventEn
record.getContentClaimOffset() +
claim.getOffset(), record.getSize());
}
- enriched.setAttributes(record.getAttributes(),
Collections.<String, String>emptyMap());
+ enriched.setAttributes(record.getAttributes(),
Collections.emptyMap());
return enriched.build();
}
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/swap/StandardSwapContents.java
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/swap/StandardSwapContents.java
index 7ec0f929053..11e6f5adcb9 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/swap/StandardSwapContents.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/swap/StandardSwapContents.java
@@ -25,7 +25,7 @@ import java.util.Collections;
import java.util.List;
public class StandardSwapContents implements SwapContents {
- public static final SwapContents EMPTY_SWAP_CONTENTS = new
StandardSwapContents(StandardSwapSummary.EMPTY_SUMMARY,
Collections.<FlowFileRecord>emptyList());
+ public static final SwapContents EMPTY_SWAP_CONTENTS = new
StandardSwapContents(StandardSwapSummary.EMPTY_SUMMARY,
Collections.emptyList());
private final SwapSummary summary;
private final List<FlowFileRecord> flowFiles;
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/swap/StandardSwapSummary.java
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/swap/StandardSwapSummary.java
index 0a7744e9eb3..253c571ebc4 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/swap/StandardSwapSummary.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/swap/StandardSwapSummary.java
@@ -25,7 +25,7 @@ import java.util.Collections;
import java.util.List;
public class StandardSwapSummary implements SwapSummary {
- public static final SwapSummary EMPTY_SUMMARY = new
StandardSwapSummary(new QueueSize(0, 0L), null,
Collections.<ResourceClaim>emptyList(), 0L, 0L);
+ public static final SwapSummary EMPTY_SUMMARY = new
StandardSwapSummary(new QueueSize(0, 0L), null, Collections.emptyList(), 0L,
0L);
private final QueueSize queueSize;
private final Long maxFlowFileId;
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 efd2d3d6939..061f5e49e3a 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
@@ -268,7 +268,7 @@ public class StandardRepositoryRecord implements
RepositoryRecord {
@Override
public List<ContentClaim> getTransientClaims() {
- return transientClaims == null ? Collections.<ContentClaim>emptyList()
: Collections.unmodifiableList(transientClaims);
+ return transientClaims == null ? Collections.emptyList() :
Collections.unmodifiableList(transientClaims);
}
void addTransientClaim(final ContentClaim claim) {
