Class HiveOptions

java.lang.Object
org.apache.storm.hive.common.HiveOptions
All Implemented Interfaces:
Serializable

public class HiveOptions extends Object implements Serializable
See Also:
  • Field Details

    • DEFAULT_TICK_TUPLE_INTERVAL_SECS

      public static final int DEFAULT_TICK_TUPLE_INTERVAL_SECS
      Half of the default Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS
      See Also:
    • mapper

      protected HiveMapper mapper
    • databaseName

      protected String databaseName
    • tableName

      protected String tableName
    • metaStoreURI

      protected String metaStoreURI
    • txnsPerBatch

      protected Integer txnsPerBatch
    • maxOpenConnections

      protected Integer maxOpenConnections
    • batchSize

      protected Integer batchSize
    • idleTimeout

      protected Integer idleTimeout
    • callTimeout

      protected Integer callTimeout
    • heartBeatInterval

      protected Integer heartBeatInterval
    • autoCreatePartitions

      protected Boolean autoCreatePartitions
    • kerberosPrincipal

      protected String kerberosPrincipal
    • kerberosKeytab

      protected String kerberosKeytab
    • tickTupleInterval

      protected Integer tickTupleInterval
  • Constructor Details

  • Method Details

    • withTickTupleInterval

      public HiveOptions withTickTupleInterval(Integer tickInterval)
    • withTxnsPerBatch

      public HiveOptions withTxnsPerBatch(Integer txnsPerBatch)
    • withMaxOpenConnections

      public HiveOptions withMaxOpenConnections(Integer maxOpenConnections)
    • withBatchSize

      public HiveOptions withBatchSize(Integer batchSize)
    • withIdleTimeout

      public HiveOptions withIdleTimeout(Integer idleTimeout)
    • withCallTimeout

      public HiveOptions withCallTimeout(Integer callTimeout)
    • withHeartBeatInterval

      public HiveOptions withHeartBeatInterval(Integer heartBeatInterval)
    • withAutoCreatePartitions

      public HiveOptions withAutoCreatePartitions(Boolean autoCreatePartitions)
    • withKerberosKeytab

      public HiveOptions withKerberosKeytab(String kerberosKeytab)
    • withKerberosPrincipal

      public HiveOptions withKerberosPrincipal(String kerberosPrincipal)
    • getMetaStoreURI

      public String getMetaStoreURI()
    • getDatabaseName

      public String getDatabaseName()
    • getTableName

      public String getTableName()
    • getMapper

      public HiveMapper getMapper()
    • getBatchSize

      public Integer getBatchSize()
    • getCallTimeOut

      public Integer getCallTimeOut()
    • getHeartBeatInterval

      public Integer getHeartBeatInterval()
    • getMaxOpenConnections

      public Integer getMaxOpenConnections()
    • getIdleTimeout

      public Integer getIdleTimeout()
    • getTxnsPerBatch

      public Integer getTxnsPerBatch()
    • getAutoCreatePartitions

      public Boolean getAutoCreatePartitions()
    • getKerberosPrincipal

      public String getKerberosPrincipal()
    • getKerberosKeytab

      public String getKerberosKeytab()
    • getTickTupleInterval

      public Integer getTickTupleInterval()