stream 相关问题

流是一系列可以以串行方式访问的数据元素。对于Java 8的新Stream API,请改用java-stream标签。

groovy 中的并行流

我正在尝试在groovy中使用并行流处理两个地图。 我有两个 HashMap 类型的映射 。 地图A和地图B。我需要通过mapA与mapB并行流到c...

回答 1 投票 0

Node.js等待.pipe()

我正在尝试读取大量文件并将其中的信息合并为一个。这是我得到的实现。我想将其重写为 .pipe(),但结果只是覆盖了文件...

回答 1 投票 0

是否有 Java I/O 流类及其用途的完整列表?

您能告诉我 Java I/O Streams 可以用来做什么吗?它们中的每一个都在标准 Java 5 或 Java 6 I/O API 中。 例如: FileReader和FileWriter用于读取和写入...

回答 3 投票 0

删除特定字段的集合重复项

我编写了代码,从员工列表中删除重复的 ID,并打印唯一的 ID 及其所有详细信息。 所以在这里我可以删除重复项并打印唯一的,但其他员工详细信息...

回答 3 投票 0

流 API java-8

我编写了代码,从员工列表中删除重复的 ID,并打印唯一的 ID 及其所有详细信息。 所以在这里我可以删除重复项并打印唯一的,但其他员工详细信息...

回答 1 投票 0

执行Python程序时更改为logging.basicConfig(level=logging.DEBUG)

//,一行回答“如何将日志记录级别设置为调试?”通常是这样的: 日志记录.basicConfig(级别=日志记录.DEBUG) 然而,人们可能会忍不住想...

回答 2 投票 0

如何将整个字节流读取到 std::vector 中?

