I have written a embedded Pig program which execute on my machine and perform query on the server(hadoop machine) and stores the results. But in this i am giving pig.property file to my class path.
Can we write Pig-Embedded program without giving Pig.property file??
You can use org.apache.pig.PigServer to run pig scripts from Java programs.
PigServer pigServer = new PigServer(ExecType.MAPREDUCE);
pigServer.registerScript("scripts/test.pig");
Requires 'pig.properties' on classpath.
fs.default.name=hdfs://: mapred.job.tracker=: Or pass an instance of java.util.Properties to PigServer constructor.
Properties props = new Properties();
props.setProperty("fs.default.name", "hdfs://<namenode-hostname>:<port>");
props.setProperty("mapred.job.tracker", "<jobtracker-hostname>:<port>");
PigServer pigServer = new PigServer(ExecType.MAPREDUCE, props);
also check this
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With