Revision 51131
Added by Claudio Atzori about 6 years ago
modules/dnet-modular-objectstore-service/trunk/src/main/java/eu/dnetlib/data/objectstore/modular/ObjectStoreConsistency.java | ||
---|---|---|
7 | 7 |
import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpException; |
8 | 8 |
import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService; |
9 | 9 |
import eu.dnetlib.enabling.locators.UniqueServiceLocator; |
10 |
import org.apache.commons.lang.StringUtils; |
|
10 |
import org.apache.commons.lang3.StringUtils;
|
|
11 | 11 |
import org.apache.commons.logging.Log; |
12 | 12 |
import org.apache.commons.logging.LogFactory; |
13 | 13 |
import org.springframework.beans.factory.annotation.Autowired; |
modules/dnet-modular-objectstore-service/trunk/src/main/java/eu/dnetlib/data/objectstore/modular/CreateObjectStoreAction.java | ||
---|---|---|
3 | 3 |
import eu.dnetlib.data.objectstore.rmi.ObjectStoreServiceException; |
4 | 4 |
import eu.dnetlib.enabling.tools.blackboard.BlackboardJob; |
5 | 5 |
import eu.dnetlib.enabling.tools.blackboard.BlackboardServerHandler; |
6 |
import org.apache.commons.lang.StringUtils; |
|
6 |
import org.apache.commons.lang3.StringUtils;
|
|
7 | 7 |
import org.apache.commons.logging.Log; |
8 | 8 |
import org.apache.commons.logging.LogFactory; |
9 | 9 |
|
modules/dnet-modular-objectstore-service/trunk/src/main/java/eu/dnetlib/data/objectstore/modular/ModularObjectStoreFeeder.java | ||
---|---|---|
1 | 1 |
package eu.dnetlib.data.objectstore.modular; |
2 | 2 |
|
3 |
import com.google.common.base.Function; |
|
4 | 3 |
import com.google.common.collect.Iterables; |
5 | 4 |
import com.google.common.collect.Lists; |
6 | 5 |
import eu.dnetlib.data.objectstore.modular.connector.ObjectStore; |
... | ... | |
88 | 87 |
public int feedMetadataObjectRecord(final String objectStoreID, final String rsEpr, final String mime) throws ObjectStoreServiceException { |
89 | 88 |
|
90 | 89 |
final Iterable<String> records = resultSetClientFactory.getClient(rsEpr); |
91 |
Iterable<MetadataObjectRecord> toIngest = Iterables.transform(records, new Function<String, MetadataObjectRecord>() { |
|
92 |
|
|
93 |
@Override |
|
94 |
public MetadataObjectRecord apply(final String input) { |
|
95 |
MetadataObjectRecord record = MetadataObjectRecord.initFromJson(input); |
|
96 |
if (record != null) { |
|
97 |
record.setMime(mime); |
|
98 |
} else { |
|
99 |
log.error("An input record is null :" + input); |
|
100 |
} |
|
101 |
return record; |
|
90 |
Iterable<MetadataObjectRecord> toIngest = Iterables.transform(records, input -> { |
|
91 |
MetadataObjectRecord record = MetadataObjectRecord.initFromJson(input); |
|
92 |
if (record != null) { |
|
93 |
record.setMime(mime); |
|
94 |
} else { |
|
95 |
log.error("An input record is null :" + input); |
|
102 | 96 |
} |
97 |
return record; |
|
103 | 98 |
}); |
104 | 99 |
ObjectStore store = dao.getObjectStore(objectStoreID); |
105 | 100 |
int size = store.feedMetadataRecord(toIngest, true); |
Also available in: Unified diff
using apache commons lang3