Revision 8647
Added by ben leinfelder over 10 years ago
| MetacatSolrIndex.java | ||
|---|---|---|
| 168 | 168 |
return inputStream; |
| 169 | 169 |
|
| 170 | 170 |
} |
| 171 |
|
|
| 172 |
public void submit(Identifier pid, SystemMetadata systemMetadata, Map<String, List<Object>> fields) {
|
|
| 171 |
|
|
| 172 |
public void submit(Identifier pid, SystemMetadata systemMetadata, Map<String, List<Object>> fields, boolean followRevisions) {
|
|
| 173 | 173 |
IndexTask task = new IndexTask(); |
| 174 | 174 |
task.setSystemMetadata(systemMetadata); |
| 175 | 175 |
task.setFields(fields); |
| 176 |
HazelcastService.getInstance().getIndexQueue().put(pid, task ); |
|
| 176 |
HazelcastService.getInstance().getIndexQueue().put(pid, task); |
|
| 177 |
|
|
| 178 |
// submit older revisions recursively otherwise they stay in the index! |
|
| 179 |
if (followRevisions && systemMetadata != null && systemMetadata.getObsoletes() != null) {
|
|
| 180 |
Identifier obsoletedPid = systemMetadata.getObsoletes(); |
|
| 181 |
SystemMetadata obsoletedSysMeta = HazelcastService.getInstance().getSystemMetadataMap().get(obsoletedPid); |
|
| 182 |
this.submit(obsoletedPid, obsoletedSysMeta , null, followRevisions); |
|
| 183 |
} |
|
| 184 |
|
|
| 177 | 185 |
} |
| 178 | 186 |
|
| 179 | 187 |
|
Also available in: Unified diff
recursively submit obsoleted objects for indexing when instructed. https://projects.ecoinformatics.org/ecoinfo/issues/6424