public class PigServerFactoryBean extends java.lang.Object implements org.springframework.beans.factory.FactoryBean<PigServerFactory>, org.springframework.beans.factory.BeanNameAware
PigServer インスタンスを作成するためのファクトリ。PigServer はスレッドセーフではなく、Pig API は何らかの型のファクトリを提供しないため、ファクトリ Bean は、再利用できない生の PigServer オブジェクトではなく、ObjectFactory のインスタンス (PigServer インスタンスの作成を処理) を返すことに注意してください。呼び出し元は、オブジェクトのクリーンアップ、具体的には PigServer.shutdown() を呼び出す必要があることに注意してください。一般に、リークを回避するには、PigTemplate を使用することをお勧めします。| コンストラクターと説明 |
|---|
PigServerFactoryBean() |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected org.apache.pig.PigServer | createPigInstance() |
PigServerFactory | getObject() |
java.lang.Class<?> | getObjectType() |
boolean | isSingleton() |
void | setBeanName(java.lang.String name) |
void | setJobName(java.lang.String jobName) ジョブ名を設定します。 |
void | setJobPriority(java.lang.String jobPriority) ジョブの優先度を設定します。 |
void | setParallelism(java.lang.Integer parallelism) 並列処理を設定します。 |
void | setPathsToSkip(java.util.Collection<java.lang.String> pathToSkip) スキップするパスを設定します。 |
void | setPigContext(org.apache.pig.impl.PigContext pigContext) 使用する PigContext を設定します。 |
void | setScripts(java.util.Collection<PigScript> scripts) 起動時に実行するスクリプトを設定します。 |
void | setUser(java.lang.String user)Pig ジョブを実行するためのユーザーの偽装 (オプション) を設定します。 |
void | setValidateEachStatement(java.lang.Boolean validateEachStatement) 各ステートメントを検証する必要があるかどうかを示します。 |
public PigServerFactory getObject() throws java.lang.Exception
org.springframework.beans.factory.FactoryBean<PigServerFactory> 内の getObject java.lang.Exceptionpublic java.lang.Class<?> getObjectType()
org.springframework.beans.factory.FactoryBean<PigServerFactory> 内の getObjectType public boolean isSingleton()
org.springframework.beans.factory.FactoryBean<PigServerFactory> 内の isSingleton protected org.apache.pig.PigServer createPigInstance()
throws java.lang.Exceptionjava.lang.Exceptionpublic void setBeanName(java.lang.String name)
org.springframework.beans.factory.BeanNameAware 内の setBeanName public void setPigContext(org.apache.pig.impl.PigContext pigContext)
PigContext を設定します。pigContext - 設定する pigContext。public void setPathsToSkip(java.util.Collection<java.lang.String> pathToSkip)
pathToSkip - 設定する pathToSkip。public void setScripts(java.util.Collection<PigScript> scripts)
scripts - 設定するスクリプト。public void setParallelism(java.lang.Integer parallelism)
parallelism - 設定する並列性。public void setJobName(java.lang.String jobName)
jobName - 設定する jobName。public void setJobPriority(java.lang.String jobPriority)
jobPriority - 設定する jobPriority。public void setValidateEachStatement(java.lang.Boolean validateEachStatement)
validateEachStatement - 各ステートメントを検証するかどうか。public void setUser(java.lang.String user)
user - ユーザー / グループ情報