Revision 7802
Added by Jing Tao almost 11 years ago
| IndexGenerator.java | ||
|---|---|---|
| 30 | 30 |
import java.io.FileNotFoundException; |
| 31 | 31 |
import java.io.InputStream; |
| 32 | 32 |
import java.util.ArrayList; |
| 33 |
import java.util.Calendar; |
|
| 33 | 34 |
import java.util.Date; |
| 34 | 35 |
import java.util.List; |
| 35 | 36 |
import java.util.TimerTask; |
| ... | ... | |
| 54 | 55 |
import com.hazelcast.core.IMap; |
| 55 | 56 |
import com.hazelcast.core.ISet; |
| 56 | 57 |
|
| 58 |
import edu.ucsb.nceas.metacat.index.event.EventlogFactory; |
|
| 59 |
import edu.ucsb.nceas.metacat.index.event.IndexEvent; |
|
| 57 | 60 |
|
| 61 |
|
|
| 58 | 62 |
/** |
| 59 | 63 |
* A class represents the object to generate massive solr indexes. |
| 60 | 64 |
* This can happen during an update of Metacat (generating index for all existing documents) |
| ... | ... | |
| 216 | 220 |
} |
| 217 | 221 |
|
| 218 | 222 |
public void run() {
|
| 223 |
IndexEvent event = new IndexEvent(); |
|
| 224 |
event.setDate(Calendar.getInstance().getTime()); |
|
| 225 |
event.setType(IndexEvent.STARTTIMEDINDEX); |
|
| 226 |
event.setDescription("Start the timed index job");
|
|
| 219 | 227 |
try {
|
| 228 |
EventlogFactory.createIndexEventLog().write(event); |
|
| 229 |
} catch (Exception e) {
|
|
| 230 |
log.error("IndexGenerator.run - IndexEventLog can't log the timed indexing start event :"+e.getMessage());
|
|
| 231 |
} |
|
| 232 |
try {
|
|
| 233 |
|
|
| 220 | 234 |
indexAll(); |
| 221 | 235 |
} catch (InvalidRequest e) {
|
| 222 | 236 |
// TODO Auto-generated catch block |
| ... | ... | |
| 244 | 258 |
} catch (FileNotFoundException e) {
|
| 245 | 259 |
log.error("IndexGenerator.run - Metadata-Index couldn't generate indexes for those documents which haven't been indexed : "+e.getMessage());
|
| 246 | 260 |
} |
| 261 |
event.setDate(Calendar.getInstance().getTime()); |
|
| 262 |
event.setType(IndexEvent.FINISHTIMEDINDEX); |
|
| 263 |
event.setDescription("Finish the timed index job");
|
|
| 264 |
try {
|
|
| 265 |
EventlogFactory.createIndexEventLog().write(event); |
|
| 266 |
} catch (Exception e) {
|
|
| 267 |
log.error("IndexGenerator.run - IndexEventLog can't log the timed indexing finish event :"+e.getMessage());
|
|
| 268 |
} |
|
| 247 | 269 |
} |
| 248 | 270 |
|
| 249 | 271 |
/* |
Also available in: Unified diff
Log the timed index jobs.