NIFI-9341 Corrected annotation syntax problem

Signed-off-by: David Handermann <exceptionfactory@apache.org>
This commit is contained in:
exceptionfactory 2022-01-28 13:24:41 -06:00
parent 49978cdd91
commit 43a24743cc
No known key found for this signature in database
GPG Key ID: 29B6A52D2AAE8DBA
3 changed files with 0 additions and 3 deletions

View File

@ -281,7 +281,6 @@ public class TestCEFReader {
Assertions.assertEquals(value, processor.getRecords().get(number).getValue(name));
}
@SafeVarargs
private void assertFieldsAre(final Map<String, Object>... fieldGroups) {
final Map<String, Object> expectedFields = new HashMap<>();
Arrays.stream(fieldGroups).forEach(fieldGroup -> expectedFields.putAll(fieldGroup));

View File

@ -445,7 +445,6 @@ public class TestCEFRecordReader {
this.results = results;
}
@SafeVarargs
private void assertFieldsAre(final Map<String, Object>... fieldGroups) {
final Map<String, Object> expectedFields = new HashMap<>();
Arrays.stream(fieldGroups).forEach(fieldGroup -> expectedFields.putAll(fieldGroup));

View File

@ -272,7 +272,6 @@ public class TestCEFSchemaInference {
result = testSubject.inferSchema(recordSource);
}
@SafeVarargs
private void assertSchemaConsistsOf(final List<RecordField>... expectedFieldGroups) {
final List<RecordField> expectedFields = Arrays.stream(expectedFieldGroups).flatMap(group -> group.stream()).collect(Collectors.toList());
Assertions.assertEquals(expectedFields.size(), result.getFieldCount());