Поток Java и фильтрация на карту приводят к ошибке - PullRequest
Новая
       6

Поток Java и фильтрация на карту приводят к ошибке

0 голосов
/ 05 февраля 2019

Я пытаюсь использовать потоки Java для создания карты, которая содержит код валюты и описание строки.Код работает, когда я пытаюсь добавить элементы с 1 по 6, но когда я пытаюсь добавить элемент 7 (где параметр currencyCode не инициализирован), я получаю следующую ошибку: 

Exception in thread "main" java.lang.NullPointerException
    at java.util.concurrent.ConcurrentHashMap.putVal(ConcurrentHashMap.java:1011)
    at java.util.concurrent.ConcurrentHashMap$KeySetView.add(ConcurrentHashMap.java:4595)
    at Test.lambda$6(Test.java:73)

Как я могу изменитькод ниже, чтобы отфильтровать элементы, где значение currencyCode не инициализировано?Я думал, что отфильтровывание нулей должно сработать, но это не совсем работает. 

public class Test {

    public static void main(String[] args) {
        Currency item1 = new Currency();
        item1.setCurrencyCode("USD");
        Currency item2 = new Currency();
        item2.setCurrencyCode("GBP");
        Currency item3 = new Currency();
        item3.setCurrencyCode("GBP");
        Currency item4 = new Currency();
        item4.setCurrencyCode("AUS");
        Currency item5 = new Currency();
        item5.setCurrencyCode("USD");
        Currency item6 = new Currency();
        item6.setCurrencyCode("");
        Currency item7 = new Currency();

        List<Currency> list = new ArrayList<>();
        list.add(item1);
        list.add(item2);
        list.add(item3);
        list.add(item4);
        list.add(item5);
        list.add(item6);
        list.add(item7);

        Map<String, String> distinctCurrencyCodes = list.stream()
                .filter( distinctByKey(p -> p.getCurrencyCode()) )
                .filter(p -> (!StringUtils.equals(p.getCurrencyCode(), "USD")))
                .filter(p -> p.getCurrencyCode() != "" || p.getCurrencyCode() != null)
                .map(p -> p.getCurrencyCode() )
                .collect( Collectors.toMap(p -> p, p -> "Blah") );

        for (Map.Entry<String, String> entry : distinctCurrencyCodes.entrySet()) {
            System.out.println(entry.getKey() + "/" + entry.getValue());
        }
    }

    public static <T> Predicate<T> distinctByKey(Function<? super T, ?> keyExtractor) {
        Set<Object> seen = ConcurrentHashMap.newKeySet();
        return t -> seen.add(keyExtractor.apply(t));
    }
}

Ответы [ 2 ]

0 голосов
/ 06 февраля 2019

Проблема в методе DifferentByKey () .

Когда вы отправляете ноль для добавления в Set, возникает исключение.Просто измените ваш метод DifferentByKey () на этот.Я обработал ноль в этом методе. 

public static <T> Predicate<T> distinctByKey(Function<? super T, ?> keyExtractor) {
    Set<Object> seen = ConcurrentHashMap.newKeySet();
    return t -> {
        Object currencyName = keyExtractor.apply(t);
        if(currencyName == null)
            return false;
        return seen.add(currencyName);
    };
}

Если вам это нравится, вам больше не нужно добавлять этот фильтр: 

.filter(p -> p.getCurrencyCode() != "" && p.getCurrencyCode() != null)

Вы можете удалить это.Таким образом, ваша отфильтрованная часть будет: 

Map<String, String> distinctCurrencyCodes = list.stream()
            .filter(distinctByKey(p -> p.getCurrencyCode()))
            .filter(p -> (!StringUtils.equals(p.getCurrencyCode(), "USD")))
            .map(p -> p.getCurrencyCode() )
            .collect( Collectors.toMap(p -> p, p -> "Blah") );
0 голосов
/ 05 февраля 2019

Ваш фильтр, чтобы избежать нуля, неправильный, должен быть &&.

Седьмая валюта с нулевым значением проходит (потому что нуль! = "") И ломается, потому что ноль не может быть ключом накарта.

Попробуйте 

.filter(p -> p.getCurrencyCode() != "" && p.getCurrencyCode() != null)
...