MAPREDUCE服务 MRS-导入并配置Spark样例工程:样例代码路径说明
样例代码路径说明
样例代码项目 |
样例名称 |
样例语言 |
---|---|---|
SparkJavaExample |
Spark Core程序 |
Java |
SparkScalaExample |
Spark Core程序 |
Scala |
SparkPyhtonExample |
Spark Core程序 |
Python |
SparkSQLJavaExample |
Spark SQL程序 |
Java |
SparkSQLScalaExample |
Spark SQL程序 |
Scala |
SparkSQLPythonExample |
Spark SQL程序 |
Python |
SparkThriftServerJavaExample |
通过JDBC访问Spark SQL的程序 |
Java |
SparkThriftServerScalaExample |
通过JDBC访问Spark SQL的程序 |
Scala |
SparkOnHbaseJavaExample-AvroSource |
Spark on HBase 程序-操作Avro格式数据 |
Java |
SparkOnHbaseScalaExample-AvroSource |
Spark on HBase 程序-操作Avro格式数据 |
Scala |
SparkOnHbasePythonExample-AvroSource |
Spark on HBase 程序-操作Avro格式数据 |
Python |
SparkOnHbaseJavaExample-HbaseSource |
Spark on HBase 程序-操作HBase数据源 |
Java |
SparkOnHbaseScalaExample-HbaseSource |
Spark on HBase 程序-操作HBase数据源 |
Scala |
SparkOnHbasePythonExample-HbaseSource |
Spark on HBase 程序-操作HBase数据源 |
Python |
SparkOnHbaseJavaExample-JavaHBaseBulkPutExample |
Spark on HBase 程序-BulkPut接口使用 |
Java |
SparkOnHbaseScalaExample-HBaseBulkPutExample |
Spark on HBase 程序-BulkPut接口使用 |
Scala |
SparkOnHbasePythonExample-HBaseBulkPutExample |
Spark on HBase 程序-BulkPut接口使用 |
Python |
SparkOnHbaseJavaExample-JavaHBaseBulkGetExample |
Spark on HBase 程序-BulkGet接口使用 |
Java |
SparkOnHbaseScalaExample-HBaseBulkGetExample |
Spark on HBase 程序-BulkGet接口使用 |
Scala |
SparkOnHbasePythonExample-HBaseBulkGetExample |
Spark on HBase 程序-BulkGet接口使用 |
Python |
SparkOnHbaseJavaExample-JavaHBaseBulkDeleteExample |
Spark on HBase 程序-BulkDelete接口使用 |
Java |
SparkOnHbaseScalaExample-HBaseBulkDeleteExample |
Spark on HBase 程序-BulkDelete接口使用 |
Scala |
SparkOnHbasePythonExample-HBaseBulkDeleteExample |
Spark on HBase 程序-BulkDelete接口使用 |
Python |
SparkOnHbaseJavaExample-JavaHBaseBulkLoadExample |
Spark on HBase 程序-BulkLoad接口使用 |
Java |
SparkOnHbaseScalaExample-HBaseBulkLoadExample |
Spark on HBase 程序-BulkLoad接口使用 |
Scala |
SparkOnHbasePythonExample-HBaseBulkLoadExample |
Spark on HBase 程序-BulkLoad接口使用 |
Python |
SparkOnHbaseJavaExample-JavaHBaseForEachPartitionExample |
Spark on HBase 程序-foreachPartition接口使用 |
Java |
SparkOnHbaseScalaExample-HBaseForEachPartitionExample |
Spark on HBase 程序-foreachPartition接口使用 |
Scala |
SparkOnHbasePythonExample-HBaseForEachPartitionExample |
Spark on HBase 程序-foreachPartition接口使用 |
Python |
SparkOnHbaseJavaExample-JavaHBaseDistributedScanExample |
Spark on HBase 程序-分布式Scan HBase表 |
Java |
SparkOnHbaseScalaExample-HBaseDistributedScanExample |
Spark on HBase 程序-分布式Scan HBase表 |
Scala |
SparkOnHbasePythonExample-HBaseDistributedScanExample |
Spark on HBase 程序-分布式Scan HBase表 |
Python |
SparkOnHbaseJavaExample-JavaHBaseMapPartitionExample |
Spark on HBase 程序-mapPartitions接口使用 |
Java |
SparkOnHbaseScalaExample-HBaseMapPartitionExample |
Spark on HBase 程序-mapPartitions接口使用 |
Scala |
SparkOnHbasePythonExample-HBaseMapPartitionExample |
Spark on HBase 程序-mapPartitions接口使用 |
Python |
SparkOnHbaseJavaExample-JavaHBaseStreamingBulkPutExample |
Spark on HBase 程序-SparkStreaming批量写入HBase表 |
Java |
SparkOnHbaseScalaExample-HBaseStreamingBulkPutExample |
Spark on HBase 程序-SparkStreaming批量写入HBase表 |
Scala |
SparkOnHbasePythonExample-HBaseStreamingBulkPutExample |
Spark on HBase 程序-SparkStreaming批量写入HBase表 |
Python |
SparkHbasetoHbaseJavaExample |
从HBase读取数据再写入HBase |
Java |
SparkHbasetoHbaseScalaExample |
从HBase读取数据再写入HBase |
Scala |
SparkHbasetoHbasePythonExample |
从HBase读取数据再写入HBase |
Python |
SparkHivetoHbaseJavaExample |
从Hive读取数据再写入HBase |
Java |
SparkHivetoHbaseScalaExample |
从Hive读取数据再写入HBase |
Scala |
SparkHivetoHbasePythonExample |
从Hive读取数据再写入HBase |
Python |
SparkStreamingKafka010JavaExample |
Spark Streaming对接Kafka0-10程序 |
Java |
SparkStreamingKafka010ScalaExample |
Spark Streaming对接Kafka0-10程序 |
Scala |
SparkStructuredStreamingJavaExample |
Structured Streaming程序 |
Java |
SparkStructuredStreamingScalaExample |
Structured Streaming程序 |
Scala |
SparkStructuredStreamingPythonExample |
Structured Streaming程序 |
Python |
StructuredStreamingADScalaExample |
Structured Streaming流流Join |
Scala |
StructuredStreamingStateScalaExample |
Structured Streaming 状态操作 |
Scala |
SparkOnHudiJavaExample |
使用Spark执行Hudi基本操作 |
Java |
SparkOnHudiPythonExample |
使用Spark执行Hudi基本操作 |
Python |
SparkOnHudiScalaExample |
使用Spark执行Hudi基本操作 |
Scala |
- 大数据分析是什么_使用MapReduce_创建MRS服务
- MapReduce服务_如何使用MapReduce服务_MRS集群客户端安装与使用
- Hudi服务_什么是Hudi_如何使用Hudi
- 网站安全-Web应用防火墙-CC攻击防护规则
- MapReduce服务_什么是存算分离_如何配置MRS集群存算分离
- MapReduce服务_什么是HDFS_HDFS特性
- MapReduce服务_什么是Loader_如何使用Loader
- 数据转发至函数工作流_数据处理_FunctionGraph处理流数据
- MapReduce工作原理_MapReduce是什么意思_MapReduce流程_MRS_华为云
- 什么是数据湖探索服务_数据湖探索DLI用途与特点