腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
FlatMapFunction
没有
定义
serialversionUid
、
SparkJob { private static final long
serialVersionUID
ScanRDD
浏览 32
提问于2020-04-29
得票数 1
回答已采纳
1
回答
使用Cassandra的Java Spark流
、
、
、
、
网络上
没有
给我任何关于java spark流媒体和Cassandra的例子。
浏览 2
提问于2017-02-09
得票数 0
1
回答
不能在flatMap后使用数据分组(Spark )
、
、
.option("header", true) private static final long
serialVersionUID
= 1L; private int cnt = 0;
浏览 3
提问于2021-12-02
得票数 0
回答已采纳
2
回答
java.lang.ClassCastException:不能将scala.Tuple2转换为java.lang.Iterable
、
java.lang.IterableJavaRDD<Tuple2<Integer, String>> artistByID0 = rawArtistData private static final long
serialVersionUID
= 1L; @SuppressWarnings
浏览 3
提问于2015-06-04
得票数 1
回答已采纳
0
回答
重新设置构建路径后不接受Iterator<String>
、
、
、
static
FlatMapFunction
<Tuple2<String, String>, String> sentimentFunc = new
FlatMapFunction
<Tuple2<String, String>, String>(){ @Override
浏览 5
提问于2017-06-14
得票数 0
回答已采纳
2
回答
为什么我的flink程序
没有
加入两个流?
、
"}我也使用了interval join以及使用TumblingEventTimeWindows和滑动窗口的JoinFunction,但它
没有
连接客户和地址流DataStream<Customer> customerStream = env.addSource(flinkKafkaConsumer) .flatMap(new
FlatMapFunction
<String,
浏览 17
提问于2020-05-15
得票数 0
2
回答
匿名类
没有
参数。
JavaRDD<String> lines = ctx.textFile(args[1], 1); } }根据我的理解,从第12行开始,它将匿名类
FlatMapFunction
它似乎
没有
将创建的String s作为参数传递,
浏览 3
提问于2014-11-23
得票数 0
回答已采纳
2
回答
如何获取Apache中筛选函数中不匹配的值的输出
、
、
org.apache.flink.api.common.functions.FilterFunction; * private static final long
serialVersionUID
}); DataStream<Tuple2<
浏览 1
提问于2020-05-12
得票数 0
回答已采纳
2
回答
从星火中的多个.gz文件读取特定文件
、
、
、
我正在尝试读取一个具有特定名称的文件,该文件存在于一个文件夹中的多个.gz文件中。D:/sample_datasets/gzfiles |-my_file_1.tar.gz |-my_file_1.tar |-file1.csv |-file2.csv |-file3.csv |-my_file_2.tar.gz |-my_file_2.tar |-file1.csv |-file2.csv |-file3.csv 我只对读取file1.csv的内容感兴趣,它在所有.gz文件中都有相同的模式
浏览 4
提问于2019-08-30
得票数 0
回答已采纳
1
回答
Flink未向Cassandra中的Store发出值
testKey", name = "contact")} 而Mapper代码是, DataStream<Reading> sideOutput = stream.flatMap(new
FlatMapFunction
setMapperOptions(() ->
浏览 6
提问于2020-08-13
得票数 0
回答已采纳
1
回答
反序列化ArrayList
、
、
、
、
在新的会话中,我很难从Java文件中反序列化对象。为什么会这样?public void LoadPersonListFromFile(String Filename) try PersonList = new ArrayList<Person>(); ObjectInputStream in = new ObjectInputStream(new
浏览 3
提问于2013-05-13
得票数 2
回答已采纳
1
回答
抽象异常类中的串行版本uid
、
、
、
我有一个基本的自
定义
异常类BaseException以及扩展BaseException的几个自
定义
异常 private static final long
serialVersionUID
浏览 2
提问于2020-04-29
得票数 0
回答已采纳
1
回答
java.lang.ClassCastException: java.io.ObjectStreamClass不能强制转换为[MyClass]
、
、
、
、
对于传输,我使用了一个自
定义
类Message,它包含一个包含要执行的操作的字符串(这里不相关)和一个作为实际消息的对象。在本例中,这将是一个ArrayList<User>。
浏览 63
提问于2020-03-02
得票数 0
1
回答
Apache WordCount - NoResult - PyFlink
、
、
、
该程序
没有
抛出任何错误,也
没有
提供所需的输出。根据代码,程序应该创建一个新的文本文件,但在执行时
没有
生成任何文件。请帮助,我的代码附在下面。flink.plan.Constants import WriteModefrom flink.functions.
FlatMapFunction
import
FlatMapFunction
from flink.functions.GroupReduceFunct
浏览 2
提问于2022-01-12
得票数 0
2
回答
为泛型类使用clojure中的类型提示
、
、
、
、
(:import (org.apache.flink.api.common.functions
FlatMapFunction
) (defn tokenizer [] (reify
FlatMapFunction
java.lang.IllegalArgumentException: The typ
浏览 2
提问于2015-08-20
得票数 5
回答已采纳
2
回答
使用
serialVersionUID
的数组类?
、
、
我很难理解来自的这个评论 数组类不能声明显式的
serialVersionUID
,因此它们总是具有默认的计算值,但是对于数组类,不需要匹配
serialVersionUID
值。也许我无法理解显而易见的事情,但是,我还
没有
想过我为什么要这么做呢?
浏览 5
提问于2013-10-07
得票数 1
1
回答
Flink自
定义
度量标准未在Datadog中显示。
、
、
在Flink中,我使用Python在
FlatMapFunction
中生成自
定义
度量。class OccupancyEventFlatMap(
FlatMapFunction
):但是我在Datadog中
没有
看到任何自
定义
度量
浏览 16
提问于2022-11-16
得票数 0
1
回答
绘制圆圈时InvalidClassException。为什么?
、
、
、
我学习了一个关于developers.android.com的教程: at
浏览 2
提问于2015-09-25
得票数 0
回答已采纳
2
回答
输出中存在重复键。
、
.sum(1); env.execute(); } class TestSource implements SourceFunction&l
浏览 0
提问于2019-01-31
得票数 0
回答已采纳
1
回答
无数据时停止提交作业
、
、
、
我使用spark streaming通过自
定义
接收器从mq中的队列中获取数据。Javastreaming上下文持续时间为10秒。并且为来自队列的输入
定义
了一个任务。在spark UI中的事件时间线中,我看到每隔10秒就会提交一个作业,即使
没有
来自接收方的数据。JavaDStream<String> words =lines.flatMap(new <
浏览 2
提问于2018-03-15
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
没有方向盘没有踏板,Cruise Origin重新定义自动驾驶
序列化和反序列化-JAVA成长之路
关于Java序列化的问题你真的会吗?
Android根据类排序生成签名字符串关于change和serialVersionUID的问题
serialVersionUID-JAVA成长之路
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券