回答情况：
提问时间：
问题标签：
数据存储到冰山表中，如下所示：val dataStreamkafkaStream.flatMap(new NullPacketFilter).map(FilteredPacket.from(_).toRow).javaStream
FlinkSink.forRow(dataStream
浏览 10修改于2021-02-19得票数 0
首先，一些上下文:四个MPR121突破板()通过i2C连接到一个Raspberry 2。一个python脚本从这四个板读取数据并用pdsend发送给纯数据。我很确定我需要更改os.system行来容纳变量，但是我找不到如何做到这一点。def send2Pd (message=' '):
os.system("echo '" +
浏览 6修改于2015-03-30得票数 1
回答已采纳
我有一个连接到服务器的程序，通过输入和输出数据流发送/接收数据。我想调试它，看看正在传递的消息是否正确，所以我必须读取通过流发送的消息，但连接有1秒超时。(在服务器端，我无法控制)有没有一种方法可以监听流，这样我就可以将数据从流中获取到控制台，并且仍然可以发送数据？ //Some code to make the console write whatever is sent in the out stream
//And received in the in s
浏览 1提问于2011-05-07得票数 2
List 注意到 提出了类似的问题，但它考虑的是一个简单的Scala ，而不是Flink (或 DataStream**). )。
浏览 5修改于2020-04-16得票数 2
回答已采纳
我是Flink的新手，以下是流式模式字数： //x is the stream of (word, 1) .flatMapwhat does the Tuple here mean in y
val z: DataStream
浏览 18提问于2019-01-13得票数 1
回答已采纳
尝试在模拟DataStream中注入一个字符串，以测试两个测试用例。我不确定如何用一些数据模拟Flink的DataStream对象。有什么想法吗？import org.apache.commons.lang3.StringUtilsimportwith valid string") { /
浏览 1修改于2017-07-13得票数 1
因此，我不得不使用更低级别的API (datastream)。
问题：--如果我可以用datastream对象创建一个表，那么我就可以接受在该表上运行的查询。这将使转换部分无缝和通用。可以在datastream对象上运行SQL查询吗？
浏览 3提问于2020-04-28得票数 2
回答已采纳
我只是在线程中使用普通的DataInputStream和DataOutputStream来接收、发送(在服务器上使用accept )来制作游戏，但它真的很慢。>5秒延迟。(dos为DataOutputStream)dos.writeFloat(dp.x);dos.writeFloat(dp.y);
dos = new D
浏览 2提问于2012-05-05得票数 5
回答已采纳
我认为应该有一些DataStream.addSink实现的MongoDB，但显然没有。Apache Kafka Broker --------------> Flink: DataStream<String>
re
浏览 3提问于2016-02-02得票数 11
回答已采纳
buffer); std::streamsize write(T value);std::streamsize DataStreamJava::read(double value) {
浏览 0修改于2015-07-31得票数 2
回答已采纳
我在我的测试用例中得到了一个分析类型的DataStream，我想为每个对象设置var c的值为'0‘。 我尝试过在DataStream上使用map函数，但没有帮助。
浏览 35修改于2019-05-11得票数 1
我试图从DataStream API开始，但是缺少一个模块。
你知道怎么回事吗？
浏览 12提问于2020-11-04得票数 0
回答已采纳
我想创建一个DataStream，并将来自另一个系统的值提供给它。所以，我想要做的是:当这个异步调用发生时，我想把值放到一个闪烁DataStream，伪代码：
mysystem.connect_to_values( (值) => { myflinkdatastream.put
浏览 2提问于2017-11-28得票数 1
假设我有两个DataStream<String>，我从Kafka收到了流，经过一些处理，我得到了这两个流。DataStream<String> A contains values {id1_id2 , id3_id4, id99_id0, id15_id3,id11_id5....}DataStream<String> B contains values {id2, id3,id5...}是否可以对DataStream A进行一些处理，以便它将值输出到另一个
DataStream
浏览 0修改于2020-12-10得票数 0
我有一个未绑定的DataStream，它代表了社交网络中的友谊。这些友谊可以是双向的，因此在流中出现两次。我的FilterFunction看起来像这样：
def filter(ds: DataStream[String]): DataStream[(String, String,
浏览 2提问于2018-07-01得票数 0
, Int]]，而是生成DataStream[Either[String, Int]] with Product with Serializable。我正在使用一些API，它确实接受DataStream[T]，如果我传递给他们一个DataStream[T] with Product with Serializable，我就会得到一个编译时错误。]
* [error] required: org.apache.flink.streaming.api.scala.DataStream[Either[?, but c
浏览 0提问于2018-02-14得票数 1
回答已采纳
{DataStream, StreamExecutionEnvironment} at org.apache.flink.streaming.api.scala.DataStream.cl
浏览 6修改于2017-05-02得票数 0
回答已采纳
我希望使用架构信息将DataStream转换为DataStream参数DataStreamargs1模式
SingleOutputStreamOperator<Stringorg.apache.
浏览 19修改于2020-03-07得票数 0
AWS ElasticSearch服务(OpenDistro)不支持吗？今天，我试图用AWS ElasticSearch服务创建数据流，但什么也做不了。试图获取数据流列表只是返回 "Message": "Your request: '/_data_stream' is not allowed."根据X文档，它声明在6.3之后的所有elasticsearch版本默认都有X，我在AWS elasticsearch服务上使用ElasticSearch版本7.10。
我在文档中找不到任何能显式说明是否支持这一点的东西。如果有人能提供更多
浏览 10修改于2021-06-17得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号