Package org.apache.accumulo.minicluster

Class MiniAccumuloConfig

java.lang.Object
org.apache.accumulo.minicluster.MiniAccumuloConfig
public class MiniAccumuloConfig extends Object
Holds configuration for MiniAccumuloCluster. Required configurations must be passed to constructor(s) and all other configurations are optional.
Since:
1.5.0

  • Constructor Details

    • MiniAccumuloConfig

      public MiniAccumuloConfig(File dir, String rootPassword)
      Parameters:
      dir - An empty or nonexistent directory that Accumulo and Zookeeper can store data in. Creating the directory is left to the user. Java 7, Guava, and Junit provide methods for creating temporary directories.
      rootPassword - The initial password for the Accumulo root user

  • Method Details

    • setNumTservers

      public MiniAccumuloConfig setNumTservers(int numTservers)
      Calling this method is optional. If not set, it defaults to two.
      Parameters:
      numTservers - the number of tablet servers that mini accumulo cluster should start

    • setNumScanServers

      public MiniAccumuloConfig setNumScanServers(int numScanServers)
      Calling this method is optional. If not set, it defaults to zero.
      Parameters:
      numScanServers - the number of scan servers that mini accumulo cluster should start
      Since:
      2.1.0

    • setInstanceName

      public MiniAccumuloConfig setInstanceName(String instanceName)
      Calling this method is optional. If not set, defaults to 'miniInstance'
      Since:
      1.6.0

    • setSiteConfig

      public MiniAccumuloConfig setSiteConfig(Map<String,String> siteConfig)
      Calling this method is optional. If not set, it defaults to an empty map.
      Parameters:
      siteConfig - key/values that you normally put in accumulo.properties can be put here.

    • setZooKeeperPort

      public MiniAccumuloConfig setZooKeeperPort(int zooKeeperPort)
      Calling this method is optional. A random port is generated by default
      Parameters:
      zooKeeperPort - A valid (and unused) port to use for the zookeeper
      Since:
      1.6.0

    • setExistingZooKeepers

      public MiniAccumuloConfig setExistingZooKeepers(String existingZooKeepers)
      Configure an existing ZooKeeper instance to use. Calling this method is optional. If not set, a new ZooKeeper instance is created.
      Parameters:
      existingZooKeepers - Connection string for a already-running ZooKeeper instance. A null value will turn off this feature.
      Since:
      2.1.0

    • setZooKeeperStartupTime

      public MiniAccumuloConfig setZooKeeperStartupTime(long zooKeeperStartupTime)
      Configure the time to wait for ZooKeeper to startup. Calling this method is optional. The default is 20000 milliseconds
      Parameters:
      zooKeeperStartupTime - Time to wait for ZooKeeper to startup, in milliseconds
      Since:
      1.6.1

    • setMemory

      public MiniAccumuloConfig setMemory(ServerType serverType, long memory, MemoryUnit memoryUnit)
      Sets the amount of memory to use in the manager process. Calling this method is optional. Default memory is 128M
      Parameters:
      serverType - the type of server to apply the memory settings
      memory - amount of memory to set
      memoryUnit - the units for which to apply with the memory size
      Since:
      1.6.0

    • setDefaultMemory

      public MiniAccumuloConfig setDefaultMemory(long memory, MemoryUnit memoryUnit)
      Sets the default memory size to use. This value is also used when a ServerType has not been configured explicitly. Calling this method is optional. Default memory is 128M
      Parameters:
      memory - amount of memory to set
      memoryUnit - the units for which to apply with the memory size
      Since:
      1.6.0

    • getSiteConfig

      public Map<String,String> getSiteConfig()
      Returns:
      a copy of the site config

    • getInstanceName

      public String getInstanceName()
      Returns:
      name of configured instance
      Since:
      1.6.0

    • getZooKeeperPort

      public int getZooKeeperPort()
      Returns:
      The configured zookeeper port
      Since:
      1.6.0

    • getMemory

      public long getMemory(ServerType serverType)
      Parameters:
      serverType - get configuration for this server type
      Returns:
      memory configured in bytes, returns default if this server type is not configured
      Since:
      1.6.0

    • getDefaultMemory

      public long getDefaultMemory()
      Returns:
      memory configured in bytes
      Since:
      1.6.0

    • getDir

      public File getDir()
      Returns:
      the base directory of the cluster configuration

    • getRootPassword

      public String getRootPassword()
      Returns:
      the root password of this cluster configuration

    • getNumTservers

      public int getNumTservers()
      Returns:
      the number of tservers configured for this cluster

    • isJDWPEnabled

      public boolean isJDWPEnabled()
      Returns:
      is the current configuration in jdwpEnabled mode?
      Since:
      1.6.0

    • setJDWPEnabled

      public MiniAccumuloConfig setJDWPEnabled(boolean jdwpEnabled)
      Parameters:
      jdwpEnabled - should the processes run remote jdwpEnabled servers?
      Returns:
      the current instance
      Since:
      1.6.0

    • getNativeLibPaths

      public String[] getNativeLibPaths()
      Returns:
      the paths to use for loading native libraries
      Since:
      1.6.0

    • setNativeLibPaths

      public MiniAccumuloConfig setNativeLibPaths(String... nativePathItems)
      Sets the path for processes to use for loading native libraries
      Parameters:
      nativePathItems - the nativePathItems to set
      Since:
      1.6.0

    • setClasspath

      public MiniAccumuloConfig setClasspath(String... classpathItems)
      Sets the classpath elements to use when spawning processes.
      Parameters:
      classpathItems - the classpathItems to set
      Returns:
      the current instance
      Since:
      2.0.0