Java 类org.apache.lucene.index.CorruptIndexException 实例源码

项目：elasticsearch_my 文件：ChecksumBlobStoreFormat.java

/**
 * Reads blob with specified name without resolving the blobName using using {@link #blobName} method.
 *
 * @param blobContainer blob container
 * @param blobName blob name
 */
public T readBlob(BlobContainer blobContainer, String blobName) throws IOException {
    try (InputStream inputStream = blobContainer.readBlob(blobName)) {
        ByteArrayOutputStream out = new ByteArrayOutputStream();
        Streams.copy(inputStream, out);
        final byte[] bytes = out.toByteArray();
        final String resourceDesc = "ChecksumBlobStoreFormat.readBlob(blob=\"" + blobName + "\")";
        try (ByteArrayIndexInput indexInput = new ByteArrayIndexInput(resourceDesc, bytes)) {
            CodecUtil.checksumEntireFile(indexInput);
            CodecUtil.checkHeader(indexInput, codec, VERSION, VERSION);
            long filePointer = indexInput.getFilePointer();
            long contentSize = indexInput.length() - CodecUtil.footerLength() - filePointer;
            BytesReference bytesReference = new BytesArray(bytes, (int) filePointer, (int) contentSize);
            return read(bytesReference);
        } catch (CorruptIndexException | IndexFormatTooOldException | IndexFormatTooNewException ex) {
            // we trick this into a dedicated exception with the original stacktrace
            throw new CorruptStateException(ex);
        }
    }
}

项目：bibliome-java-utils 文件：PubMedIndexSearcher.java

private void outputBatch(IndexReader indexReader, TopDocs topDocs, int batch, String outputBaseFormat, String pmidOutputFormat, String xmlOutputFormat) throws CorruptIndexException, IOException {
    String outputBasePath = String.format(outputBaseFormat, batch);
    OutputDirectory outputBaseDir = new OutputDirectory(outputBasePath);
    int start = batch * batchSize;
    int end = Math.min(start + batchSize, topDocs.totalHits);
    if (pmidOutputFormat != null) {
        try (PrintStream out = open(batch, outputBaseDir, pmidOutputFormat)) {
            for (int d = start; d < end; ++d) {
                outputBatchDocument(indexReader, topDocs, out, PubMedIndexField.PMID, d);
            }
        }
    }
    if (xmlOutputFormat != null) {
        try (PrintStream out = open(batch, outputBaseDir, xmlOutputFormat)) {
            out.println(XML_HEADER);
            for (int d = start; d < end; ++d) {
                outputBatchDocument(indexReader, topDocs, out, PubMedIndexField.XML, d);
            }
            out.println(XML_FOOTER);
        }
    }
}

项目：elasticsearch_my 文件：StoreTests.java

public void testCanOpenIndex() throws IOException {
    final ShardId shardId = new ShardId("index", "_na_", 1);
    IndexWriterConfig iwc = newIndexWriterConfig();
    Path tempDir = createTempDir();
    final BaseDirectoryWrapper dir = newFSDirectory(tempDir);
    assertFalse(Store.canOpenIndex(logger, tempDir, shardId, (id, l) -> new DummyShardLock(id)));
    IndexWriter writer = new IndexWriter(dir, iwc);
    Document doc = new Document();
    doc.add(new StringField("id", "1", random().nextBoolean() ? Field.Store.YES : Field.Store.NO));
    writer.addDocument(doc);
    writer.commit();
    writer.close();
    assertTrue(Store.canOpenIndex(logger, tempDir, shardId, (id, l) -> new DummyShardLock(id)));

    DirectoryService directoryService = new DirectoryService(shardId, INDEX_SETTINGS) {

        @Override
        public Directory newDirectory() throws IOException {
            return dir;
        }
    };
    Store store = new Store(shardId, INDEX_SETTINGS, directoryService, new DummyShardLock(shardId));
    store.markStoreCorrupted(new CorruptIndexException("foo", "bar"));
    assertFalse(Store.canOpenIndex(logger, tempDir, shardId, (id, l) -> new DummyShardLock(id)));
    store.close();
}

