java - 如何在流中访问 getter 和 setter
问题描述
我有一个采用 json 对象并将其插入到 aws 弹性搜索服务的方法,但我想编写另一种采用多个 json 对象并将它们插入到 aws 弹性搜索的方法
/**
* 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 && (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 不是功能接口”我怎样才能让它工作。
解决方案
您不需要该map
操作,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());
}
推荐阅读
- bash - 如何在标准输出和文件中显示任何命令和/或脚本的执行输出,但在标准输出中保留颜色?
- python - 来自列表字典和字典列表组合的终端列表的输入 - 来自 json
- python - 如何解决此错误以在列表/字符串中弹出单词?(Python 3.x)
- r - CVXR 用于最大化零均值的高斯似然性
- python - 如何在python中的垂直条形图下方制作水平颜色轨迹
- python - 在python中将字节数组的字符串转换为字节数组
- r - R:order() 在 RStudio 之外无法按预期工作
- python - 为什么python在定义时返回“NameError:名称'正确'未定义?
- python - 如何设置 Heroku 配置文件,使其在 Heroku 部署的任何终端问题中接受“是”
- css - 如何使用 CSS 选择所有元素中第一次出现的类