|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.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>
Exception
public Class<?> getObjectType()
getObjectType
in interface FactoryBean<PigServer>
public boolean isSingleton()
isSingleton
in interface FactoryBean<PigServer>
protected PigServer createPigInstance() throws Exception
Exception
public void setBeanName(String name)
setBeanName
in interface BeanNameAware
public 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 |