xubo245 commented on a change in pull request #3054: [CARBONDATA-3232] Add example and doc for alluxio integration
URL:
https://github.com/apache/carbondata/pull/3054#discussion_r248912703
##########
File path: examples/spark2/src/main/scala/org/apache/carbondata/examples/AlluxioExample.scala
##########
@@ -28,46 +33,86 @@ import org.apache.carbondata.examples.util.ExampleUtils
/**
* configure alluxio:
* 1.start alluxio
- * 2.upload the jar :"/alluxio_path/core/client/target/
- * alluxio-core-client-YOUR-VERSION-jar-with-dependencies.jar"
- * 3.Get more detail at:
http://www.alluxio.org/docs/master/en/Running-Spark-on-Alluxio.html+ * 2.Get more detail at:
https://www.alluxio.org/docs/1.8/en/compute/Spark.html */
-
object AlluxioExample {
- def main(args: Array[String]) {
- val spark = ExampleUtils.createCarbonSession("AlluxioExample")
- exampleBody(spark)
- spark.close()
+ def main (args: Array[String]) {
+ val carbon = ExampleUtils.createCarbonSession("AlluxioExample",
+ storePath = "alluxio://localhost:19998/carbondata")
+ exampleBody(carbon)
+ carbon.close()
}
- def exampleBody(spark : SparkSession): Unit = {
+ def exampleBody (spark: SparkSession): Unit = {
+ val rootPath = new File(this.getClass.getResource("/").getPath
+ + "../../../..").getCanonicalPath
spark.sparkContext.hadoopConfiguration.set("fs.alluxio.impl", "alluxio.hadoop.FileSystem")
Review comment:
already added before. for beeline and CarbonThriftServer, another contributor is analyzing it. He can raise another PR to fix it.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[hidden email]
With regards,
Apache Git Services
Locked
