腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Apache
Flink
-
Dataset
api
端
输出
、
Flink
是否支持数据集(Batch
Api
)中的副
输出
功能?如果不是,从文件加载时如何处理有效记录和无效记录?
浏览 7
提问于2020-02-01
得票数 1
2
回答
为泛型类使用clojure中的类型提示
、
、
、
、
这是我的代码: (:import (org.
apache
.
flink
.
api
.common.functionsFlatMapFunction) (org.
apache
.
flink</em
浏览 2
提问于2015-08-20
得票数 5
回答已采纳
2
回答
在map函数内部闪动
DataSet
连接
、
、
、
、
我只是想知道这在
Flink
中是否可行。我知道map函数本身是作为单独分区的单独任务运行的,所以我想知道map函数内部是否允许分布式连接?
浏览 17
提问于2018-01-21
得票数 0
1
回答
将
DataSet
<Row>保存为CSV
是否可以将元组另存为CSV
输出
?toDataSet
DataSet
<Row>需要Row.class,而writeAsCSV需要元组。你能帮帮忙吗?
DataSet
<Row> finalResult = tEnv.toDataSet(flattenedTripByGender, Row.class);这是一个错误: Caused by: java.lang.ClassCastExc
浏览 0
提问于2016-11-30
得票数 3
1
回答
IDE eclipse中的scala和maven错误
、
、
at org.
apache
.
flink
.
api
.common.PlanExecutor.createLocalExecutor(PlanExecutor.java:161) at org.
apache
.
flink
.
api
.java.LocalE
浏览 0
提问于2016-09-06
得票数 0
2
回答
当
flink
组case类对象时NPE
、
、
我使用
dataSet
API
,我有两种案例类。:56) at org.
apache
.
flink
.
api
.scala.
DataSet
$$anon$5$$anonfun$flatMap$1.apply(
DataSet</em
浏览 5
提问于2016-11-04
得票数 0
回答已采纳
1
回答
如何在
Flink
中以本地执行方式执行batch sql?
、
据我所知,
Flink
支持本地执行模式(请参考https://nightlies.
apache
.org/
flink
/
flink
-docs-release-1.14/docs/dev/
dataset
/local_execution但我想使用本地执行CollectionEnvironment在
flink
中执行批处理sql,以保持与在线服务和离线训练数据集功能工程的一致性。 谁能告诉我如何使用本地模式执行batch
浏览 67
提问于2021-11-16
得票数 0
1
回答
Flink
linearRegression:如何加载数据(Scala)
、
、
(x._1,x._2,x._3)) } mapped: org.
apache
.
flink
.
api
.scala.
DataSet
[org.
apache
.
flink
.ml.common.LabeledVector] = org.
apache
.
flink
.
api
.scala.
DataSet
@7cb37ad3 LabeledVector(6.7, DenseVect
浏览 10
提问于2017-05-31
得票数 0
回答已采纳
1
回答
Flink
多元线性回归:它有预测吗?
、
、
、
阅读,我理解输入是一个标记向量,
输出
是一个包含元组InputValue,PredictValue的数据集,对吗?我创建了我的标记向量:mapped: org.
apache
.<
浏览 8
提问于2017-06-02
得票数 0
回答已采纳
1
回答
公文中` `Projection of Tuple
DataSet
`的正确示例是什么?
我现在正在学习
Flink
DataSet
Transformations 我正在阅读的部分是Projection of Tuple
DataSet
但是in的示例senv.fromElements(1,6.56,"study")是错误的, import org.
apache
.
flink
.
api
.java.tuple.Tuple3; import org.
apache
.
flink
.
api
.java.tuple.Tup
浏览 15
提问于2020-06-22
得票数 0
回答已采纳
1
回答
Apache
SQL InvalidProgramException:选定的排序键不是可排序的类型
、
= c.reportCodeException in thread "main" org.
apache
.
flink
.
api
.common.InvalidProgramException(SortPartitionOperator.java:111) a
浏览 8
提问于2020-08-11
得票数 0
回答已采纳
1
回答
Flink
Scala“参数不足”
、
[String])org.
apache
.
flink
.
api
.scala.
DataSet
[String].- could not find implicit value for evidence parameter of type org.
apache
.
flink
.
api
.common.typeinfo.TypeInformation[String])org.
apache
.
flink
.
api
.scala.
Dat
浏览 0
提问于2015-04-09
得票数 11
回答已采纳
2
回答
如何用齐柏林飞艇将
Flink
var的内容写入屏幕?
、
%
flink
"ARTHUR: What, behind the rabbit?"但不幸的是,我只得到了以下
输出
。rabbit: org.
apache
.
flink
.
api
.scala.
DataSet
[String] = org.
apache
.
flink
.
api
.scala.
DataSet
@37fdb65c counts: org.<
浏览 3
提问于2015-09-04
得票数 5
回答已采纳
1
回答
TypeInformation for
Apache
Flink
1.3.2 BatchTableEnvironment的translate方法
我想我提供了所有的details...theimport org.
apache
.
flink
.
api
.java.
DataSet
;import org.
apache
.<e
浏览 0
提问于2017-10-29
得票数 0
2
回答
本地执行示例
Flink
程序
、
import org.
apache
.
flink
.
api
.common.functions.FlatMapFunction;import org.
apache
.
flink
.
api
.java.ExecutionEnvironment; import org.
apache
.
flink
.
api</
浏览 2
提问于2015-06-01
得票数 7
2
回答
出现java.lang.NoSuchMethodError异常的Flick WordCount示例失败
: org.
apache
.
flink
.core.memory.MemorySegmentFactory.initializeFactory(Lorg/
apache
/
flink
/core/memory/MemorySegmentFactory:236)at org.
apache
.<
浏览 0
提问于2017-03-17
得票数 2
1
回答
在
apache
flink
中使用
DataSet
的collect()函数时出现问题
、
、
下面是我的代码: import org.
apache
.
flink
.
api
.java.ExecutionEnvironment; import org.
apache
.
flink
.
api
.java.tuple.Tuple2; import org.
apache
.
flink<
浏览 97
提问于2020-09-10
得票数 0
1
回答
关于泛型参数的
Flink
Scala
API
函数
我希望能够传递
Flink
的
DataSet
,并对其执行一些操作,但是数据集的参数是通用的。我现在遇到的问题是:import org.
apache
.
flink
.
api
.scala._arguments for method map: (implicit evidence$256: org.
apache
.
flink</em
浏览 2
提问于2015-04-09
得票数 3
回答已采纳
1
回答
flink
ClassNotFoundException ProcessFunction
、
我有一个
flink
演示,可以找到
dataSet
1的一列,而不是在其他
dataSet
中。我用
flink
sql编写它。这看起来和代码没什么关系,但不起作用。org.
apache
.
flink
.
api
.common.functions.MapFunction;importorg.
apache
.
浏览 1
提问于2019-05-05
得票数 1
1
回答
闪烁序列化错误
、
、
我正在尝试在我的
Apache
Flink
Gelly图上运行标签传播协议。return inputValue; .run(new LabelPropagation<String, Long, String>(10)); org.
apache
.
flink
.
api
.common.InvalidProgramException:对象org.
apache
.
flink
.graph.Graph$ApplyCoGro
浏览 2
提问于2016-07-27
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Flink基础教程(二):初探Flink
Flink概念:编程模型下
《从0到1学习Flink》——Apache Flink 介绍
Apache Flink的下一步:不止于流处理
Apache Flink 1.10.0 重磅发布,年度最大规模版本升级
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券