我想流式传输一个csv文件，并使用flink执行sql操作。但是我写的代码只读一次就会停止。它不会流式传输。StreamExecutionEnvironment.getExecutionEnvironment();
.path("D:/employ
浏览 11提问于2017-07-25得票数 4
回答已采纳
2回答
我正在用Apache Flink编写一个流媒体服务。我基本上是使用org.apache.flink.table.sources.CsvTableSource.从CSV文件中挑选数据。streamTableEnvironment = TableEnvironment
CsvTableSourcecsvTableSource = CsvTableSource</
浏览 4提问于2018-03-06得票数 3
我想使用Flink对Postgresql中的数据进行一些分析。我应该如何和在哪里给出端口地址，用户名和密码。我正在尝试使用链接：中提到的表源。ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
final static TableSource csvSource = new CsvTableSource
浏览 0提问于2018-06-21得票数 1
回答已采纳
1回答
也尝试使用CsvTableSource版本1.5.1Flink，但是语法不太好。由于.field("%CPU", Types.FLOAT())不断给出错误的类型浮点未被识别的符号。;import org.apache.flink.table.sources.CsvTableSourcecsvTableSource = new CsvTableSource<
浏览 0提问于2018-07-30得票数 2
回答已采纳
我的scala程序中有下面的代码，它使用Flink的Table。val custTS = new CsvTableSource("D:\\input\\customerinfo.csv", import org.apache.flink.table.api.TableEnvironment
import org.apache.flink.t
浏览 9提问于2017-03-24得票数 0
回答已采纳
在Spark中，我们可以使用推断模式从文件中动态读取模式，例如：在弗林克有办法做同样的事吗？
浏览 3提问于2017-12-28得票数 1
回答已采纳
URL fileUrl = HotItemsSql.class.getClassLoader().getResource("UserBehavior-less.csv"); .field("userId", BasicTypeInfo.LONG_TYPE_INFOBasicTypeInfo.LON
浏览 0提问于2019-11-27得票数 2
回答已采纳
我试图用Flink 1.5.0创建一个面向批处理的Flink作业，并希望使用Table和SQL来处理数据。引起于据我所知，我不依赖于流环境;import org.apache.flink.table.api.TableEnvironment;
import
浏览 1提问于2018-06-19得票数 0
我有一个像这样的集群，在这个集群中，我有多个对应于每个主机的分片的CSV。我想使用表API来计算多个主机上CSV列的总和。每个工人应该能够计算出他所拥有的CSV的总和，并将结果返回到主服务器上。这是可能的吗?如果是，我应该实现什么。
浏览 0提问于2018-05-10得票数 0
1回答
按两列连接单个表flink表
、、、、
SELECT * JOIN Data t2 ON t1.s = t2.oval csvTableSource = CsvTableSource .ignoreParseErrors .build()val table
浏览 1提问于2018-06-27得票数 1
回答已采纳
我正在搜索函数from_unixtime(bigint unixtime)的等效值，该函数存在于Spark和Flink-SQL中。
浏览 0提问于2018-09-06得票数 2
1回答
目前，我正在使用AWS Kinesis/Flink和Scala --我有以下体系结构：
如您所见，我使用CSVTableSource使用CSV文件。不幸的是，CSV文件对于Flink作业来说太大了。
浏览 1提问于2022-01-06得票数 0
我已经将数据从CSV文件导入到Flink Java中。由于解析错误，我不得不将其中一个属性作为字符串(属性Result)导入。现在，我想将字符串转换为双精度。我查看了flink文档，并尝试了一些使用Map和FlatMap类的解决方案。但是我没有找到解决这个问题的办法。TableSource csvSource = CsvTableSource.builder() .fieldDelimiter
浏览 11提问于2019-10-17得票数 0
1回答
我使用的是flink 1.9.0，无法导入或获取表文件 我已经尝试导入与之相关的不同SBT def main(args: Array[String]): Unit = { val tEnv = StreamTableEnvironment.create(env)
val tempSource = CsvTableSource.builderCould not access type SelfResolvingTyp
浏览 22提问于2019-10-01得票数 0
众所周知，Flink有两个核心mode.So (数据流/数据集)，但是当我使用flink Sql客户端提交作业时，我不需要选择流或批处理API，因为Flink SQL客户端如何决定使用批处理模式和流模式那么，我想知道Flink SQL Client如何区分批处理模式和流模式？
浏览 29提问于2019-12-23得票数 0
回答已采纳
flink流具有多个数据流，然后使用org.apache.flink.streaming.api.datastream.DataStream#union方法对这些数据流进行合并。然后，我得到了问题，数据流是混乱的，我不能设置窗口来对数据流中的数据进行排序。Sorting union of streams to identify user sessions in Apache Flink 我得到了答案，但com.liam.learn.flink.exam
浏览 30提问于2019-01-12得票数 2
1回答
Table t = tableEnv.sqlQuery("SELECT result FROM HBATable " );
TableSource csvSource = CsvTableSource.builder
浏览 3提问于2019-10-18得票数 1
回答已采纳
1回答
为了丰富数据流，我们计划将MySQL (MemSQL)服务器连接到现有的flink流应用程序此外，我还发现了另一个名为Flink-CDC https:&
浏览 19提问于2022-02-07得票数 0
回答已采纳
事件数据报
现在我有了一个tuple3的数据仓库，它看起来像<ruleId, Rule, Event>。我正在学习动态表和Flink SQL的概念。我不知道如何进一步处理。有人能帮帮我吗？
浏览 0提问于2018-02-09得票数 0
我们感兴趣的是从连接到常规的Flink流应用程序，最好使用Table。这样做的想法是查阅Statefun在Flink中注册的表，是否有此可能，如何做才是正确的方法？到目前为止，我的想法是在一些主函数中初始化我的表流，并注册一个有状态函数提供程序来连接到该表：public classFnEnrichmentCallback.TYPE, myTable.select("max(amount)").toString(),
浏览 2提问于2020-04-11得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
