public interface HiveOperations
HiveTemplate
によって実装されます。直接使用されることはあまりありませんが、簡単にモック化またはスタブ化できるため、テスト可能性を高めるのに役立つオプションです。修飾子と型 | メソッドと説明 |
---|---|
<T> T | execute(HiveClientCallback<T> action) アクティブな HiveClient 内で、指定されたコールバックオブジェクトによって指定されたアクションを実行します。 |
java.util.List<java.lang.String> | executeScript(HiveScript script) Hive スクリプトを実行します。 |
java.util.List<java.lang.String> | executeScript(java.lang.Iterable<HiveScript> scripts) 複数の Hive スクリプトを実行します。 |
java.util.List<java.lang.String> | query(java.lang.String query) 指定された HiveQL を実行し、オブジェクトのリストを生成します。 |
java.util.List<java.lang.String> | query(java.lang.String query, java.util.Map<?,?> arguments) オブジェクトのリストを想定し、引数のリストを使用して指定された HiveQL を実行します。 |
java.lang.Integer | queryForInt(java.lang.String query) 指定された HiveQL を実行し、単一の int 値を生成します。 |
java.lang.Integer | queryForInt(java.lang.String query, java.util.Map<?,?> arguments) 引数のリストを使用して指定された HiveQL を実行し、単一の int 値を生成します。 |
java.lang.Long | queryForLong(java.lang.String query) 指定された HiveQL を実行し、単一の long 値を生成します。 |
java.lang.Long | queryForLong(java.lang.String query, java.util.Map<?,?> arguments) 引数のリストを使用して指定された HiveQL を実行し、単一の long 値を生成します。 |
java.lang.String | queryForString(java.lang.String query) 指定された HiveQL を実行し、単一のオブジェクトを生成します。 |
java.lang.String | queryForString(java.lang.String query, java.util.Map<?,?> arguments) 引数のリストを使用して指定された HiveQL を実行し、単一のオブジェクトを生成します。 |
<T> T execute(HiveClientCallback<T> action) throws org.springframework.dao.DataAccessException
HiveClient
内で、指定されたコールバックオブジェクトによって指定されたアクションを実行します。T
- アクションタイプ action
- Hive アクションを指定するコールバックオブジェクト org.springframework.dao.DataAccessException
- 例外 java.util.List<java.lang.String> query(java.lang.String query) throws org.springframework.dao.DataAccessException
query
- ハイブ QLorg.springframework.dao.DataAccessException
- 例外 java.util.List<java.lang.String> query(java.lang.String query, java.util.Map<?,?> arguments) throws org.springframework.dao.DataAccessException
query
- ハイブ QLarguments
- クエリ引数 org.springframework.dao.DataAccessException
- 例外 java.lang.String queryForString(java.lang.String query) throws org.springframework.dao.DataAccessException
query
- ハイブ QLorg.springframework.dao.DataAccessException
- 例外 java.lang.String queryForString(java.lang.String query, java.util.Map<?,?> arguments) throws org.springframework.dao.DataAccessException
query
- ハイブ QLarguments
- クエリ引数 org.springframework.dao.DataAccessException
- 例外 java.lang.Integer queryForInt(java.lang.String query) throws org.springframework.dao.DataAccessException
query
- ハイブ QLorg.springframework.dao.DataAccessException
- 例外 java.lang.Integer queryForInt(java.lang.String query, java.util.Map<?,?> arguments) throws org.springframework.dao.DataAccessException
query
- ハイブ QLarguments
- クエリ引数 org.springframework.dao.DataAccessException
- 例外 java.lang.Long queryForLong(java.lang.String query) throws org.springframework.dao.DataAccessException
query
- ハイブ QLorg.springframework.dao.DataAccessException
- 例外 java.lang.Long queryForLong(java.lang.String query, java.util.Map<?,?> arguments) throws org.springframework.dao.DataAccessException
query
- ハイブ QLarguments
- クエリ引数 org.springframework.dao.DataAccessException
- 例外 java.util.List<java.lang.String> executeScript(HiveScript script) throws org.springframework.dao.DataAccessException
script
- スクリプトリソースと引数 org.springframework.dao.DataAccessException
- 例外 java.util.List<java.lang.String> executeScript(java.lang.Iterable<HiveScript> scripts) throws org.springframework.dao.DataAccessException
scripts
- スクリプトのリソースと引数 org.springframework.dao.DataAccessException
- 例外