我在这里阅读了一个答案,展示了如何使用以下一(两个)衬里将整个流读入 std::string : std::istreambuf_iterator eos; std::string s(std::istreambuf_itera...

回答 0 投票 0

如何检查具有包含元素的列表的对象流是否具有另一个列表中存在的元素

我正在学习 Java Streams,这是学校的作业。我试图了解 Streams 是如何工作的,并在互联网上搜索示例和教程,但一直无法解决这个问题......

回答 1 投票 0

比较数组列表中对象的值

有一个数组列表,如下所示 列表 accList = [{"acCat":"SBSDF","acDesc":"SBA","tranID":"D1P902368"},{"...

回答 1 投票 0

提高Java/Stream/filter的响应时间

我正在使用流(filter/anyMatch)对两个对象列表进行比较。两个列表的大小最多可达一百万个对象。 我用下面的代码进行了测试。通常t的大小...

回答 1 投票 0

PowerShell 错误 - Copy-Item:找不到与名称“Stream”匹配的参数

我想创建一个 PowerShell 脚本来将 Templates 文件夹从远程计算机复制到本地计算机: # 要求管理员输入远程PC的名称 $RemotePCName = 读取主机 &q...

回答 1 投票 0

如何关闭通过 TransformStream 传输的 Web 串行端口?

我有一个 Web 串行端口,我想从中读取一些数据。我想使用 TransformStreams 通过使用 pipelineT 进行一些处理(例如将字节解码为字符串、分离出逻辑消息等)...

回答 2 投票 0

flutter 如何屈服于块流?

嗨,我是 flutter 和 dart 新手。我正在网上学习一堂课,练习使用集团来控制国家。第一课是在显示appStart动画后,转到登录页面。 莱斯...

回答 2 投票 0

捕获并播放AMR数据包

我使用 AMR 拨打 VoLTE 呼叫。我看到 AMR 数据包。右键单击并选择源作为过滤器。我看到所有传入的 AMR 数据包。接下来我去分析一个选择Decode as。设置已提交 RT...

回答 2 投票 0

使用 Stax2 转义 Scala 中的特殊字符

我正在尝试使用 Stax2 来编写带有转义特殊字符的属性的 xml 文件。 当我试图实现这样的精确输出时: 我正在尝试使用 Stax2 来编写带有转义特殊字符的属性的 xml 文件。 当我试图实现这样的精确输出时: <elem1 att1="This &#x0A; That" /> 但是当我使用通常的XMLStreamWriter时,输出是这样的: <elem1 att1="This &amp;#x0A; That" /> 所以我用 Stax2 尝试了以下操作: import org.codehaus.stax2.{XMLOutputFactory2} import org.scalatest.funsuite.AnyFunSuite import java.io.{File, FileOutputStream} import javax.xml.stream.{XMLOutputFactory, XMLStreamWriter} class testStreamXML extends AnyFunSuite{ val file = new File("stax2test.xml") val fileOutputStream = new FileOutputStream(file) val outputFactory: XMLOutputFactory2 = XMLOutputFactory.newInstance().asInstanceOf[XMLOutputFactory2] //outputFactory.setProperty(XMLOutputFactory2.P_ATTR_VALUE_ESCAPER, true) val writer= outputFactory.createXMLStreamWriter(fileOutputStream) writer.writeStartDocument() writer.writeStartElement("elem1") writer.writeAttribute("att1", "This &#x0A; That") writer.writeEndElement() writer.writeEndDocument() } 每当我尝试将属性 P_ATTR_VALUE_ESCAPER 设置为 true 或 false 时,我都会收到此错误: An exception or error caused a run to abort: class java.lang.Boolean cannot be cast to class org.codehaus.stax2.io.EscapingWriterFactory (java.lang.Boolean is in module java.base of loader 'bootstrap'; org.codehaus.stax2.io.EscapingWriterFactory is in unnamed module of loader 'app') java.lang.ClassCastException: class java.lang.Boolean cannot be cast to class org.codehaus.stax2.io.EscapingWriterFactory (java.lang.Boolean is in module java.base of loader 'bootstrap'; org.codehaus.stax2.io.EscapingWriterFactory is in unnamed module of loader 'app') at com.ctc.wstx.api.WriterConfig.setProperty(WriterConfig.java:401) at com.ctc.wstx.api.CommonConfig.setProperty(CommonConfig.java:100) at com.ctc.wstx.stax.WstxOutputFactory.setProperty(WstxOutputFactory.java:153) at testStreamXML3.<init>(testStreamXML3.scala:10) at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:64) at java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.base/java.lang.reflect.Constructor.newInstanceWithCaller(Constructor.java:500) at java.base/java.lang.reflect.ReflectAccess.newInstance(ReflectAccess.java:128) at java.base/jdk.internal.reflect.ReflectionFactory.newInstance(ReflectionFactory.java:350) at java.base/java.lang.Class.newInstance(Class.java:645) at org.scalatest.tools.Runner$.genSuiteConfig(Runner.scala:1402) at org.scalatest.tools.Runner$.$anonfun$doRunRunRunDaDoRunRun$8(Runner.scala:1199) at scala.collection.immutable.List.map(List.scala:246) at org.scalatest.tools.Runner$.doRunRunRunDaDoRunRun(Runner.scala:1198) at org.scalatest.tools.Runner$.$anonfun$runOptionallyWithPassFailReporter$24(Runner.scala:993) at org.scalatest.tools.Runner$.$anonfun$runOptionallyWithPassFailReporter$24$adapted(Runner.scala:971) at org.scalatest.tools.Runner$.withClassLoaderAndDispatchReporter(Runner.scala:1480) at org.scalatest.tools.Runner$.runOptionallyWithPassFailReporter(Runner.scala:971) at org.scalatest.tools.Runner$.run(Runner.scala:798) at org.scalatest.tools.Runner.run(Runner.scala) at org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner.runScalaTest2or3(ScalaTestRunner.java:38) at org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner.main(ScalaTestRunner.java:25) 有什么建议如何解决这个问题吗?或者达到我转义属性中特殊字符的目的? 您所指的属性确实需要一个 EscapingWriterFactory 类。这是文档: 如果需要对属性值内容进行自定义输出转义,可以设置的属性。值集必须是类型 逃离WriterFactory。设置后,工厂将用于创建 每个写入器实例用于转义所有写入的属性值,两者 通过显式 XMLStreamWriter.writeAttribute(java.lang.String, java.lang.String) 方法,以及通过复制方法 (XMLStreamWriter2.copyEventFromReader(org.codehaus.stax2.XMLStreamReader2, 布尔值))。 [1] 关于如何实现“个人”逃避该工厂的实施的问题就可以完成这项工作。这是一个使用给定编写器的简单实现(受 [2] 启发),无需应用任何转义 - 这可能是您想要解决的任何特殊用例的起点: class CustomXmlEscapingWriterFactory extends EscapingWriterFactory{ override def createEscapingWriterFor(writer: Writer, s: String): Writer = new Writer(){ override def write(cbuf: Array[Char], off: Int, len: Int): Unit = writer.write(cbuf, off, len) override def flush(): Unit = writer.flush() override def close(): Unit = writer.close() } override def createEscapingWriterFor(outputStream: OutputStream, s: String): Writer = throw IllegalArgumentException("not supported") } class TestStreamXML extends AnyFunSuite{ val file = new File("stax2test.xml") val fileOutputStream = new FileOutputStream(file) val oprovider: OutputFactoryProviderImpl = new OutputFactoryProviderImpl() val outputFactory: XMLOutputFactory2 = oprovider.createOutputFactory() // your factory implementation goes here as property outputFactory.setProperty(XMLOutputFactory2.P_ATTR_VALUE_ESCAPER, CustomXmlEscapingWriterFactory()) val writer= outputFactory.createXMLStreamWriter(fileOutputStream) writer.writeStartDocument() writer.writeStartElement("elem1") writer.writeAttribute("att1", "This &#x0A; That") writer.writeEndElement() writer.writeEndDocument() } 结果输出如下所示: <?xml version='1.0' encoding='UTF-8'?><elem1 att1="This &#x0A; That"/> [1] https://fasterxml.github.io/stax2-api/javadoc/4.0.0/org/codehaus/stax2/XMLOutputFactory2.html#P_ATTR_VALUE_ESCAPER [2] 使用 jackson-dataformat-xml 转义引号

回答 1 投票 0

如何拆分列表<String >值并仅将数字放入另一个列表

我的列表值为 ["12-dept20","13-dept50"] 我想将它们拆分为仅包含 - 之前的数字的列表,以获得 [12, 13] 的列表 列表。使用流分割,但是...

回答 1 投票 0

在 Java 中使用流时这是一个不好的做法吗?

假设我有一个字符串数组,我想过滤该数组,反转流的顺序,然后将流组合成一个字符串。 包含此内容以反转输出是不好的做法吗

回答 1 投票 0

Express.Multer.File 到 ReadStream

我想上传我的视频,但 createAndUploadVideo 方法中的 Bunny.Net (https://github.com/dan-online/bunnycdn-stream/tree/main/src) 包装器需要 ReadStream 类型,而 Express.Multe ...

回答 1 投票 0

在 pandas 数据帧上创建和更新组行总和

我有一个包含学生及其学校科目的数据框: 主题 标记 海伦 艺术 20 哲学 16.8 经济学 12 科林 数学 19.2 地理 17 号 历史 15 对于每个主题,都有一个

回答 1 投票 0

比较两个填充有不同类型对象的集合

我在尝试比较两个大集合时遇到性能问题,我正在寻求一些帮助以找到更好的方法来做到这一点。 课程: 公共类 TypeOne { 私有 int id; } 和 公共...

回答 2 投票 0

最新问题
© www.soinside.com 2019 - 2024. All rights reserved.