Added Methods |
String doParamSubstitution(InputStream, Map, List)
|
Do parameter substitution. |
List getJobs(PigStats )
|
Retrieves a list of Job objects from the PigStats object |
PigStats launchPlan(PhysicalPlan, String)
|
A common method for launching the jobs according to the physical plan |
void registerScript(InputStream )
|
Register a pig script from InputStream source which is more general and extensible the pig script can be from local file then you can use FileInputStream. |
void registerScript(InputStream, List)
|
Register a pig script from InputStream source which is more general and extensible the pig script can be from local file then you can use FileInputStream. |
void registerScript(InputStream, Map)
|
Register a pig script from InputStream source which is more general and extensible the pig script can be from local file then you can use FileInputStream. |
void registerScript(InputStream, Map, List)
|
Register a pig script from InputStream. The pig script can be from local file then you can use FileInputStream. |
void setValidateEachStatement(boolean )
|
This can be called to indicate if the query is being parsed/compiled in a mode that expects each statement to be validated as it is entered instead of just doing it once for whole script. |