《stream》专题

本文向大家介绍Spark Streaming和Storm有何区别？相关面试题，主要包含被问及Spark Streaming和Storm有何区别？时的应答技巧和注意事项，需要的朋友参考一下 一个实时毫秒一个准实时亚秒，不过storm的吞吐率比较低。

问题内容： 我在Google中警告我的字体： 资源被解释为字体，但以MIME类型application / octet-stream传输：“ … / Content / Fonts / iconFont.ttf”。 即使我有此警告也可以，但是我更喜欢避免此警告。 这里是我的报关表： 我已经搜索过其他帖子，但到目前为止还没有运气。 请注意，我的服务器是Microsoft的IIS。 知道如何避免此警告

问题内容： 我的问题是，当它尝试第二次读取对象时，会引发异常： 我第一次发送完全相同的对象消息；但是，当我第二次尝试执行相同的操作时，则会在上面抛出错误。我是否需要重新初始化readObject（）方法？我什至打印出了下面一行所接收到的消息对象，它与第一个可以正常工作的实例完全相同。 Object buf = myInput.readObject(); 我假设附加有一些问题，但是附加确实没有用。我

问题内容： 我有一张地图，其中“值”是项目列表： 我想从地图中提取项目，但仅提取1个项目列表： 我已经看到了答案，但它们不适用于我的情况。我不想要这个结果： 我想要的结果是： 如何使用JAVA 8 Streams实现此目的？谢谢。莱昂纳多。 问题答案： 感谢@Holger的回答。 在值映射中的Collection为Null的情况下避免NullPointerException的代码：

问题内容： 使用Java 8 Stream从Collection中查找与Property值匹配的对象。 人物属性->姓名，电话，电子邮件。 遍历“人员”列表并找到与对象匹配的电子邮件。看到这可以通过Java 8流轻松完成。但这仍然会返回收藏吗？ 例如： 但是我知道它将永远只有一个唯一的对象。我们可以做些什么而不是让我直接得到实际的对象。而不是获取对象列表。 问题答案： 代替使用收集器，请尝试使用或

问题内容： 我在UTC和ISO8601中使用了时间戳，但是使用结构化流，它会自动转换为本地时间。有没有办法阻止这种转换？我想在UTC中使用它。 我正在从Kafka中读取json数据，然后使用Spark函数对其进行解析。 输入： 流： 架构： 输出： 如您所见，小时本身已经增加。 PS：我尝试使用Spark功能，但没有运气。 问题答案： 对我来说，它可以使用： 它告诉spark SQL将UTC用作时

问题内容： 我大约提高了一些代码，以前也问了一个问题在这里。@霍尔格给了我正确的回答，他说： 每当发现自己通过groupingBy使用reducer收集器时，都应检查toMap是否更合适 好像是花样！他建议我做的只是完美的。 这是众所周知的模式吗？为什么比（在某些情况下）结合和更好？ 问题答案： 通过使用两个收集器的经验，这种模式变得显而易见。您会在Stackoverflow上找到一些问题和解答，

问题内容： 您有任何想法如何从对象中检索全部吗？我需要将 for循环 更改为 流 “同类”代码。 非常感谢任何帮助 问题答案： 您可以与涉及的串联和三元运算符混合使用，例如：

问题内容： 假设有一个名为Type的简单枚举定义如下： 找到具有给定值的正确枚举通常是通过带for循环的静态方法（假设该方法在枚举内部定义）完成的，例如： 我认为用Stream API表示的功能等效如下： 我们怎么能写得更好，更简单？这段代码让人感觉很强迫，而且不太清楚。该特别是似乎笨重和滥用，因为它不累积什么，不进行计算，并始终直接返回（提供过滤器返回一个值- 如果不说的显然是个灾难），更何况是

问题内容： 我想知道为什么接口不提供和方法。考虑以下类别： 它是 一手 牌的一种实现，因为您在玩交易纸牌游戏时可以手拿牌。 本质上，它包装了，可确保最大容量并提供其他一些有用的功能。最好将其直接实现为。 现在，为了方便起见，我认为实现起来会很不错，这样，如果您想对其进行循环，则可以使用增强的for循环。（我的课程也提供了一种方法，因此我认为该方法是合理的。） 该界面提供了以下内容（省略了javad

问题内容： 我知道这些方法的执行顺序不同，但是在我所有的测试中，我无法实现不同的执行顺序。 例： 输出： 请提供示例，说明两种方法将产生不同的输出。 问题答案： 第二行将始终输出 而第一个不保证，因为不保留顺序。将按照其源指定的顺序处理流的元素，而不管该流是顺序的还是并行的。 引用Javadoc： 该操作的行为明确地是不确定的。对于并行流管道，此操作不能保证尊重流的遇到顺序，因为这样做会牺牲并行性

问题内容： 在Java 8中，它允许对集合进行聚合。在Kotlin中，除了以stdlib中的扩展功能的集合形式存在之外，这并不完全相同。但尚不清楚不同用例的等效性。 例如，在JavaDoc的顶部是为Java 8编写的示例，将它们移植到Kolin时，在不同的JDK版本上不能使用Java 8类，因此可能应该以不同的方式编写它们。 在网上显示Kotlin集合示例的资源方面，它们通常是微不足道的，不能真正

问题内容： 我正在尝试使用Stream API生成Order实例。我有一个创建订单的工厂函数，并且使用DoubleStream初始化订单金额。 如果我使用文字（1.0）初始化Order实例，则可以正常工作。当我使用doubleStream创建随机数量时，将引发异常。 问题答案： 答案在（重点是我的）的javadoc中： 流仅应操作一次（调用中间流或终端流操作） 。例如，这排除了“分叉”流，其中相同

问题内容： 我有兴趣对流中的列表进行排序。这是我正在使用的代码： 我想念什么吗？列表未排序。 它应该根据具有最低值的项目对列表进行排序。 以及打印方法： 问题答案： 这与对参数引用进行排序的地方不同。在这种情况下，您将得到一个排序后的流，最终需要将其收集并分配给另一个变量： 您只是错过了分配结果

问题内容： 我有一个客户端和服务器应用程序，这些应用程序通过TCP序列化来传输消息。反序列化对象时出现以下错误： 对原因进行分析的任何想法或可能的后续步骤？ 问题答案： 序列化数据开头的魔术数字有问题。您可能需要捕获序列化的数据，并从头开始研究它。该ascii流为“ 8 = FI”。