草庐IT

Mongo-Spark

全部标签

合并spark structured streaming处理流式数据产生的小文件

备注:By远方时光原创,可转载,open合作微信公众号:大数据左右手背景:做流批一体,湖仓一体的大数据架构,常见的做法就是数据源->sparkStreaming->ODS(数据湖)->sparkstreaming->DWD(数据湖)->...那么数据源->sparkStreaming->ODS,以这段为例,在数据源通过sparkstructuredstreaming写入ODS在数据湖(DeltaLake)落盘时候必然会产生很多小文件目的:为了在批处理spark-sql运行更快,也避免因为小文件而导致报错影响:WARNING:Failedtoconnectto/172.16.xx.xx:9866

java - 无法使用来自 Spark 的 GSC 连接器连接 Google 存储文件

我在我的本地机器上编写了一个spark作业,它使用谷歌hadoop连接器(如https://cloud.google.com/dataproc/docs/connectors/cloud-storage中提到的gs://storage.googleapis.com/从谷歌云存储读取文件)我已经设置了具有计算引擎和存储权限的服务帐户。我的spark配置和代码是SparkConfconf=newSparkConf();conf.setAppName("SparkAPp").setMaster("local");conf.set("google.cloud.auth.service.acco

java - 使用 Kerberos 设置 Spark SQL 连接

我有一个简单的Java应用程序,它可以使用Hive或Impala使用如下代码连接和查询我的集群importjava.sql.Connection;importjava.sql.DriverManager;importjava.sql.ResultSet;importjava.sql.SQLException;importjava.sql.Statement;...Class.forName("com.cloudera.hive.jdbc41.HS2Driver");Connectioncon=DriverManager.getConnection("jdbc:hive2://myHos

java - Spark : Read an inputStream instead of File

我在Java应用程序中使用SparkSQL对CSV文件进行一些处理,使用Databricks进行解析。我正在处理的数据来自不同的来源(远程URL、本地文件、谷歌云存储),我习惯于将所有内容都变成一个InputStream,这样我就可以在不知道数据来自哪里的情况下解析和处理数据来自。我在Spark上看到的所有文档都是从路径读取文件,例如SparkConfconf=newSparkConf().setAppName("spark-sandbox").setMaster("local");JavaSparkContextsc=newJavaSparkContext(conf);SQLCont

Spark写入kafka(批数据和流式)

Spark写入(批数据和流式处理)Spark写入kafka批处理写入kafka基础#spark写入数据到kafkafrompyspark.sqlimportSparkSession,functionsasFss=SparkSession.builder.getOrCreate()#创建df数据df=ss.createDataFrame([[9,'王五',21,'男'],[10,'大乔',20,'女'],[11,'小乔',22,'女']],schema='idint,namestring,ageint,genderstring')df.show()#todo注意一:需要拼接一个value#在写入

java - 使用 Spring 定义 Mongo 模式验证

我想使用Spring-boot和JSONSchemavalidator选项在Mongo中定义一个集合(https://docs.mongodb.com/manual/core/schema-validation/#json-schema),我不想要JSR-303Bean验证(这不是有效答案SpringdatamongoDbnotnullannotationlikeSpringdataJpa),但在创建集合时定义一个选项,该选项使用CollectionInfos()显示在JSON中。例如,如果我定义一个Account模型类,例如:publicclassAccount{@Idprivate

java - 如何访问 spark javadoc 或来自 java 项目的源代码?

我在IntelliJ14CE上使用Java项目中的Spark。有没有办法导航到Spark源或javadoc?默认情况下,它只显示粗略的反编译代码,没有任何注释。如果有办法的话,我不介意导航到scala代码。但也许插入javadoc会更好,但我在任何地方都找不到它谢谢 最佳答案 我的诀窍是为IntelliJ安装Scala插件,然后我能够通过spark核心(用scala编写)进行导航和调试,尽管项目是用Java编写的,并且正确地看到Javadoc,它是从scala源代码中自动推断出来的。当然,您还需要正确设置Spark源代码,使用Gra

java - Spring boot 2.0.5.RELEASE 和 mongo 4.0 连接问题

我正在关注Springwebsite上的使用MongoDB访问数据教程我安装了MongoDB服务器版本4作为服务当我使用客户端连接到它时,它的身份验证工作正常。我面临以下问题:MongoCommandException:Commandfailedwitherror18:'Authenticationfailed'我看到代码使用的是与服务器版本4不兼容的mongodb-driver-core-3.6.4.jar如何在不打乱项目的情况下只升级驱动?为什么他们使用spring-boot-starter-data-mongodb而不是mongodb-driver-sync?com.mongod

java - 在 Java 中获取 Spark 中的当前任务 ID

我需要在Spark中获取当前任务的ID。我一直在谷歌和官方API中搜索,但我能找到的唯一ID是执行者ID和RDD的ID。有谁知道如何获得任务的唯一ID?我已经看到类TaskInfo正是我要找的东西,但我不知道如何获取此类的实例。 最佳答案 为了获得特定的任务ID,您可以使用TaskContext:importorg.apache.spark.TaskContext;textFile.map(x->{TaskContexttc=TaskContext.get();System.out.println(tc.taskAttemptId(

java - 如何使用java spark下载文件?

我想为文件下载编写简单的restapi。我找不到关于它的文档,因为我知道我需要为响应设置mimetype='application/zip',但不清楚如何返回流。http://sparkjava.com/更新:此处解决示例代码:publicstaticvoidmain(String[]args){//setPort(8080);get("/hello",(request,responce)->getFile(request,responce));}privatestaticObjectgetFile(Requestrequest,Responseresponce){Filefile=n