使用偏移量复制流

文章/答案/技术大牛

发布

1回答

我正在使用UWP API来使用Windows的音频捕获功能，因此我可以从麦克风输入录制音频。如何将inStream的内容写到另一个流中？以下面几行为例。transmitStream是一个名为VoiceTransmitStream的类，它继承自Stream (VoiceTransmitStream : Stream)，因此我可以访问所有常用的流方法/属性如何将inStream的内容分块复制到transmitStream？我基本上需要将写入inStream的内容同步到transmitStream，这

浏览 21提问于2020-10-03得票数 0

1回答

重新部署SCDF流时，Kafka偏移量有何变化？

apache-kafka、spring-cloud-dataflow

对于流应用程序，我使用带有Kafka 0.10.0的SCDF on YARN 1.0.2.RELEASE。当我取消部署一个流，然后重新部署它时，似乎有时它会从当前的Kafka主题偏移量继续，而有时它会从最旧的偏移量开始。在哪里配置可以在重新部署流时获得可预测的行为(例如，当前偏移量、最新偏移量、最旧偏移量)？有没有办法期望不同的流有不同的行为？

浏览 0提问于2017-05-22得票数 1

1回答

NTFS + CreateFile:在路径名中指定流偏移量？

winapi、path、filepath、ntfs、createfile

通过CreateFile打开NTFS文件数据流时，是否可以在路径名中指定流偏移量例如，abcd.txt::$DATA指定未命名流的偏移量为0*，是否可以在路径名内指定不同的偏移量** *从技术上讲，这也意味着在不使用SetFilePointer的情况下，使用append调用WriteFile时，偏移量等于流长度**

浏览 10提问于2016-07-21得票数 0

回答已采纳

1回答

从特定偏移量到结束偏移量的流处理

apache-kafka、apache-kafka-streams

是否可以进行从输入主题的特定偏移量到结束偏移量的kafka流处理？我有一个Kafka流应用程序，它使用一个输入主题，但由于某种原因它失败了。我修复了这个问题并重新启动了它，但它从输入主题的最新偏移量开始消耗。我知道应用程序处理的输入主题的偏移量。现在，如何处理从一个偏移量到另一个偏移量的输入主题。我正在使用confluent Platform 5.1.2。

浏览 0提问于2019-10-30得票数 0

1回答

如何取代/转型卡夫卡消费群体？

apache-kafka、apache-kafka-streams

我有一个包含多个Kafka流的存储库。我想将其中一个流提取到它自己的存储库中。但是，我不知道如何处理该流的消费者组。我的意思是:在新的存储库中，流将有一个不同的application.id。据我所知，使用者组的名称基于application.id设置。如果我简单地关闭旧流，对于每个主题的每个分区，新流将从第零偏移量开始，而不是从偏移量开始，而旧流已经停止。这将导致输出主题中的重复消息。我需要：关闭旧流</e

浏览 0提问于2020-03-23得票数 1

回答已采纳

1回答

为什么这个简单的MemoryStream.Write()实验失败了？

.net、memorystream

我被一个使用可写System.IO.MemoryStream的基本实验搞砸了，这个实验基于一个字节数组，提供一个ArgumentException。 ms.Write(byte(4), 1, 1);end try 异常是文本“偏移量和长度超出界限的数组或计数大于从索引到源集

浏览 0提问于2018-10-04得票数 2

回答已采纳

1回答

关于MimeMessage.Load的MimeKit性能问题

c#、mimekit

我目前正在为更大的MIME文件实现打印支持，从50MB的阈值到2000MB，我正在做一些性能测试，我注意到MimeMessage.Load(流)(这是方法)正在非常快地填满我的内存，对于一些运行打印机的平台来说现在，我正在给我的Load方法提供一个NetworkStream，我读到使用可以帮助我解决性能问题。有没有人有过同样的经历，也许可以解释一下如何加载持久化工作，以及如何避免使用太多内存？

浏览 0提问于2020-03-19得票数 0

1回答

从C++中的偏移量覆盖二进制文件的字节

c++、file-io

在此操作中，我首先复制源文件二进制文件。在这次行动中我遗漏了什么吗？ 

浏览 0提问于2019-04-01得票数 1

回答已采纳

1回答

在使用缓冲区写入DataOutputStream和从RandomAccessFile读取数据时出现问题

java、file-io、buffer、dataoutputstream

= -1){ }使用这段代码，我在f.read()中得到了一个索引越界异常。我可能错误地使用了参数偏移量和长度。不是每次我读入块的时候，我都应该将偏移量移动到块的大小吗？也许我只需要一次读取更少的内容，并使用更小的缓冲区？目前，我已经实现了这个功能，但是我担心内存的使用： DataOutputStream lWriter = new DataOutputStrea

浏览 1提问于2013-02-06得票数 0

回答已采纳

1回答

c# byte[]相当于asspan？

c#、io、.net-4.7.2

我发现使用System.Memory NuGet包可以使用“NuGet”方法。然而，写方法则需要一个偏移量和计数。不幸的是，我对文件操作一无所知。有人能帮帮我吗？

浏览 3提问于2022-05-14得票数 0

