streaming

    0热度

    1回答

    我有一个小场景,我读取文本文件并根据日期计算平均值并将总结存储到Mysql数据库中。 以下是代码 val repo_sum = joined_data.map(SensorReport.generateReport) repo_sum.show() --- STEP 1 repo_sum.write.mode(SaveMode.Overwrite).jdbc(url,

    0热度

    1回答

    我不明白StreamExecutionEnvironment.readFile方法。 FileProcessingMode有2个选项:PROCESS_ONCE和PROCESS_CONTINUOUSLY。如果我们选择前者,它只处理一次文件,并在execute()后退出。如果我们选择后者,即使我们只是在文件中添加一些行,它会再次处理整个文件(添加所有文件,例如,在最后一次处理之前的每个单词的计数)。我

    0热度

    2回答

    Kinesis Firehose以及Kinesis Streams用于根据AWS博客中提到的细节加载流式数据。在Firehose的情况下没有碎片或维护的概念。在这种情况下,Kinesis Firehose是Kinesis Streams的替代品吗?

    1热度

    1回答

    我想从Apache Flink DataStream捕获事件,每个“自然”小时。也就是说,我想捕捉事件从12:00:00窗口,直到12:59:59,13:00:00,直到13点59分59秒...... 我一直在使用: datastream.keyBy(0) .timeWindow(Time.minutes(60)) 但是,我怎么知道那些每分钟开始的60分钟,并且窗口不是例如从12:30:00

    -2热度

    1回答

    我正在使用ApachePOI,但它并没有解决ms字流的机制,所以我越来越OutMemeory异常(我正在使用4GB的RAM)

    0热度

    1回答

    假设我有ň制片人,对于每一个时间戳吨卡夫卡发送数据。消费者获取时间戳t的数据的条件是从所有生产者接收到用于时间戳t的数据。 卡夫卡是否让消费者做这样的检查?或者让卡夫卡为这样的问题提供任何策略?

    0热度

    1回答

    我一直在寻找网络,看着各种WCF书籍而没有找到答案 - 所以现在我在这里尝试我的运气。 我正在创建一个WCF服务,该服务向其他利益相关者公开了一些方法。其中一种方法是连续的实时数据流,它将通过MessagePack序列化(请参见下面的示例)。 [ServiceContract] public interface IMyHappyStreamingService { [Operatio

    2热度

    4回答

    我是Java的新手,我想用它做一些很酷的事情。作为第一步,我想出了为我的家建立本地服务器的想法。我想要一个简单的服务器在没有互联网的情况下运行,所有连接到家庭WiFi的设备都可以查看。 在稍后的阶段,我打算用它做各种各样的东西,比如初学者一个简单的聊天应用程序。或者在我的设备之间共享文件的门户。 而在最终产品中,我想做流式传输。就像主机在服务器上播放音乐一样,所有连接的设备都可以进入该页面并听完完

    4热度

    1回答

    有没有人与koa.js和流一起工作? 考虑这个例子 const fs = require('fs'); const Koa = require('koa'); const app = new Koa(); app.use(async (ctx) => { ctx.body = fs.createReadStream('really-large-file'); }); ap

    0热度

    1回答

    我正在iOS中做转录应用。所以,我必须将音频记录在缓冲区中,并通过套接字将它们传输到服务器。所以,我用AudioQueue将音频录制在缓冲区中。 音频正在本地文件中正确记录。对于流媒体,我将音频数据转换为NSData并通过套接字发送。但是,服务器中的音频质量并不好,尤其是语音不清晰。它包含很多声音的地方的噪音。同样的逻辑在Android中正常工作。所以,服务器端代码工作正常。但是,iOS流式转换是