stream

0热度

1回答

这可能是一个愚蠢的问题。但以下两个想法，与流处理时，这是概念性地正确： 1）的位置是字符之间（POS0）字节0（POS1）字节1（POS2）字节2 2）的位置是上的字符（POS0 /字节0）（POS1 /字节1）（POS2 /字节2）感谢

0热度

1回答

在开发简单应用程序时遇到与I/O相关的问题，我不确定为什么我的代码无法正常工作。我只拿走了那部分不工作的代码，并做了一个简单的例子。服务器类 public class Server { public static void main(String[] args) throws IOException { ServerSocket serversocket = new S

-2热度

1回答

PHP - 将文件从桌面流式传输到站点

我正在尝试创建文件上传以使用户能够将.txt文件保存到我的网站，但文件内容需要每隔N秒更新一次或从用户桌面进行流式传输进行实时更改。我比较喜欢用PHP运行，因为我比JavaScript更熟悉，但是我愿意接受所有建议。

1热度

1回答

如何在Node.js中关闭https流

我正在通过https加载.ndjson文件。我想在阅读100行文件后关闭它。 const amount = 100; https.get(url, (res) => { var { statusCode } = res; if (statusCode !== 200) { throw new Error(`Request Failed.\n Status

0热度

1回答

maprsteam with spring integration java client

我正在寻找一个解决方案，使用maprstream与弹簧整合。我可以创建流和主题，也可以使用流：主题组合来消费/发布消息。通过参考link来使用卡夫卡客户端：但是使用Spring集成努力消费/发布消息，并且看不到任何解释相同的示例程序。有人可以帮助我吗？

2热度

1回答

在Scala中编写带有偏移量的通用takeWhile

我有一个takeWhile的用例，但是我希望在谓词为true后保留固定数量的项目。我也试图把它写成尽可能通用的类型的集合。因此，像： def takeWhileWithOffset[A, Iter[_] <: Iterable[A]](iter: Iter[A], p: A => Boolean, offset: Int) 我选择Iterable为界，是因为希望它与Stream工作。但是我很难

1热度

1回答

nodejs pipe https对request.post和写入文件的响应

我使http代理程序检查http url，如果它是下载链接（content-type：octet-stream），我会得到响应并将响应中继给其他计算机通过使用request.post和其他计算机下载文件与http代理给出的响应。让我们假设Web代理计算机是A，它是A的代码部分192.168.5.253 if(contentType && (contentType== "application/o

1热度

1回答

加入包含Java哈希映射对象的Kafka流

目前我正在构建数据管道。我正在从sql数据库中读取2个表，并且我必须在使用kafka流将数据流加入到数据仓库后，将它们以非规范化格式存储在OLAP数据仓库中。而不是每个表有单独的主题，我有两个表将数据插入单个主题。我将行转换为散列表，然后使用字节序列化程序将此信息转换为字节数组并将其推送到主题，因此一行中的所有信息都存储在单个对象中。的代码是： ByteArrayOutputStream bo

1热度

2回答

流<Object>到InputStream

如何将 Stream<Object>转换为InputStream？目前，我得到的迭代器，并遍历所有的数据将其转换为ByteArray并将其添加到一个InputStream的： ByteArrayOutputStream bos = new ByteArrayOutputStream(); ObjectOutputStream oos = new ObjectOutputStream(bos);

0热度

1回答

捕获到数据库的串口流

我被困在一个应用程序，该应用程序应该从串口接收来自串行端口（工业权重）的数据，我必须仅将权值切割并将其发送到数据库。我遇到的唯一问题是抓住线和切割重量值。这是我做赶上串行流进文本框领域： public void write_to_field(object sender, EventArgs e) { if (textBox1.Text.Length <= Convert.ToInt