回答已采纳

2回答

Delphi TFileStream.Seek，如何检查无效的寻道偏移

delphi、filestream、tfilestream

我正在使用Delphi2006中的TFileStream。当我使用超出范围的偏移量调用TFileStream.Seek时，我得到了不同的返回值。当我查找到流开头以下的位置时，函数返回-1，如果我查找流大小之外的位置，函数将返回流中的位置(如果流那么大)。是否有一种方法可以检查对流的查找操作是否成功？当寻道偏移量超出当前流大小的范围时，为什么TFileStream.Seek不会失败？提前谢谢。

浏览 5提问于2010-07-21得票数 2

回答已采纳

1回答

如何进一步处理不能被Tika / PDFBox解析但可以通过Evince / Libre绘图的but /格式错误的PDF？

pdfbox、apache-tika

使用mutool show -be mypdf.pdf 29输出一个warning: PDF stream Length incorrect，然后输出压缩的内容。(偏移量16945)：循环检测到解析对象35 0警告: myPDFWithIssues.pdf(对象35 0，偏移量16946)：试图恢复流长度警告: myPDFWithIssues.pdf (对

浏览 12提问于2022-05-14得票数 1

回答已采纳

1回答

是否有办法从卡夫卡流中的特定偏移量读取火花流作业？

java、apache-kafka、spark-streaming

我试图使用以下方法从我的星火流工作到Kafka进行抵消：我知道，没有办法同步提交来自星火流作业的抵消(虽然如果我使用Kafka

浏览 0提问于2019-04-24得票数 4

回答已采纳

2回答

如何在发送reactor消耗的前100条消息后有条件地发布附加SSE web流量事件kafka主题

java、project-reactor、server-sent-events、webflux、reactor-kafka

我正在使用reactor-kafka库和spring webflux SSE流消费来自kafka主题的数据。当来自主题的所有消息都被消费完时，我需要返回一个特殊的ServerSentEvent，即最大主题偏移量get等于订阅时从0偏移量开始消耗的当前偏移量。有没有可能使用web flux来实现这样的目标？也就是说，如果我说在每100个元素从任何有限的元素列表中消费并作为ServerSentEvent发送到SSE流之后，这个SSE流应该再得到一个作为Se

浏览 7提问于2021-06-28得票数 1

2回答

有效地从缓冲区读取值

c++、c++11、c++14

我在内存中有一个std::vector<char>缓冲区，在特定偏移量处有一个数字。00 00 00 00 33 2E 31 34 99 99 99 .........3.14™™™ 我知道结束并开始偏移来读取double/float值，但是现在我用std::copy()将相关部分复制到一个例如:我可以将流指向另一个缓冲区中的特定偏移量吗？或者类似的东西

浏览 2提问于2015-12-04得票数 1

回答已采纳

1回答

fork()和缓冲IO流

io、fork、buffered

但是，当控制返回到父进程时，由于某种原因，文件偏移量被设置为文件的末尾，父进程无法从流中读取任何内容。如果fork()创建了一个文件描述符的dup (这在使用系统调用read()和write()复制相同的程序时工作得很好)，人们会期望父进程从流中读取下一行，但这里似乎没有发生这种情况。当控件到达父级时，文件偏移量设置为文件的末尾。谁能解释一下这件事？

浏览 8提问于2013-11-25得票数 0

1回答

使用wcf恢复和上载文件

wcf、file、uploading

我正在构建一个应用程序，以便使用wcf将文件从客户端上传到服务器，并且在连接失败时尝试实现一种恢复上传的方法。假设我有一个500 KB的文件，上传开始，连接失败，只有100 KB被复制。当我读取用这样的代码发送的流时：是0(偏移)我开始读取的字节吗？？

浏览 1提问于2011-06-08得票数 2

1回答

ffmpeg集应用一致的偏移量，不需要重新编码。

video、ffmpeg、offset、pts

我能够计算出任何给定视频的音频和视频流的结尾，并在转换序列中的后期视频时应用该结束(累积)偏移。我希望能够理想地复制视频/音频流。是否有任何方法为.ts文件的音频/视频流应用统一的文本偏移量，而无需重新编码整个文件？

浏览 2提问于2018-11-20得票数 5

回答已采纳

1回答

使用TextInputFormat和Python流-跟踪行号

python、hadoop、hadoop-streaming

我使用Python和Hadoop流，但我无法找到任何方法来配置Hadoop流以获得每一行的偏移量，正如所说，使用TextInputFormat。说要抛弃keys of LongWritable class，但我不确定这是否是偏移量。如何配置作业以获得偏移量？

浏览 1提问于2016-02-03得票数 1

回答已采纳

3回答

如何计算RTP中的有效时间偏移

voip、offset、rtp、timestamp

我必须计算RTP流中数据包之间的时间偏移量。对于使用Theora编解码器编码的视频流，我有时间戳字段，如 2940000 ...所以我假设传输偏移量是84000。对于音频规范编解码器，我有时间戳字段，如 38400 ... 所以我假设传输偏移量是320。为什么价值观如此不同？

浏览 0提问于2011-06-07得票数 2

回答已采纳

点击加载更多