Skip to content

Commit

Permalink
Addressed review comments
Browse files Browse the repository at this point in the history
Signed-off-by: Kondaka <krishkdk@amazon.com>
  • Loading branch information
kkondaka committed Sep 27, 2024
1 parent ba7a482 commit fde302f
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,6 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.Collections;
Expand Down Expand Up @@ -84,7 +83,7 @@ public Collection<Record<Event>> doExecute(final Collection<Record<Event>> recor
if (keyVal != null) {
if (!nullValues.contains(keyVal.toString())) {
try {
if (keyVal instanceof ArrayList || keyVal.getClass().isArray()) {
if (keyVal instanceof List || keyVal.getClass().isArray()) {
Stream<Object> inputStream;
if (keyVal.getClass().isArray()) {
inputStream = Arrays.stream((Object[])keyVal);
Expand Down

0 comments on commit fde302f

Please sign in to comment.