public interface HiveOperations
HiveTemplate.
Not often used directly, but a useful option to enhance testability, as it can easily be mocked or stubbed.| Modifier and Type | Method and Description |
|---|---|
<T> T |
execute(HiveClientCallback<T> action)
Executes the action specified by the given callback object within an active
HiveClient. |
List<String> |
executeScript(HiveScript script)
Executes a Hive script.
|
List<String> |
executeScript(Iterable<HiveScript> scripts)
Executes multiple Hive scripts.
|
List<String> |
query(String query)
Executes the given HiveQL that results in a list of objects.
|
List<String> |
query(String query,
Map<?,?> arguments)
Executes the given HiveQL using the list of arguments, expecting a list of objects.
|
Integer |
queryForInt(String query)
Executes the given HiveQL that results in a single int value.
|
Integer |
queryForInt(String query,
Map<?,?> arguments)
Executes the given HiveQL using the list of arguments, that results in a single int value.
|
Long |
queryForLong(String query)
Executes the given HiveQL that results in a single long value.
|
Long |
queryForLong(String query,
Map<?,?> arguments)
Executes the given HiveQL using the list of arguments, that results in a single long value.
|
String |
queryForString(String query)
Executes the given HiveQL that results in a single object.
|
String |
queryForString(String query,
Map<?,?> arguments)
Executes the given HiveQL using the list of arguments, that results in a single object.
|
<T> T execute(HiveClientCallback<T> action) throws DataAccessException
HiveClient.T - action typeaction - callback object taht specifies the Hive actionDataAccessException - exceptionList<String> query(String query) throws DataAccessException
query - HiveQLDataAccessException - exceptionList<String> query(String query, Map<?,?> arguments) throws DataAccessException
query - HiveQLarguments - query argumentsDataAccessException - exceptionString queryForString(String query) throws DataAccessException
query - HiveQLDataAccessException - exceptionString queryForString(String query, Map<?,?> arguments) throws DataAccessException
query - HiveQLarguments - query argumentsDataAccessException - exceptionInteger queryForInt(String query) throws DataAccessException
query - HiveQLDataAccessException - exceptionInteger queryForInt(String query, Map<?,?> arguments) throws DataAccessException
query - HiveQLarguments - query argumentsDataAccessException - exceptionLong queryForLong(String query) throws DataAccessException
query - HiveQLDataAccessException - exceptionLong queryForLong(String query, Map<?,?> arguments) throws DataAccessException
query - HiveQLarguments - query argumentsDataAccessException - exceptionList<String> executeScript(HiveScript script) throws DataAccessException
script - script resource and argumentsDataAccessException - exceptionList<String> executeScript(Iterable<HiveScript> scripts) throws DataAccessException
scripts - script resources and argumentsDataAccessException - exception