Github user jdasch commented on a diff in the pull request: https://github.com/apache/incubator-rya/pull/256#discussion_r159484266 --- Diff: extras/indexing/src/main/java/org/apache/rya/indexing/entity/update/mongo/MongoEntityIndexer.java --- @@ -39,44 +35,16 @@ */ @DefaultAnnotation(NonNull.class) public class MongoEntityIndexer extends BaseEntityIndexer { - private MongoClient client; - - @Override - public EntityStorage getEntityStorage(final Configuration conf) throws EntityStorageException { - final MongoDBRdfConfiguration mongoConf = (MongoDBRdfConfiguration) conf; - if (client == null) { - if(mongoConf.getMongoClient() != null) { - client = mongoConf.getMongoClient(); - } else { - client = MongoConnectorFactory.getMongoClient(conf); - } - } - final String ryaInstanceName = new MongoDBRdfConfiguration(conf).getMongoDBName(); - return new MongoEntityStorage(client, ryaInstanceName); - } - - @Override - public TypeStorage getTypeStorage(final Configuration conf) { - final MongoDBRdfConfiguration mongoConf = (MongoDBRdfConfiguration) conf; - if (client == null) { - if(mongoConf.getMongoClient() != null) { - client = mongoConf.getMongoClient(); - } else { - client = MongoConnectorFactory.getMongoClient(conf); - } - } - final String ryaInstanceName = new MongoDBRdfConfiguration(conf).getMongoDBName(); - return new MongoTypeStorage(client, ryaInstanceName); - } - @Override - public void init() { - //nothing to init. + public EntityStorage getEntityStorage() throws EntityStorageException { + final StatefulMongoDBRdfConfiguration conf = super.configuration.get(); --- End diff -- remove tab character
---