public interface PigOperations
PigTemplate
によって実装されています。直接使用されることはあまりありませんが、簡単にモック化またはスタブ化できるため、テスト可能性を高めるのに役立つオプションです。修飾子と型 | メソッドと説明 |
---|---|
<T> T | execute(PigCallback<T> action) アクティブな PigServer 内で、指定されたコールバックオブジェクトによって指定されたアクションを実行します。 |
java.util.List<org.apache.pig.backend.executionengine.ExecJob> | executeScript(java.lang.Iterable<PigScript> scripts) 複数のスクリプトを実行し、ジョブ実行のリストを生成します。 |
java.util.List<org.apache.pig.backend.executionengine.ExecJob> | executeScript(PigScript script) 場所と引数によって識別される指定されたスクリプトを実行し、ジョブ実行のリストを生成します。 |
java.util.List<org.apache.pig.backend.executionengine.ExecJob> | executeScript(java.lang.String script) 指定された Pig Latin を実行し、ジョブ実行のリストを生成します。 |
java.util.List<org.apache.pig.backend.executionengine.ExecJob> | executeScript(java.lang.String script, java.util.Map<?,?> arguments) 指定された Pig Latin を引数付きで実行し、ジョブ実行のリストを生成します。 |
<T> T execute(PigCallback<T> action) throws org.springframework.dao.DataAccessException
PigServer
内で、指定されたコールバックオブジェクトによって指定されたアクションを実行します。T
- アクションタイプ action
- Hive アクションを指定するコールバックオブジェクト org.springframework.dao.DataAccessException
- 例外 java.util.List<org.apache.pig.backend.executionengine.ExecJob> executeScript(java.lang.String script) throws org.springframework.dao.DataAccessException
script
- スクリプト URL またはピッグラテンステートメント org.springframework.dao.DataAccessException
- 例外 java.util.List<org.apache.pig.backend.executionengine.ExecJob> executeScript(java.lang.String script, java.util.Map<?,?> arguments) throws org.springframework.dao.DataAccessException
script
- スクリプト URL またはピッグラテンステートメント arguments
- スクリプト引数 org.springframework.dao.DataAccessException
- 例外 java.util.List<org.apache.pig.backend.executionengine.ExecJob> executeScript(PigScript script) throws org.springframework.dao.DataAccessException
script
- スクリプトの場所と引数 org.springframework.dao.DataAccessException
- 例外 java.util.List<org.apache.pig.backend.executionengine.ExecJob> executeScript(java.lang.Iterable<PigScript> scripts) throws org.springframework.dao.DataAccessException
scripts
- スクリプトの場所と引数 org.springframework.dao.DataAccessException
- 例外