AccumuloProperties extends StoreProperties { @Override public String getJsonSerialiserModules() { return new StringDeduplicateConcat().apply( SketchesJsonModules.class.getName(), super.getJsonSerialiserModules() ); } AccumuloProperties();  AccumuloProperties(final Path propFileLocation); static AccumuloProperties loadStoreProperties(final String pathStr); static AccumuloProperties loadStoreProperties(final InputStream storePropertiesStream); static AccumuloProperties loadStoreProperties(final Path storePropertiesPath); @Override AccumuloProperties clone(); void setNumThreadsForBatchWriter(final String numThreadsForBatchWriter); void setMaxTimeOutForBatchWriterInMilliseconds(final String maxTimeOutForBatchWriterInMilliseconds); void setMaxBufferSizeForBatchWriterInBytes(final String maxBufferSizeForBatchWriterInBytes); int getNumThreadsForBatchWriter(); Long getMaxTimeOutForBatchWriterInMilliseconds(); Long getMaxBufferSizeForBatchWriterInBytes(); String getZookeepers(); void setZookeepers(final String zookeepers); String getInstance(); void setInstance(final String instance); @Deprecated String getTable(); @Deprecated void setTable(final String tableName); String getUser(); void setUser(final String user); String getPassword(); void setPassword(final String password); String getNamespace(); void setNamespace(final String namespace); int getThreadsForBatchScanner(); void setThreadsForBatchScanner(final String threadsForBatchScanner); int getMaxEntriesForBatchScanner(); void setMaxEntriesForBatchScanner(final String maxEntriesForBatchScanner); int getClientSideBloomFilterSize(); void setClientSideBloomFilterSize(final String clientSideBloomFilterSize); double getFalsePositiveRate(); void setFalsePositiveRate(final String falsePositiveRate); int getMaxBloomFilterToPassToAnIterator(); void setMaxBloomFilterToPassToAnIterator(final String maxBloomFilterToPassToAnIterator); String getKeyPackageClass(); void setKeyPackageClass(final String keyPackageClass); String getTableFileReplicationFactor(); void setTableFileReplicationFactor(final String replicationFactor); boolean getEnableValidatorIterator(); void setEnableValidatorIterator(final boolean enableValidatorIterator); @Override String getJsonSerialiserModules(); static final String KEY_PACKAGE_CLASS; static final String INSTANCE_NAME; static final String ZOOKEEPERS; @Deprecated
    static final String TABLE; static final String USER; static final String PASSWORD; static final String NAMESPACE; static final String THREADS_FOR_BATCH_SCANNER; static final String MAX_ENTRIES_FOR_BATCH_SCANNER; static final String CLIENT_SIDE_BLOOM_FILTER_SIZE; static final String FALSE_POSITIVE_RATE; static final String MAX_BLOOM_FILTER_TO_PASS_TO_AN_ITERATOR; static final String MAX_BUFFER_SIZE_FOR_BATCH_WRITER; static final String MAX_TIME_OUT_FOR_BATCH_WRITER; static final String NUM_THREADS_FOR_BATCH_WRITER; static final String TABLE_REPLICATION_FACTOR; static final String ENABLE_VALIDATOR_ITERATOR; static final String HDFS_SKIP_PERMISSIONS; static final String ENABLE_VALIDATOR_ITERATOR_DEFAULT; }
@Test public void shouldMergeAccumuloJsonModules() { final AccumuloProperties props = new AccumuloProperties(); props.setJsonSerialiserModules(TestCustomJsonModules1.class.getName() + "," + TestCustomJsonModules2.class.getName()); final String modules = props.getJsonSerialiserModules(); assertEquals(SketchesJsonModules.class.getName() + "," + TestCustomJsonModules1.class.getName() + "," + TestCustomJsonModules2.class.getName(), modules); }
@Test public void shouldMergeAccumuloJsonModulesAndDeduplicate() { final AccumuloProperties props = new AccumuloProperties(); props.setJsonSerialiserModules(TestCustomJsonModules1.class.getName() + "," + SketchesJsonModules.class.getName()); final String modules = props.getJsonSerialiserModules(); assertEquals(SketchesJsonModules.class.getName() + "," + TestCustomJsonModules1.class.getName(), modules); }