Help Center> MapReduce Service> Developer Guide (3.x)> Spark2x Development Guide (Normal Mode)> Developing the Project> Using Spark to Perform Basic Hudi Operations> Instance
View PDF

Instance

Use Spark to perform operations such as data insertion, query, update, incremental query, query at a specific time point, and data deletion on Hudi.

Run the following spark-submit command:

Scala:

spark-submit --jars /opt/huditest/example/hudi-examples-0.8.0.jar --class com.huawei.bigdata.hudi.examples.HoodieDataSourceExample /opt/huditest/example/* hdfs://hacluster/tmp/huditest/example/scala hoodie_rt_scala

Python:

spark-submit /opt/huditest/example/HudiPythonExample.py hdfs://hacluster/tmp/huditest/example/python hudi_trips_cow

Java:

spark-submit --jars /opt/huditest/example/hudi-examples-0.8.0.jar --class com.huawei.bigdata.hudi.examples.HoodieWriteClientExample /opt/huditest/example/* hdfs://hacluster/tmp/huditest/example/java hoodie_java