|
Spring for Apache Hadoop | ||||||||
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()
|
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(org.apache.hadoop.conf.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)
|
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 org.springframework.beans.factory.DisposableBean
public void afterPropertiesSet() throws java.lang.Exception
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
java.lang.Exception
public org.apache.thrift.server.TServer getObject()
getObject
in interface org.springframework.beans.factory.FactoryBean<org.apache.thrift.server.TServer>
public java.lang.Class<?> getObjectType()
getObjectType
in interface org.springframework.beans.factory.FactoryBean<org.apache.thrift.server.TServer>
public boolean isSingleton()
isSingleton
in interface org.springframework.beans.factory.FactoryBean<org.apache.thrift.server.TServer>
public void start()
start
in interface org.springframework.context.Lifecycle
public void stop()
stop
in interface org.springframework.context.Lifecycle
public boolean isRunning()
isRunning
in interface org.springframework.context.Lifecycle
public int getPhase()
getPhase
in interface org.springframework.context.Phased
public boolean isAutoStartup()
isAutoStartup
in interface org.springframework.context.SmartLifecycle
public void stop(java.lang.Runnable callback)
stop
in interface org.springframework.context.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(org.apache.hadoop.conf.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.
|
Spring for Apache Hadoop | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |