Как получить доступ к геттерам и сеттеру внутри потока

#java #spring #spring-boot #java-8 #java-stream

#java #весна #пружинный ботинок #java-8 #java-stream #spring #spring-boot

Вопрос:

У меня есть метод, который принимает объект json и вставляет его в aws elastic search service, но я хочу написать другой метод, который принимает несколько объектов json и вставляет их в aws elastic search

 /**
 * Create the Product in ElasticSearch
 *
 * @param product The Product
 * @return The response string
 * @throws JsonProcessingException Throws JsonProcessingException when response cannot be parsed
 */
public String createNewProduct(Product product) throws JsonProcessingException {
    final ObjectMapper objectMapper = new ObjectMapper();
    final String json = objectMapper.writeValueAsString(product);
    if (json != null) {
        AwsResponse response = createDocument(ElasticSearchConstants.PRODUCTS_INDEX,
            ElasticSearchConstants.PRODUCTS_DOCUMENT_TYPE,
            json,
            product.getPartNo());
        // Creating a new document not seen before results in a 201 status, where as overwriting a previous document results in a 200
        if (response != null amp;amp; (response.getHttpResponse().getStatusCode() == HttpStatus.CREATED.value()
            || response.getHttpResponse().getStatusCode() == HttpStatus.OK.value())) {
            LOGGER.info("Successfully created new Product", product.getPartNo(), product.getLevelOne());
            return product.getPartNo();
        }
    }

    return null;
}

/**
 * Create new Products in ElasticSearch
 * @param products The product
 * @throws JsonProcessingException Throws JsonProcessingException when response cannot be parsed
 */
public String createNewProducts(ArrayList<Product> products) throws JsonProcessingException{
    final ObjectMapper objectMapper = new ObjectMapper();
    products.stream()
        .map(product -> {
          try {
              return objectMapper.writeValueAsString(product);
          } catch (JsonProcessingException e) {
              return new JsonProcessingException(e){};
          }
      })
      .forEach(product -> {
          createDocument(ElasticSearchConstants.PRODUCTS_INDEX,
              ElasticSearchConstants.PRODUCTS_DOCUMENT_TYPE,
              product,
              products.stream().forEach(p->p::getPartNo)
              );
      });




    return null;
}

Как вы видите, методы createDocument принимают 4 параметра, 4 из которых являются строковыми
Первый метод работает очень хорошо, но у второго метода есть проблема.
Когда я пытаюсь получить partNo, он выдает мне обычную ошибку «void не является функциональным интерфейсом», как я могу заставить его работать.

1. Либо Product::getPartNo или p->p.getPartNo() .. Или, скорее, проблема в вашем случае должна заключаться в сигнатуре используемого метода createDocument , разве это не должно вызываться только с одним product ?

Ответ №1:

Вам не нужна map операция, a forEach может работать в вашем случае. Использование stream s также не очень эффективно в этом случае. Вы могли бы просто написать for цикл и выполнить операцию как :

 for (Product product : products) {
    String json = objectMapper.writeValueAsString(product);
    // handle the exception as well above
    createDocument(ElasticSearchConstants.PRODUCTS_INDEX,
            ElasticSearchConstants.PRODUCTS_DOCUMENT_TYPE,
            json, product.getPartNo());
}