|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.data.hadoop.pig.PigServerFactoryBean
public class PigServerFactoryBean
Factory for creating a PigServer instance. Note that since PigServer is not thread-safe, this factory will
create a new instance for every getObject() invocation. The caller needs to handle the object clean-up,
specifically calling PigServer.shutdown().
| Constructor Summary | |
|---|---|
PigServerFactoryBean()
|
|
| Method Summary | |
|---|---|
protected PigServer |
createPigInstance()
|
PigServer |
getObject()
|
Class<?> |
getObjectType()
|
boolean |
isSingleton()
|
void |
setBeanName(String name)
|
void |
setJobName(String jobName)
Sets the job name. |
void |
setJobPriority(String jobPriority)
Sets the job priority. |
void |
setParallelism(Integer parallelism)
Sets the parallelism. |
void |
setPathsToSkip(Collection<String> pathToSkip)
Sets the paths to skip. |
void |
setPigContext(PigContext pigContext)
Sets the PigContext to use. |
void |
setScripts(Collection<PigScript> scripts)
Sets the scripts to execute at startup. |
void |
setUser(String user)
Sets the user impersonation (optional) for executing Pig jobs. |
void |
setValidateEachStatement(Boolean validateEachStatement)
Indicates whether each statement should be validated or not. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public PigServerFactoryBean()
| Method Detail |
|---|
public PigServer getObject()
throws Exception
getObject in interface FactoryBean<PigServer>Exceptionpublic Class<?> getObjectType()
getObjectType in interface FactoryBean<PigServer>public boolean isSingleton()
isSingleton in interface FactoryBean<PigServer>
protected PigServer createPigInstance()
throws Exception
Exceptionpublic void setBeanName(String name)
setBeanName in interface BeanNameAwarepublic void setPigContext(PigContext pigContext)
PigContext to use.
pigContext - The pigContext to set.public void setPathsToSkip(Collection<String> pathToSkip)
pathToSkip - The pathToSkip to set.public void setScripts(Collection<PigScript> scripts)
scripts - The scripts to set.public void setParallelism(Integer parallelism)
parallelism - The parallelism to set.public void setJobName(String jobName)
jobName - The jobName to set.public void setJobPriority(String jobPriority)
jobPriority - The jobPriority to set.public void setValidateEachStatement(Boolean validateEachStatement)
validateEachStatement - whether to validate each statement or not.public void setUser(String user)
user - user/group information
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||