|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.springframework.data.hadoop.hive.HiveServerFactoryBean
public class HiveServerFactoryBean
FactoryBean for easy declaration and creation of an embeddable Hive server.
Similar in functionality to HiveServer
but not tied to the command line.
Constructor Summary | |
---|---|
HiveServerFactoryBean()
|
Method Summary | |
---|---|
void |
afterPropertiesSet()
|
void |
destroy()
|
TServer |
getObject()
|
Class<?> |
getObjectType()
|
int |
getPhase()
|
boolean |
isAutoStartup()
|
boolean |
isRunning()
|
boolean |
isSingleton()
|
void |
setAutoStartup(boolean autoStartup)
Indicates whether the Hive client should start automatically (default) or not. |
void |
setConfiguration(Configuration configuration)
Sets the Hadoop configuration to use. |
void |
setExecutor(Executor executor)
Sets the executor for starting the server (which is a blocking operation). |
void |
setMaxThreads(int maxThreads)
Sets the maximum number of threads serving this server. |
void |
setMinThreads(int minThreads)
Sets the minimum number of threads serving this server. |
void |
setPort(int port)
Sets the server port. |
void |
setProperties(Properties properties)
Sets the configuration properties. |
void |
start()
|
void |
stop()
|
void |
stop(Runnable callback)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public HiveServerFactoryBean()
Method Detail |
---|
public void destroy()
destroy
in interface DisposableBean
public void afterPropertiesSet() throws Exception
afterPropertiesSet
in interface InitializingBean
Exception
public TServer getObject()
getObject
in interface FactoryBean<TServer>
public Class<?> getObjectType()
getObjectType
in interface FactoryBean<TServer>
public boolean isSingleton()
isSingleton
in interface FactoryBean<TServer>
public void start()
start
in interface Lifecycle
public void stop()
stop
in interface Lifecycle
public boolean isRunning()
isRunning
in interface Lifecycle
public int getPhase()
getPhase
in interface Phased
public boolean isAutoStartup()
isAutoStartup
in interface SmartLifecycle
public void stop(Runnable callback)
stop
in interface SmartLifecycle
public void setAutoStartup(boolean autoStartup)
autoStartup
- whether to automatically start or notpublic void setPort(int port)
port
- The port to set.public void setMinThreads(int minThreads)
minThreads
- The minThreads to set.public void setMaxThreads(int maxThreads)
maxThreads
- The maxThreads to set.public void setConfiguration(Configuration configuration)
configuration
- The configuration to set.public void setProperties(Properties properties)
properties
- The properties to set.public void setExecutor(Executor executor)
SimpleAsyncTaskExecutor
instance is used.
executor
- The executor to set.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |