腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
在
使用
scala
case
类
时
,
Flink
不允许
POJO
对象
使用
不
可变
的
样式
设置
器
scala
、
apache-flink
相关问题:https://issues.apache.org/jira/browse/
FLINK
-14380
在
使用
类型提取
器
Flink
判断一个
类
是否符合
POJO
时
,
Flink
会检查该类是否实现了setter对于setter方法,
Flink
断言返回类型为Void。如果经常
使用
case
类
,
case
<
浏览 37
提问于2019-10-12
得票数 2
1
回答
Flink
窗口状态大小和状态管理
apache-flink
、
stream-processing
在
阅读了
flink
的
文档和搜索之后,我不能完全理解
flink
是如何处理窗口中
的
状态
的
。假设我有一个每小时滚动一次
的
窗口,其中包含一个聚合函数,该函数将msg累积到某个java
pojo
或
scala
case
类
中。该窗口
的
大小是与
在
一个小时内进入该窗口
的
事件
的
数量相关,还是仅仅与
pojo
/
cas
浏览 49
提问于2019-03-20
得票数 5
回答已采纳
1
回答
如何在
Flink
1.7中对
scala
case
类
使用
Avro序列化?
scala
、
apache-flink
、
avro
、
flink-streaming
我们有一个用
Scala
编写
的
Flink
作业,
使用
case
类
(由avrohugger从avsc文件生成)来表示我们
的
状态。我们希望
使用
Avro来序列化我们
的
状态,这样当我们更新我们
的
模型
时
,状态迁移就会起作用。我们从
Flink
1.7开始就知道Avro序列化是支持OOTB
的
。我们将
flink
-avro模块添加到
类
路径中,但从保存<
浏览 16
提问于2019-03-21
得票数 1
2
回答
在
反序列化期间将
POJO
映射到具有不
可变
列表
的
case
类
java
、
scala
、
immutability
、
case-class
、
json4s
我来自Java背景,并试图了解如何在
Scala
中建模域
类
/
POJO
。] 问题: 1)
在
DataSetGetResponse
case
类
中,字段“列”是List.By默认值--这是
浏览 0
提问于2019-07-19
得票数 1
回答已采纳
1
回答
DataSet/DataStream
类
接口
scala
、
apache-flink
、
typeclass
、
subtyping
、
adhoc-polymorphism
我只是尝试
在
Flink
中
使用
Scala
类型
的
类
。为什么
在
EventSyntax2中
使用
case
类
包装
器
比
在
EventSyntax中
使用
常规
类
更有问题?在这里,我只是为了学习而尝试类型
类
模式,但在我看来,一种更面向
对象
的
方法(基于子类型)看起来更简单。List 注意到 提出了类似的问题,但它考
浏览 5
提问于2020-04-13
得票数 2
回答已采纳
7
回答
何时
使用
case
类
或常规
类
scala
我有一些误解,
在
什么情况下,我应该
使用
案例
类
或常规
类
,然后再
使用
最佳实践。我已经读过关于这两个
类
的
差异,但无法想象自己
在
现实生活中
的
例子中推荐
使用
用例或常规
类
。谁能给我举个真实
的
例子,解释为什么推荐这样做,而不是其他方式?
浏览 22
提问于2014-09-30
得票数 53
2
回答
如何在
flink
中
使用
joda.time (或如何
使用
typeutils.runtime.kryo)
serialization
、
jodatime
、
kryo
、
apache-flink
在
flink
项目中,我
使用
case
类
单击。
case
class click( date: LocalDateTime, stbId:String, channelId :Int) 这个
类
填充了DataSets,并且
在
日期为java 8 java.time.LocalDateTime
在
java7环境中切换到org.joda (版本2.9)之后,对DataSets中
的
click
对象
的
调
浏览 11
提问于2015-11-11
得票数 4
回答已采纳
2
回答
如何在Intellij中为
scala
的
所有字段生成getter和setter
java
、
scala
、
intellij-idea
、
intellij-14
我有下面的代码 private var name : String = _}谷歌
的</e
浏览 1
提问于2018-10-19
得票数 0
回答已采纳
1
回答
scala
中
的
Val不是不变
的
scala
我只是
在
玩
scala
,并且做了一些非常基本
的
Val分配,参见下面,如果我重新分配val,它看起来就像一个var。
scala
> val number = 1717 number: Int= 20 res1: Int = 20
scala
> val string =
浏览 2
提问于2013-09-09
得票数 0
回答已采纳
2
回答
Gson将小写JSON反序列化为camel-
case
Class
对象
java
、
json
、
serialization
、
gson
、
deserialization
我试图用
设置
为小写
的
所有字段来反序列化JSON。问题是:我
的
POJO
对象
的
属性
设置
为camel-
case
,而当我尝试用Gson.fromJson反序列化时,没有
设置
camel-
case
属性。
Pojo
类
的
列表,是因为
在
我
的
代码中,我不知道我应该创建哪个
类
。问题是:
在
反序列化之后,没有
设置
浏览 2
提问于2017-08-10
得票数 0
回答已采纳
2
回答
喷射Json编组
可变
对象
scala
、
spray-json
在
我
的
应用程序中
的
案例
类
中,我很难编组
可变
对象
。我正在
使用
喷雾库,我已经做了必要
的
进口 import DefaultJsonProtocol._但是,当我试图为
case
类
提供伴生
对象
时
,会出现以下错误。[String]] 其他没有
可变
浏览 4
提问于2015-11-26
得票数 1
回答已采纳
4
回答
如何在
Scala
中
使用
POJO
等效项?
scala
假设我有以下内容以下内容有什么问题?println(mySimple.myInt)
浏览 0
提问于2011-07-17
得票数 23
回答已采纳
1
回答
非
case
类
的
“‘copy”?
scala
在
设计不
可变
对象
时
,
case
类
非常方便,因为它是自动生成
的
copy方法。class De
浏览 0
提问于2011-07-10
得票数 20
回答已采纳
1
回答
对
可变
状态
使用
case
类
(真的)不好吗?
scala
、
mutable
、
case-class
{ this.y += v.y }如您所见,
case
class保持
可变
状态。这是非常气馁
的
做法,通常我会同意和绝对坚持这个“规则”,但这是一个完整
的
故事。 我正用
Scala
从头开始编写一个3D游戏引擎。因此,首先我考虑
使用
一种(更多
的
)功能
样式
,但是垃圾收集
器
会经常出现。如果我要在这些
类
中运行(Vector3和Matrix4)
浏览 3
提问于2015-09-24
得票数 3
回答已采纳
2
回答
用默认值填充
可变
映射或替代
Scala
函数回溯
的
可变
映射
scala
、
dictionary
、
default-value
我知道withDefault允许您指定将应用于键
的
函数以生成默认
的
映射值,但每当您将未知键传递到映射中
时
,都会调用该函数,即使您传递相同
的
键--这些值没有存储
在
映射中。
scala
>
case
class Foo(foo: String) {}creating value for elvis re
浏览 2
提问于2016-02-04
得票数 2
1
回答
我应该以什么二进制格式向德鲁伊( FlinkKafkaProducer[<
Scala
case
class>]发送事件)吞食卡夫卡主题?
scala
、
apache-kafka
、
apache-flink
、
flink-streaming
、
druid
Flink
应用程序生成
Scala
类
的
DataStream (在下面的代码中为ExampleData)。根据,
Scala
类属于“
Flink
提供
的
特殊序列化
器
”,但我不确定它是如何被序列化
的
,因此当Druid从Kafka主题读取它
时
,它是如何被反序列化
的
(即以什么格式)。(我不想向
Flink
应用程序添加依赖项,除非有充分
的
理由,以降低维护成本) 所以我
的</e
浏览 5
提问于2021-08-06
得票数 0
回答已采纳
5
回答
带val字段
的
Scala
不
可变
对象
和特征
scala
、
immutability
、
scala-2.8
、
traits
我只想
使用
不
可变
的
对象
来构造我
的
域模型。但是我也想在val字段中
使用
特性,并将一些功能转移到特性上。name = "Scot") 据我所知,目前
Scala
中缺乏这样
的
功能,
不允许
使用
不
可变
的
类
和特征,而不
使用
带有属性字段
的
类
构造函数。我知道copy方法
在
case</
浏览 5
提问于2010-08-11
得票数 11
2
回答
运行用maven构建
的
jar
时
的
FlinkMLTools NoClassDef
maven
、
jar
、
noclassdeffounderror
、
apache-flink
、
flinkml
我正在
使用
Apache开发一个推荐系统。当我
在
IntelliJ中测试它
时
,这个实现正在运行,但是现在我想在集群上运行它。java.lang.NoClassDefFoundError: org/apache/
flink
/ml/common/
flink
ml$ 正如我们所看到
的
,
在
我
的
代码中
使用
的
类
FlinkMLTools是
在
ja
浏览 1
提问于2015-07-15
得票数 4
回答已采纳
2
回答
在
Scala
case
类
中
设置
setter和getter
的
格式
scala
、
encapsulation
在
Scala
中,我有一个
case
类
: type MonthSelection = Value } 当我有一个
case
类
的
实例
时
,我必须
使
浏览 2
提问于2012-05-02
得票数 1
回答已采纳
2
回答
在
Scala
中
设置
多个
对象
属性?
scala
、
attributes
我不太确定它
的
正确名称,但是
在
Scala
中是否有一种方法可以同时
设置
/更改一个
对象
的
多个属性?(
对象
已经初始化)sampleObject.{ quantity = 5相对于:sampleObject.quantity = 5
Scala
有这样<
浏览 5
提问于2015-01-26
得票数 4
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Apache Flink 进阶(五):数据类型和序列化
重要:优化flink的四种方式
一文解决现代编程语言选择困难:响应式编程
剖析Java15新语法特性
Flink 流式计算在节省资源方面的简单分析
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券