コンストラクターの詳細

• HiveTemplate

  public HiveTemplate()

  新しい HiveClient インスタンスを構築します。使用する前に setHiveClientFactory(HiveClientFactory) が呼び出される必要があります。

• HiveTemplate

  public HiveTemplate(HiveClientFactory hiveClientFactory)

  新しい HiveTemplate インスタンスを構築します。

  パラメーター:

  hiveClientFactory - HiveClient ファクトリ

メソッドの詳細

• afterPropertiesSet

  public void afterPropertiesSet()

  次で指定:

  インターフェース org.springframework.beans.factory.InitializingBean 内の afterPropertiesSet 

• execute

  public <T> T execute(HiveClientCallback<T> action)
            throws org.springframework.dao.DataAccessException

  アクティブな接続内で、指定されたコールバックオブジェクトによって指定されたアクションを実行します。

  次で指定:

  インターフェース HiveOperations 内の execute 

  型パラメーター:

  T - アクションタイプ

  パラメーター:

  action - Hive アクションを指定するコールバックオブジェクト

  戻り値:

  アクション結果オブジェクト

  例外:

  org.springframework.dao.DataAccessException - 例外

• convertHiveAccessException

  protected org.springframework.dao.DataAccessException convertHiveAccessException(java.lang.Exception ex)

  指定された Hive 例外を org.springframework.dao 階層からの適切な例外に変換します。

  パラメーター:

  ex - ハイブ例外

  戻り値:

  対応する DataAccessException

• query

  public java.util.List<java.lang.String> query(java.lang.String query)
                                         throws org.springframework.dao.DataAccessException

  指定された HiveQL を実行し、オブジェクトのリストを生成します。スクリプトは URL として解釈されますが、失敗した場合は HiveQL ステートメントとして解釈されます。

  次で指定:

  インターフェース HiveOperations 内の query 

  パラメーター:

  query - ハイブ QL

  戻り値:

  クエリによって返される値のリスト

  例外:

  org.springframework.dao.DataAccessException - 例外

• query

  public java.util.List<java.lang.String> query(java.lang.String query,
                                       java.util.Map<?,?> arguments)
                                         throws org.springframework.dao.DataAccessException

  引数のリストを使用して、オブジェクトのリストを想定して、指定された HiveQL を実行します。スクリプトは URL として解釈されますが、それが失敗した場合は HiveQL ステートメントとして解釈されます。

  次で指定:

  インターフェース HiveOperations 内の query 

  パラメーター:

  query - ハイブ QL

  arguments - クエリ引数

  戻り値:

  クエリによって返される値のリスト

  例外:

  org.springframework.dao.DataAccessException - 例外

• queryForString

  public java.lang.String queryForString(java.lang.String query)
                                  throws org.springframework.dao.DataAccessException

  指定された HiveQL を実行し、単一のオブジェクトを生成します。スクリプトは URL として解釈されますが、失敗した場合は HiveQL ステートメントとして解釈されます。

  次で指定:

  インターフェース HiveOperations 内の queryForString 

  パラメーター:

  query - ハイブ QL

  戻り値:

  クエリ結果

  例外:

  org.springframework.dao.DataAccessException - 例外

• queryForString

  public java.lang.String queryForString(java.lang.String query,
                                java.util.Map<?,?> arguments)
                                  throws org.springframework.dao.DataAccessException

  引数のリストを使用して指定された HiveQL を実行し、単一のオブジェクトを生成します。スクリプトは URL として解釈されますが、失敗した場合は HiveQL ステートメントとして解釈されます。

  次で指定:

  インターフェース HiveOperations 内の queryForString 

  パラメーター:

  query - ハイブ QL

  arguments - クエリ引数

  戻り値:

  クエリ結果

  例外:

  org.springframework.dao.DataAccessException - 例外

• queryForInt

  public java.lang.Integer queryForInt(java.lang.String query)
                                throws org.springframework.dao.DataAccessException

  指定された HiveQL を実行し、単一の int 値を生成します。スクリプトは URL として解釈されますが、失敗した場合は HiveQL ステートメントとして解釈されます。

  次で指定:

  インターフェース HiveOperations 内の queryForInt 

  パラメーター:

  query - ハイブ QL

  戻り値:

  クエリ int 結果

  例外:

  org.springframework.dao.DataAccessException - 例外

• queryForInt

  public java.lang.Integer queryForInt(java.lang.String query,
                              java.util.Map<?,?> arguments)
                                throws org.springframework.dao.DataAccessException

  引数のリストを使用して指定された HiveQL を実行し、単一の int 値を返します。スクリプトは URL として解釈されますが、失敗した場合は HiveQL ステートメントとして解釈されます。

  次で指定:

  インターフェース HiveOperations 内の queryForInt 

  パラメーター:

  query - ハイブ QL

  arguments - クエリ引数

  戻り値:

  クエリ int 結果

  例外:

  org.springframework.dao.DataAccessException - 例外

• queryForLong

  public java.lang.Long queryForLong(java.lang.String query)
                              throws org.springframework.dao.DataAccessException

  指定された HiveQL を実行し、単一の長い値を生成します。スクリプトは URL として解釈されますが、それが失敗した場合は HiveQL ステートメントとして解釈されます。

  次で指定:

  インターフェース HiveOperations 内の queryForLong 

  パラメーター:

  query - ハイブ QL

  戻り値:

  クエリの長い結果

  例外:

  org.springframework.dao.DataAccessException - 例外

• queryForLong

  public java.lang.Long queryForLong(java.lang.String query,
                            java.util.Map<?,?> arguments)
                              throws org.springframework.dao.DataAccessException

  引数のリストを使用して指定された HiveQL を実行し、単一の長い値を生成します。スクリプトは URL として解釈されますが、それが失敗した場合は HiveQL ステートメントとして解釈されます。

  次で指定:

  インターフェース HiveOperations 内の queryForLong 

  パラメーター:

  query - ハイブ QL

  arguments - クエリ引数

  戻り値:

  クエリの長い結果

  例外:

  org.springframework.dao.DataAccessException - 例外

• executeScript

  public java.util.List<java.lang.String> executeScript(HiveScript script)
                                                 throws org.springframework.dao.DataAccessException

  Hive スクリプトを実行します。

  次で指定:

  インターフェース HiveOperations 内の executeScript 

  パラメーター:

  script - スクリプトリソースと引数

  戻り値:

  スクリプト結果

  例外:

  org.springframework.dao.DataAccessException - 例外

• executeScript

  public java.util.List<java.lang.String> executeScript(java.lang.Iterable<HiveScript> scripts)
                                                 throws org.springframework.dao.DataAccessException

  複数の Hive スクリプトを実行します。

  次で指定:

  インターフェース HiveOperations 内の executeScript 

  パラメーター:

  scripts - スクリプトのリソースと引数

  戻り値:

  スクリプトの結果

  例外:

  org.springframework.dao.DataAccessException - 例外

• createHiveClient

  protected HiveClient createHiveClient()

• setHiveClientFactory

  public void setHiveClientFactory(HiveClientFactory hiveClientFactory)

  HiveClient ファクトリを設定します。

  パラメーター:

  hiveClientFactory - 設定する Hive クライアントファクトリ

• setResourceLoader

  public void setResourceLoader(org.springframework.core.io.ResourceLoader resourceLoader)

  次で指定:

  インターフェース org.springframework.context.ResourceLoaderAware 内の setResourceLoader