public class FluoConfiguration extends SimpleConfiguration
Constructor and Description |
---|
FluoConfiguration() |
FluoConfiguration(File propertiesFile) |
FluoConfiguration(InputStream in) |
FluoConfiguration(Map<String,String> map) |
FluoConfiguration(SimpleConfiguration other) |
clear, clearProperty, containsKey, getBoolean, getBoolean, getInt, getInt, getKeys, getKeys, getLong, getLong, getRawString, getString, getString, save, save, setProperty, setProperty, setProperty, setProperty, subset, toMap, toString
public static final String FLUO_PREFIX
public static final String CLIENT_APPLICATION_NAME_PROP
public static final String CLIENT_ACCUMULO_PASSWORD_PROP
public static final String CLIENT_ACCUMULO_USER_PROP
public static final String CLIENT_ACCUMULO_INSTANCE_PROP
public static final String CLIENT_ACCUMULO_ZOOKEEPERS_PROP
public static final String CLIENT_ZOOKEEPER_TIMEOUT_PROP
public static final String CLIENT_ZOOKEEPER_CONNECT_PROP
public static final String CLIENT_RETRY_TIMEOUT_MS_PROP
public static final int CLIENT_ZOOKEEPER_TIMEOUT_DEFAULT
public static final String CLIENT_ACCUMULO_ZOOKEEPERS_DEFAULT
public static final String CLIENT_ZOOKEEPER_CONNECT_DEFAULT
public static final int CLIENT_RETRY_TIMEOUT_MS_DEFAULT
public static final String ADMIN_ACCUMULO_TABLE_PROP
public static final String ADMIN_ACCUMULO_CLASSPATH_PROP
public static final String ADMIN_ACCUMULO_CLASSPATH_DEFAULT
public static final String WORKER_NUM_THREADS_PROP
public static final int WORKER_NUM_THREADS_DEFAULT
public static final String LOADER_NUM_THREADS_PROP
public static final String LOADER_QUEUE_SIZE_PROP
public static final int LOADER_NUM_THREADS_DEFAULT
public static final int LOADER_QUEUE_SIZE_DEFAULT
public static final String MINI_START_ACCUMULO_PROP
public static final String MINI_DATA_DIR_PROP
public static final boolean MINI_START_ACCUMULO_DEFAULT
public static final String MINI_DATA_DIR_DEFAULT
@Deprecated public static final String OBSERVER_PREFIX
public static final String OBSERVER_PROVIDER
public static final String OBSERVER_PROVIDER_DEFAULT
public static final String TRANSACTION_PREFIX
public static final String TRANSACTION_ROLLBACK_TIME_PROP
public static final long TRANSACTION_ROLLBACK_TIME_DEFAULT
public static final String REPORTER_PREFIX
public static final String APP_PREFIX
public FluoConfiguration()
public FluoConfiguration(SimpleConfiguration other)
public FluoConfiguration(InputStream in)
public FluoConfiguration(File propertiesFile)
public void validate()
public FluoConfiguration setApplicationName(String applicationName)
public String getApplicationName()
public FluoConfiguration setInstanceZookeepers(String zookeepers)
public String getInstanceZookeepers()
public String getAppZookeepers()
public FluoConfiguration setZookeeperTimeout(int timeout)
public int getZookeeperTimeout()
public FluoConfiguration setClientRetryTimeout(int timeoutMS)
public int getClientRetryTimeout()
public FluoConfiguration setAccumuloInstance(String accumuloInstance)
public String getAccumuloInstance()
public FluoConfiguration setAccumuloUser(String accumuloUser)
public String getAccumuloUser()
public FluoConfiguration setAccumuloPassword(String accumuloPassword)
public String getAccumuloPassword()
public FluoConfiguration setAccumuloZookeepers(String zookeepers)
public String getAccumuloZookeepers()
public FluoConfiguration setAccumuloTable(String table)
public String getAccumuloTable()
public FluoConfiguration setAccumuloClasspath(String path)
public String getAccumuloClasspath()
public FluoConfiguration setWorkerThreads(int numThreads)
public int getWorkerThreads()
@Deprecated public List<ObserverSpecification> getObserverSpecifications()
setObserverProvider(String)
and
getObserverProvider()
public void setObserverProvider(String className)
className
- Name of a class that implements ObserverProvider
. Must be non-null and
non-empty.public void setObserverProvider(Class<? extends ObserverProvider> clazz)
setObserverProvider(String)
with the class name.public String getObserverProvider()
ObserverProvider
class name. If one was not configured, returns
""@Deprecated public FluoConfiguration addObserver(ObserverSpecification oconf)
setObserverProvider(String)
and
getObserverProvider()
ObserverSpecification
to the configuration using a unique integer prefix thats
not currently in use.@Deprecated public FluoConfiguration addObservers(Iterable<ObserverSpecification> observers)
setObserverProvider(String)
and
getObserverProvider()
@Deprecated public FluoConfiguration clearObservers()
setObserverProvider(String)
and
getObserverProvider()
public FluoConfiguration setTransactionRollbackTime(long time, TimeUnit tu)
public long getTransactionRollbackTime()
public FluoConfiguration setLoaderThreads(int numThreads)
public int getLoaderThreads()
public FluoConfiguration setLoaderQueueSize(int queueSize)
public int getLoaderQueueSize()
public SimpleConfiguration getReporterConfiguration(String reporter)
reporter
- The name of the reporter to get configuration for, i.e. console, jmx, graphite.public SimpleConfiguration getAppConfiguration()
FluoClient.getAppConfiguration()
and ObserverProvider.Context.getAppConfiguration()
public FluoConfiguration setMiniStartAccumulo(boolean startAccumulo)
public boolean getMiniStartAccumulo()
public FluoConfiguration setMiniDataDir(String dataDir)
public String getMiniDataDir()
public void print()
public boolean hasRequiredClientProps()
public boolean hasRequiredAdminProps()
public boolean hasRequiredOracleProps()
public boolean hasRequiredWorkerProps()
public boolean hasRequiredMiniFluoProps()
public SimpleConfiguration getClientConfiguration()
public static SimpleConfiguration getDefaultConfiguration()
public static void setDefaultConfiguration(SimpleConfiguration config)
Copyright © 2016–2017 The Apache Software Foundation. All rights reserved.