项目：elasticsearch_my 文件：ShardFailedClusterStateTaskExecutorTests.java

private List<ShardStateAction.ShardEntry> createNonExistentShards(ClusterState currentState, String reason) {
    // add shards from a non-existent index
    String nonExistentIndexUUID = "non-existent";
    Index index = new Index("non-existent", nonExistentIndexUUID);
    List<String> nodeIds = new ArrayList<>();
    for (ObjectCursor<String> nodeId : currentState.nodes().getNodes().keys()) {
        nodeIds.add(nodeId.toString());
    }
    List<ShardRouting> nonExistentShards = new ArrayList<>();
    nonExistentShards.add(nonExistentShardRouting(index, nodeIds, true));
    for (int i = 0; i < numberOfReplicas; i++) {
        nonExistentShards.add(nonExistentShardRouting(index, nodeIds, false));
    }

    List<ShardStateAction.ShardEntry> existingShards = createExistingShards(currentState, reason);
    List<ShardStateAction.ShardEntry> shardsWithMismatchedAllocationIds = new ArrayList<>();
    for (ShardStateAction.ShardEntry existingShard : existingShards) {
        shardsWithMismatchedAllocationIds.add(new ShardStateAction.ShardEntry(existingShard.shardId, UUIDs.randomBase64UUID(), 0L, existingShard.message, existingShard.failure));
    }

    List<ShardStateAction.ShardEntry> tasks = new ArrayList<>();
    nonExistentShards.forEach(shard -> tasks.add(new ShardStateAction.ShardEntry(shard.shardId(), shard.allocationId().getId(), 0L, reason, new CorruptIndexException("simulated", nonExistentIndexUUID))));
    tasks.addAll(shardsWithMismatchedAllocationIds);
    return tasks;
}

项目：sdudoc 文件：LuceneIndexSearch.java

/**
 * 查询方法
 * @throws IOException 
 * @throws CorruptIndexException 
 * @throws ParseException 
 */
public List Search(String searchString,LuceneResultCollector luceneResultCollector) throws CorruptIndexException, IOException, ParseException{
    //方法一:

    System.out.println(this.indexSettings.getAnalyzer().getClass()+"----分词选择");
    QueryParser q = new QueryParser(Version.LUCENE_44, "summary", this.indexSettings.getAnalyzer());
    String search = new String(searchString.getBytes("ISO-8859-1"),"UTF-8"); 
    System.out.println(search+"----------搜索的词语dd");
    Query query = q.parse(search);
    //方法二:
    /*
    Term t = new Term("title", searchString);
    TermQuery query = new TermQuery(t);
    */
    System.out.println(query.toString()+"--------query.tostring");
    ScoreDoc[] docs = this.indexSearcher.search(query,100).scoreDocs;
    System.out.println("一共有:"+docs.length+"条记录");
    List result = luceneResultCollector.collect(docs, this.indexSearcher);
    return result;
}

项目：lams 文件：Lucene40StoredFieldsReader.java

private void skipField(int bits) throws IOException {
  final int numeric = bits & FIELD_IS_NUMERIC_MASK;
  if (numeric != 0) {
    switch(numeric) {
      case FIELD_IS_NUMERIC_INT:
      case FIELD_IS_NUMERIC_FLOAT:
        fieldsStream.readInt();
        return;
      case FIELD_IS_NUMERIC_LONG:
      case FIELD_IS_NUMERIC_DOUBLE:
        fieldsStream.readLong();
        return;
      default: 
        throw new CorruptIndexException("Invalid numeric type: " + Integer.toHexString(numeric));
    }
  } else {
    final int length = fieldsStream.readVInt();
    fieldsStream.seek(fieldsStream.getFilePointer() + length);
  }
}