Package org.apache.storm.hive.common
Class HiveOptions
java.lang.Object
org.apache.storm.hive.common.HiveOptions
- All Implemented Interfaces:
Serializable
- See Also:
-
Field Summary
Modifier and TypeFieldDescriptionprotected Boolean
protected Integer
protected Integer
protected String
static final int
Half of the default Config.TOPOLOGY_MESSAGE_TIMEOUT_SECSprotected Integer
protected Integer
protected String
protected String
protected HiveMapper
protected Integer
protected String
protected String
protected Integer
protected Integer
-
Constructor Summary
ConstructorDescriptionHiveOptions
(String metaStoreUri, String databaseName, String tableName, HiveMapper mapper) -
Method Summary
Modifier and TypeMethodDescriptionwithAutoCreatePartitions
(Boolean autoCreatePartitions) withBatchSize
(Integer batchSize) withCallTimeout
(Integer callTimeout) withHeartBeatInterval
(Integer heartBeatInterval) withIdleTimeout
(Integer idleTimeout) withKerberosKeytab
(String kerberosKeytab) withKerberosPrincipal
(String kerberosPrincipal) withMaxOpenConnections
(Integer maxOpenConnections) withTickTupleInterval
(Integer tickInterval) withTxnsPerBatch
(Integer txnsPerBatch)
-
Field Details
-
DEFAULT_TICK_TUPLE_INTERVAL_SECS
public static final int DEFAULT_TICK_TUPLE_INTERVAL_SECSHalf of the default Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS- See Also:
-
mapper
-
databaseName
-
tableName
-
metaStoreURI
-
txnsPerBatch
-
maxOpenConnections
-
batchSize
-
idleTimeout
-
callTimeout
-
heartBeatInterval
-
autoCreatePartitions
-
kerberosPrincipal
-
kerberosKeytab
-
tickTupleInterval
-
-
Constructor Details
-
HiveOptions
-
-
Method Details
-
withTickTupleInterval
-
withTxnsPerBatch
-
withMaxOpenConnections
-
withBatchSize
-
withIdleTimeout
-
withCallTimeout
-
withHeartBeatInterval
-
withAutoCreatePartitions
-
withKerberosKeytab
-
withKerberosPrincipal
-
getMetaStoreURI
-
getDatabaseName
-
getTableName
-
getMapper
-
getBatchSize
-
getCallTimeOut
-
getHeartBeatInterval
-
getMaxOpenConnections
-
getIdleTimeout
-
getTxnsPerBatch
-
getAutoCreatePartitions
-
getKerberosPrincipal
-
getKerberosKeytab
-
getTickTupleInterval
-