MAPREDUCE服务 MRS-配置并导入样例工程:样例代码路径说明
样例代码路径说明
样例代码项目 |
样例名称 |
样例语言 |
---|---|---|
SparkJavaExample |
Spark Core程序 |
Java |
SparkScalaExample |
Spark Core程序 |
Scala |
SparkPythonExample |
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 |