《交流讨论》专题

我正在从文件中读取值并获取列表。如下- 一旦我得到这个

以下代码正在为空的属性抛出NPE。class Person有属性：string:name，Integer:age，Integer:salary此处可以为空。我想创建一个工资列表。 在这里，我必须在结果列表中保留空值。null不能替换为0。

null null 哪一个比较好？（cookie与令牌“共享”） 是否应该实现不同的（即更好的）流？

我正在向drools规则引擎插入数据，但我无法理解它是如何处理插入的数据的。插入数据的代码是：

我最近开始研究口水。我只是设计了一个简单的应用程序来更好地理解它。 谢谢。

我知道你用 假设有动物超类和狗猫子类。基本上我想要一个包含狗和猫的列表。我发现我可以做到以下几点： 上面的代码可以编译。那么，它是否违反了我为动物主义者写价值观的规则？

在准备拓扑优化时，我偶然发现了以下几点： 目前，Kafka Streams在启用时会执行两种优化： 1-源KTable将源主题重新用作变更日志主题。 2-如果可能，Kafka流会将多个重新分区主题压缩为单个重新分区主题。 这个问题是关于第一点的。我不完全明白这里发生了什么。只是为了确保我没有在这里做任何假设。有人能解释一下，以前是什么状态吗： 1-KTable使用内部变更日志主题吗？如果是，有人能

它们之间有什么相同和不同之处，看起来Java并行流中有RXJava中可用的一些元素，是吗？

我想加入一个 kstream:从主题创建，该主题具有JSON值。我使用值中的两个属性来重新键控流。示例值（json的片段）。我创建了自定义pojo类并使用自定义SERDES。 键映射为： 我查看了KStream并打印了键和我使用的属性。看起来都很好。 null 现在，当我执行内部连接并对主题进行窥视或通过/时，我看到键和值不匹配。Join似乎不起作用, 我有完全相同的东西通过ksql工作，但想做我

我有一个关于Kafka流的时间窗的问题，有些概念真的让我困惑。 我们有一个主题每天获得1000万个事件，我们有6天的日志保留，所以总的主题包含6000万个事件。 现在，我创建了一个KTable，我正在执行load all操作并迭代事件。正如我之前提到的，实际上我们只是当前的事件，而不是6千万事件，所以我在KTable定义中窗口化了这些数据。 现在，当我用以下语句加载所有事件时，一切都运行良好。 问

我一直在玩Java新的和闪亮的功能部分，最让我困惑的事情之一是流？ 它们有什么用？ 在谷歌上，我主要找到了如何使用它们的解释和实际例子，我已经记下来了，没有关于幕后魔法的具体内容，这是我感兴趣的。 我的意思并不是说，从实际意义上讲，我从一些函数语言中找到了map/filter/reduce/etc。相当快，但为什么我们需要先转换为流？Java已经有了迭代器。流和迭代器之间是否有根本的区别，比如一个

任何人都可以指向一个官方Java文档，该文档描述了流将调用每个元素的每个“无干扰和无状态”中间操作的次数。 例如: 以上代码当前将调用< code>check方法4次。 在JDK的当前或未来版本中，方法的执行次数是否可能多于或少于从List或任何其他标准JavaAPI创建的流中的元素数量？

我一直在玩动态LINQ，我想知道Java是否有可能做类似的事情。例如，如果我使用这个工作代码： 有没有一种方法可以让它像使用动态LINQ一样动态

我正在阅读Poi(3.7)的excel文件。我正在学习一些关于poi的链接poi快速指南。现在我担心的是： 打开工作簿（.xls HSSFWorkbook或.xlsx XSSFWorkbook）时，可以从文件或InputStream加载工作簿。使用File对象允许更低的内存消耗，而InputStream需要更多的内存，因为它必须缓冲整个文件 在3.7版本的Poi中，WorkbookFactory没

如何使用项目Reactor背压功能与Kafka粘合剂在斯佩林云流？ 如果我使用这种方式，比发布者发送延迟1秒的消息，但消费者消费消息没有任何延迟。 有可能在春雨云流中使用cunsumer上的BackPereSure吗？