样例1：
HoodieWriteClientExample：

    1.使用maven打包成hudi-java-examples-1.0.jar并上传至指定目录（以/opt/example/为例）

    2.source client的bigdata_env和Hudi目录下的component_env，kinit有Hive Hadoop权限的用户

    3.使用spark-submit提交作业：
        spark-submit --keytab <user_keytab_path> --principal=<principal_name> --class com.huawei.bigdata.hudi.examples.HoodieWriteClientExample /opt/example/hudi-java-security-examples-1.0.jar  hdfs://hacluster/tmp/example/hoodie_java  hoodie_java

样例2：
HoodieDeltaStreamer：

    1.使用maven打包成hudi-java-examples-1.0.jar并上传至指定目录（以/opt/example/为例）

    2.制造写入Kafka的数据
        命令启动格式：
        spark-submit --keytab <user_keytab_path> --principal=<principal_name> --class com.huawei.bigdata.hudi.examples.ProducerDemo /opt/example/hudi-java-security-examples-1.0.jar bootstrap.servers topic_name kerberos.domain.name security.protocol sasl.kerberos.service.name
        其中bootstrap.servers、kerberos.domain.name、security.protocol和sasl.kerberos.service.name可以查看客户端下的producer.properties来获取值
        
        示例：
        spark-submit --keytab /opt/example/user.keytab --principal=admintest --class com.huawei.bigdata.hudi.examples.ProducerDemo /opt/example/hudi-java-security-examples-1.0.jar ip1:21007,ip2:21007,ip3:21007 test_topic hadoop.hadoop.com SASL_PLAINTEXT kafka

    3.将kafka-source.properties上传至指定目录（以/opt/example/为例），修改其中的kafka参数
        bootstrap.servers= xx.xx.xx.xx:xxxx
        kerberos.domain.name=xxx
        security.protocol=xxx
        sasl.kerberos.service.name=xxx

    4.启动deltastreamer消费kafka写入Hudi
        spark-submit --keytab <user_keytab_path> --principal=<principal_name> --master yarn --driver-memory 1g  --executor-memory 1g --executor-cores 1 --num-executors 2 --conf spark.kryoserializer.buffer.max=128m --driver-class-path /opt/client/Hudi/hudi/conf:/opt/client/Hudi/hudi/lib/*:/opt/example/*:/opt/client/Spark2x/spark/jars/* --class org.apache.hudi.utilities.deltastreamer.HoodieDeltaStreamer spark-internal --props file:///opt/example/kafka-source.properties --target-base-path /tmp/huditest/hudi_deltastreamer_example_table --table-type MERGE_ON_READ --target-table hudi_deltastreamer_example_table --source-ordering-field age --source-class org.apache.hudi.utilities.sources.JsonKafkaSource --schemaprovider-class com.huawei.bigdata.hudi.examples.DataSchemaProviderExample --transformer-class com.huawei.bigdata.hudi.examples.TransformerExample --enable-hive-sync  --continuous