public class HiveServerFactoryBean extends java.lang.Object implements FactoryBean<org.apache.thrift.server.TServer>, InitializingBean, DisposableBean, SmartLifecycle
HiveServer but not tied to the command line.| Constructor and Description |
|---|
HiveServerFactoryBean() |
| Modifier and Type | Method and Description |
|---|---|
void |
afterPropertiesSet() |
void |
destroy() |
org.apache.thrift.server.TServer |
getObject() |
java.lang.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(java.util.concurrent.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(java.util.Properties properties)
Sets the configuration properties.
|
void |
start() |
void |
stop() |
void |
stop(java.lang.Runnable callback) |
public void destroy()
destroy in interface DisposableBeanpublic void afterPropertiesSet()
throws java.lang.Exception
afterPropertiesSet in interface InitializingBeanjava.lang.Exceptionpublic org.apache.thrift.server.TServer getObject()
getObject in interface FactoryBean<org.apache.thrift.server.TServer>public java.lang.Class<?> getObjectType()
getObjectType in interface FactoryBean<org.apache.thrift.server.TServer>public boolean isSingleton()
isSingleton in interface FactoryBean<org.apache.thrift.server.TServer>public boolean isAutoStartup()
isAutoStartup in interface SmartLifecyclepublic void stop(java.lang.Runnable callback)
stop in interface SmartLifecyclepublic 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(java.util.Properties properties)
properties - The properties to set.public void setExecutor(java.util.concurrent.Executor executor)
SimpleAsyncTaskExecutor instance is used.executor - The executor to set.