@Test(expected = NullPointerException.class) public void testNullObserverProvider() { FluoConfiguration fc = new FluoConfiguration(); fc.setObserverProvider((String) null); }
public void setObserverProvider(String className) { setNonEmptyString(OBSERVER_PROVIDER, className); }
FluoConfiguration extends SimpleConfiguration { public void setObserverProvider(String className) { setNonEmptyString(OBSERVER_PROVIDER, className); } }
FluoConfiguration extends SimpleConfiguration { public void setObserverProvider(String className) { setNonEmptyString(OBSERVER_PROVIDER, className); } FluoConfiguration();  FluoConfiguration(SimpleConfiguration other);  FluoConfiguration(InputStream in);  FluoConfiguration(File propertiesFile);  FluoConfiguration(Map<String, String> map); }
FluoConfiguration extends SimpleConfiguration { public void setObserverProvider(String className) { setNonEmptyString(OBSERVER_PROVIDER, className); } FluoConfiguration();  FluoConfiguration(SimpleConfiguration other);  FluoConfiguration(InputStream in);  FluoConfiguration(File propertiesFile);  FluoConfiguration(Map<String, String> map); void validate(); FluoConfiguration setApplicationName(String applicationName); String getApplicationName(); FluoConfiguration setInstanceZookeepers(String zookeepers); String getInstanceZookeepers(); String getAppZookeepers(); FluoConfiguration setZookeeperTimeout(int timeout); int getZookeeperTimeout(); String getZookeeperSecret(); void setZookeeperSecret(String secret); @Deprecated FluoConfiguration setClientRetryTimeout(int timeoutMs); @Deprecated int getClientRetryTimeout(); FluoConfiguration setConnectionRetryTimeout(int timeoutMS); int getConnectionRetryTimeout(); FluoConfiguration setAccumuloInstance(String accumuloInstance); String getAccumuloInstance(); FluoConfiguration setAccumuloUser(String accumuloUser); String getAccumuloUser(); FluoConfiguration setAccumuloPassword(String accumuloPassword); String getAccumuloPassword(); FluoConfiguration setAccumuloZookeepers(String zookeepers); String getAccumuloZookeepers(); FluoConfiguration setAccumuloTable(String table); String getAccumuloTable(); FluoConfiguration setAccumuloJars(String path); String getAccumuloJars(); FluoConfiguration setDfsRoot(String dfsRoot); String getDfsRoot(); FluoConfiguration setWorkerThreads(int numThreads); int getWorkerThreads(); @Deprecated List<ObserverSpecification> getObserverSpecifications(); void setObserverProvider(String className); void setObserverProvider(Class<? extends ObserverProvider> clazz); FluoConfiguration setObserverInitDir(String observerDir); String getObserverInitDir(); FluoConfiguration setObserverJarsUrl(String observerJarsUrl); String getObserverJarsUrl(); String getObserverProvider(); @Deprecated FluoConfiguration addObserver(ObserverSpecification oconf); @Deprecated FluoConfiguration addObservers(Iterable<ObserverSpecification> observers); @Deprecated FluoConfiguration clearObservers(); FluoConfiguration setTransactionRollbackTime(long time, TimeUnit tu); long getTransactionRollbackTime(); FluoConfiguration setLoaderThreads(int numThreads); int getLoaderThreads(); FluoConfiguration setLoaderQueueSize(int queueSize); int getLoaderQueueSize(); SimpleConfiguration getReporterConfiguration(String reporter); SimpleConfiguration getAppConfiguration(); FluoConfiguration setMiniStartAccumulo(boolean startAccumulo); boolean getMiniStartAccumulo(); FluoConfiguration setMiniDataDir(String dataDir); String getMiniDataDir(); void print(); boolean hasRequiredConnectionProps(); boolean hasRequiredClientProps(); boolean hasRequiredAdminProps(); boolean hasRequiredOracleProps(); boolean hasRequiredWorkerProps(); boolean hasRequiredMiniFluoProps(); SimpleConfiguration getClientConfiguration(); static SimpleConfiguration getDefaultConfiguration(); static void setDefaultConfiguration(SimpleConfiguration config); }
FluoConfiguration extends SimpleConfiguration { public void setObserverProvider(String className) { setNonEmptyString(OBSERVER_PROVIDER, className); } FluoConfiguration();  FluoConfiguration(SimpleConfiguration other);  FluoConfiguration(InputStream in);  FluoConfiguration(File propertiesFile);  FluoConfiguration(Map<String, String> map); void validate(); FluoConfiguration setApplicationName(String applicationName); String getApplicationName(); FluoConfiguration setInstanceZookeepers(String zookeepers); String getInstanceZookeepers(); String getAppZookeepers(); FluoConfiguration setZookeeperTimeout(int timeout); int getZookeeperTimeout(); String getZookeeperSecret(); void setZookeeperSecret(String secret); @Deprecated FluoConfiguration setClientRetryTimeout(int timeoutMs); @Deprecated int getClientRetryTimeout(); FluoConfiguration setConnectionRetryTimeout(int timeoutMS); int getConnectionRetryTimeout(); FluoConfiguration setAccumuloInstance(String accumuloInstance); String getAccumuloInstance(); FluoConfiguration setAccumuloUser(String accumuloUser); String getAccumuloUser(); FluoConfiguration setAccumuloPassword(String accumuloPassword); String getAccumuloPassword(); FluoConfiguration setAccumuloZookeepers(String zookeepers); String getAccumuloZookeepers(); FluoConfiguration setAccumuloTable(String table); String getAccumuloTable(); FluoConfiguration setAccumuloJars(String path); String getAccumuloJars(); FluoConfiguration setDfsRoot(String dfsRoot); String getDfsRoot(); FluoConfiguration setWorkerThreads(int numThreads); int getWorkerThreads(); @Deprecated List<ObserverSpecification> getObserverSpecifications(); void setObserverProvider(String className); void setObserverProvider(Class<? extends ObserverProvider> clazz); FluoConfiguration setObserverInitDir(String observerDir); String getObserverInitDir(); FluoConfiguration setObserverJarsUrl(String observerJarsUrl); String getObserverJarsUrl(); String getObserverProvider(); @Deprecated FluoConfiguration addObserver(ObserverSpecification oconf); @Deprecated FluoConfiguration addObservers(Iterable<ObserverSpecification> observers); @Deprecated FluoConfiguration clearObservers(); FluoConfiguration setTransactionRollbackTime(long time, TimeUnit tu); long getTransactionRollbackTime(); FluoConfiguration setLoaderThreads(int numThreads); int getLoaderThreads(); FluoConfiguration setLoaderQueueSize(int queueSize); int getLoaderQueueSize(); SimpleConfiguration getReporterConfiguration(String reporter); SimpleConfiguration getAppConfiguration(); FluoConfiguration setMiniStartAccumulo(boolean startAccumulo); boolean getMiniStartAccumulo(); FluoConfiguration setMiniDataDir(String dataDir); String getMiniDataDir(); void print(); boolean hasRequiredConnectionProps(); boolean hasRequiredClientProps(); boolean hasRequiredAdminProps(); boolean hasRequiredOracleProps(); boolean hasRequiredWorkerProps(); boolean hasRequiredMiniFluoProps(); SimpleConfiguration getClientConfiguration(); static SimpleConfiguration getDefaultConfiguration(); static void setDefaultConfiguration(SimpleConfiguration config); static final String FLUO_PREFIX; @Deprecated
  static final String CLIENT_APPLICATION_NAME_PROP; @Deprecated
  static final String CLIENT_ACCUMULO_PASSWORD_PROP; @Deprecated
  static final String CLIENT_ACCUMULO_USER_PROP; @Deprecated
  static final String CLIENT_ACCUMULO_INSTANCE_PROP; @Deprecated
  static final String CLIENT_ACCUMULO_ZOOKEEPERS_PROP; @Deprecated
  static final String CLIENT_ZOOKEEPER_TIMEOUT_PROP; @Deprecated
  static final String CLIENT_ZOOKEEPER_CONNECT_PROP; @Deprecated
  static final String CLIENT_RETRY_TIMEOUT_MS_PROP; @Deprecated
  static final int CLIENT_ZOOKEEPER_TIMEOUT_DEFAULT; @Deprecated
  static final String CLIENT_ACCUMULO_ZOOKEEPERS_DEFAULT; @Deprecated
  static final String CLIENT_ZOOKEEPER_CONNECT_DEFAULT; @Deprecated
  static final int CLIENT_RETRY_TIMEOUT_MS_DEFAULT; static final String CONNECTION_PREFIX; static final String CONNECTION_APPLICATION_NAME_PROP; static final String CONNECTION_ZOOKEEPER_TIMEOUT_PROP; static final String CONNECTION_ZOOKEEPER_SECRET; static final String CONNECTION_ZOOKEEPERS_PROP; static final String CONNECTION_RETRY_TIMEOUT_MS_PROP; static final int CONNECTION_ZOOKEEPER_TIMEOUT_DEFAULT; static final String CONNECTION_ZOOKEEPERS_DEFAULT; static final int CONNECTION_RETRY_TIMEOUT_MS_DEFAULT; static final String ACCUMULO_INSTANCE_PROP; static final String ACCUMULO_TABLE_PROP; static final String ACCUMULO_PASSWORD_PROP; static final String ACCUMULO_USER_PROP; static final String ACCUMULO_ZOOKEEPERS_PROP; static final String ACCUMULO_JARS_PROP; static final String ACCUMULO_ZOOKEEPERS_DEFAULT; static final String ACCUMULO_JARS_DEFAULT; static final String DFS_ROOT_PROP; static final String DFS_ROOT_DEFAULT; @Deprecated
  static final String ADMIN_ACCUMULO_TABLE_PROP; static final String WORKER_NUM_THREADS_PROP; static final int WORKER_NUM_THREADS_DEFAULT; static final String LOADER_NUM_THREADS_PROP; static final String LOADER_QUEUE_SIZE_PROP; static final int LOADER_NUM_THREADS_DEFAULT; static final int LOADER_QUEUE_SIZE_DEFAULT; static final String MINI_START_ACCUMULO_PROP; static final String MINI_DATA_DIR_PROP; static final boolean MINI_START_ACCUMULO_DEFAULT; static final String MINI_DATA_DIR_DEFAULT; static final String OBSERVER_PREFIX; static final String OBSERVER_PROVIDER; static final String OBSERVER_INIT_DIR_PROP; static final String OBSERVER_JARS_URL_PROP; static final String OBSERVER_PROVIDER_DEFAULT; static final String OBSERVER_INIT_DIR_DEFAULT; static final String OBSERVER_JARS_URL_DEFAULT; static final String TRANSACTION_PREFIX; static final String TRANSACTION_ROLLBACK_TIME_PROP; static final long TRANSACTION_ROLLBACK_TIME_DEFAULT; static final String REPORTER_PREFIX; static final String APP_PREFIX; }