Searched refs:infos (Results 1 - 22 of 22) sorted by relevance

/lucene-3.6.0/lucene/contrib/misc/src/java/org/apache/lucene/index/
H A DBalancedSegmentMergePolicy.java108 public MergeSpecification findForcedMerges(SegmentInfos infos, int maxNumSegments, Map<SegmentInfo,Boolean> segmentsToMerge) throws IOException { argument
114 if (!isMerged(infos, maxNumSegments, segmentsToMerge)) {
119 int last = infos.size();
122 final SegmentInfo info = infos.info(--last);
135 if (last > 1 || !isMerged(infos.info(0))) {
138 spec.add(new OneMerge(infos.asList().subList(0, last)));
143 spec = findBalancedMerges(infos, last, maxNumSegments, _partialExpunge);
150 private MergeSpecification findBalancedMerges(SegmentInfos infos, int infoLen, int maxNumSegments, boolean partialExpunge) argument
159 double[][] variance = createVarianceTable(infos, infoLen, maxNumSegments);
195 spec.add(new OneMerge(infos
217 createVarianceTable(SegmentInfos infos, int last, int maxNumSegments) argument
246 findForcedDeletesMerges(SegmentInfos infos) argument
271 findMerges(SegmentInfos infos) argument
337 findOneSegmentToExpunge(SegmentInfos infos, int maxNumSegments) argument
[all...]
H A DIndexSplitter.java55 public SegmentInfos infos; field in class:IndexSplitter
100 infos = new SegmentInfos();
101 infos.read(fsDir);
106 for (int x = 0; x < infos.size(); x++) {
107 SegmentInfo info = infos.info(x);
114 for (int x = 0; x < infos.size(); x++) {
115 if (name.equals(infos.info(x).name))
122 for (int x = 0; x < infos.size(); x++) {
123 if (name.equals(infos.info(x).name))
124 return infos
[all...]
/lucene-3.6.0/lucene/core/src/java/org/apache/lucene/index/
H A DReadOnlyDirectoryReader.java30 ReadOnlyDirectoryReader(Directory directory, SegmentInfos infos, SegmentReader[] oldReaders, int[] oldStarts, Map<String,byte[]> oldNormsCache, boolean doClone, argument
32 super(directory, infos, oldReaders, oldStarts, oldNormsCache, true, doClone, termInfosIndexDivisor);
35 ReadOnlyDirectoryReader(IndexWriter writer, SegmentInfos infos, int termInfosIndexDivisor, boolean applyAllDeletes) throws IOException { argument
36 super(writer, infos, termInfosIndexDivisor, applyAllDeletes);
H A DLogMergePolicy.java135 public boolean useCompoundFile(SegmentInfos infos, SegmentInfo mergedInfo) throws IOException { argument
144 for (SegmentInfo info : infos)
204 protected boolean isMerged(SegmentInfos infos, int maxNumSegments, Map<SegmentInfo,Boolean> segmentsToMerge) throws IOException { argument
205 final int numSegments = infos.size();
210 final SegmentInfo info = infos.info(i);
246 SegmentInfos infos, int maxNumSegments, int last) throws IOException {
248 final List<SegmentInfo> segments = infos.asList();
252 SegmentInfo info = infos.info(start);
259 if (last - start - 1 > 1 || (start != last - 1 && !isMerged(infos.info(start + 1)))) {
275 if (last > 0 && (++start + 1 < last || !isMerged(infos
245 findForcedMergesSizeLimit( SegmentInfos infos, int maxNumSegments, int last) argument
287 findForcedMergesMaxNumSegments(SegmentInfos infos, int maxNumSegments, int last) argument
352 findForcedMerges(SegmentInfos infos, int maxNumSegments, Map<SegmentInfo,Boolean> segmentsToMerge) argument
492 findMerges(SegmentInfos infos) argument
[all...]
H A DMergeDocIDRemapper.java33 public MergeDocIDRemapper(SegmentInfos infos, int[][] docMaps, int[] delCounts, MergePolicy.OneMerge merge, int mergedDocCount) { argument
38 SegmentInfo info = infos.info(i);
47 numDocs += infos.info(i).docCount;
48 assert infos.info(i).equals(merge.segments.get(j));
H A DDirectoryReader.java75 SegmentInfos infos = new SegmentInfos();
76 infos.read(directory, segmentFileName);
78 return new ReadOnlyDirectoryReader(directory, infos, deletionPolicy, termInfosIndexDivisor);
80 return new DirectoryReader(directory, infos, deletionPolicy, false, termInfosIndexDivisor);
119 DirectoryReader(IndexWriter writer, SegmentInfos infos, int termInfosIndexDivisor, boolean applyAllDeletes) throws IOException { argument
127 // us, which ensures infos will not change; so there's
129 final int numSegments = infos.size();
134 segmentInfos = (SegmentInfos) infos.clone();
140 final SegmentInfo info = infos.info(i);
165 DirectoryReader(Directory directory, SegmentInfos infos, SegmentReade argument
487 doOpenIfChanged(SegmentInfos infos, boolean doClone, boolean openReadOnly) argument
1007 ReaderCommit(SegmentInfos infos, Directory dir) argument
[all...]
H A DTieredMergePolicy.java268 public MergeSpecification findMerges(SegmentInfos infos) throws IOException { argument
270 message("findMerges: " + infos.size() + " segments");
272 if (infos.size() == 0) {
278 final List<SegmentInfo> infosSorted = new ArrayList<SegmentInfo>(infos.asList());
481 public MergeSpecification findForcedMerges(SegmentInfos infos, int maxSegmentCount, Map<SegmentInfo,Boolean> segmentsToMerge) throws IOException { argument
483 message("findForcedMerges maxSegmentCount=" + maxSegmentCount + " infos=" + writer.get().segString(infos) + " segmentsToMerge=" + segmentsToMerge);
490 for(SegmentInfo info : infos) {
553 public MergeSpecification findForcedDeletesMerges(SegmentInfos infos) argument
556 message("findForcedDeletesMerges infos
601 useCompoundFile(SegmentInfos infos, SegmentInfo mergedInfo) argument
[all...]
H A DBufferedDeletesStream.java151 public synchronized ApplyDeletesResult applyDeletes(IndexWriter.ReaderPool readerPool, List<SegmentInfo> infos) throws IOException { argument
154 if (infos.size() == 0) {
166 message("applyDeletes: infos=" + infos + " packetCount=" + deletes.size());
170 infos2.addAll(infos);
277 // assert infos != segmentInfos || !any() : "infos=" + infos + " segmentInfos=" + segmentInfos + " any=" + any;
H A DSegmentInfos.java210 * Get the segments_N filename in use by this segment infos.
342 // Clear any segment infos we had loaded so we
392 segnOutput.writeInt(size()); // write infos
576 // the time it took us to load the now-old infos files
779 SegmentInfos infos = new SegmentInfos();
780 infos.addAll(segments.subList(first, last));
781 return infos;
1041 void rollbackSegmentInfos(List<SegmentInfo> infos) { argument
1043 this.addAll(infos);
H A DIndexWriter.java477 synchronized void clear(List<SegmentInfo> infos) throws IOException { argument
478 if (infos == null) {
483 for (final SegmentInfo info: infos) {
567 public synchronized void drop(List<SegmentInfo> infos) throws IOException { argument
568 for(SegmentInfo info : infos) {
628 synchronized void commit(SegmentInfos infos) throws IOException { argument
634 for (SegmentInfo info : infos) {
2869 message("rollback: infos=" + segString(segmentInfos));
3115 List<SegmentInfo> infos = new ArrayList<SegmentInfo>();
3121 SegmentInfos sis = new SegmentInfos(); // read infos fro
4422 segString(Iterable<SegmentInfo> infos) argument
4736 nrtIsCurrent(SegmentInfos infos) argument
[all...]
/lucene-3.6.0/lucene/core/src/test/org/apache/lucene/index/
H A DTestIndexWriterForceMerge.java204 SegmentInfos infos = new SegmentInfos();
205 infos.read(dir);
206 assertEquals(2, infos.size());
H A DTestBackwardsCompatibility.java757 final SegmentInfos infos = new SegmentInfos();
758 infos.read(dir);
760 System.out.println("checkAllSegmentsUpgraded: " + infos);
762 for (SegmentInfo si : infos) {
765 return infos.size();
769 final SegmentInfos infos = new SegmentInfos();
770 infos.read(dir);
771 return infos.size();
H A DTestPerSegmentDeletes.java73 // there will still be deletes in the segment infos
166 static boolean hasPendingDeletes(SegmentInfos infos) {
167 for (SegmentInfo info : infos) {
208 boolean segThere(SegmentInfo info, SegmentInfos infos) { argument
209 for (SegmentInfo si : infos) {
/lucene-3.6.0/lucene/backwards/src/test/org/apache/lucene/index/
H A DTestIndexWriterForceMerge.java204 SegmentInfos infos = new SegmentInfos();
205 infos.read(dir);
206 assertEquals(2, infos.size());
H A DTestBackwardsCompatibility.java724 final SegmentInfos infos = new SegmentInfos();
725 infos.read(dir);
727 System.out.println("checkAllSegmentsUpgraded: " + infos);
729 for (SegmentInfo si : infos) {
732 return infos.size();
736 final SegmentInfos infos = new SegmentInfos();
737 infos.read(dir);
738 return infos.size();
H A DTestPerSegmentDeletes.java72 // there will still be deletes in the segment infos
165 static boolean hasPendingDeletes(SegmentInfos infos) {
166 for (SegmentInfo info : infos) {
207 boolean segThere(SegmentInfo info, SegmentInfos infos) { argument
208 for (SegmentInfo si : infos) {
H A DTestIndexWriter.java146 SegmentInfos infos = new SegmentInfos();
147 infos.read(dir);
/lucene-3.6.0/lucene/test-framework/src/java/org/apache/lucene/index/
H A DMockRandomMergePolicy.java110 public boolean useCompoundFile(SegmentInfos infos, SegmentInfo mergedInfo) throws IOException { argument
/lucene-3.6.0/lucene/backwards/src/test-framework/java/org/apache/lucene/index/
H A DMockRandomMergePolicy.java107 public boolean useCompoundFile(SegmentInfos infos, SegmentInfo mergedInfo) throws IOException { argument
/lucene-3.6.0/lucene/contrib/misc/src/test/org/apache/lucene/index/
H A DTestIndexSplitter.java69 String splitSegName = is.infos.info(1).name;
126 String splitSegName = indexSplitter.infos.info(0).name;
/lucene-3.6.0/lucene/contrib/facet/src/java/org/apache/lucene/facet/taxonomy/directory/
H A DDirectoryTaxonomyWriter.java121 SegmentInfos infos = new SegmentInfos();
122 infos.read(dir);
123 return infos.getUserData();
/lucene-3.6.0/lucene/contrib/benchmark/src/test/org/apache/lucene/benchmark/byTask/
H A DTestPerfTasksLogic.java851 SegmentInfos infos = new SegmentInfos();
852 infos.read(benchmark.getRunData().getDirectory());
853 assertEquals(3, infos.size());

Completed in 97 milliseconds