Class 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 Detail

      • 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 Detail

      • 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
      • 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
      • 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 master 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