SegmentTermPositions.cs
上传用户:zhangkuixh
上传日期:2013-09-30
资源大小:5473k
文件大小:2k
源码类别:

搜索引擎

开发平台:

C#

  1. /*
  2.  * Copyright 2004 The Apache Software Foundation
  3.  * 
  4.  * Licensed under the Apache License, Version 2.0 (the "License");
  5.  * you may not use this file except in compliance with the License.
  6.  * You may obtain a copy of the License at
  7.  * 
  8.  * http://www.apache.org/licenses/LICENSE-2.0
  9.  * 
  10.  * Unless required by applicable law or agreed to in writing, software
  11.  * distributed under the License is distributed on an "AS IS" BASIS,
  12.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13.  * See the License for the specific language governing permissions and
  14.  * limitations under the License.
  15.  */
  16. using System;
  17. using IndexInput = Lucene.Net.Store.IndexInput;
  18. namespace Lucene.Net.Index
  19. {
  20. sealed class SegmentTermPositions : SegmentTermDocs, TermPositions
  21. {
  22. private IndexInput proxStream;
  23. private int proxCount;
  24. private int position;
  25. internal SegmentTermPositions(SegmentReader p) : base(p)
  26. {
  27. this.proxStream = (IndexInput) parent.proxStream.Clone();
  28. }
  29. internal override void  Seek(TermInfo ti)
  30. {
  31. base.Seek(ti);
  32. if (ti != null)
  33. proxStream.Seek(ti.proxPointer);
  34. proxCount = 0;
  35. }
  36. public override void  Close()
  37. {
  38. base.Close();
  39. proxStream.Close();
  40. }
  41. public int NextPosition()
  42. {
  43. proxCount--;
  44. return position += proxStream.ReadVInt();
  45. }
  46. protected internal override void  SkippingDoc()
  47. {
  48. for (int f = freq; f > 0; f--)
  49. // skip all positions
  50. proxStream.ReadVInt();
  51. }
  52. public override bool Next()
  53. {
  54. for (int f = proxCount; f > 0; f--)
  55. // skip unread positions
  56. proxStream.ReadVInt();
  57. if (base.Next())
  58. {
  59. // run super
  60. proxCount = freq; // note frequency
  61. position = 0; // reset position
  62. return true;
  63. }
  64. return false;
  65. }
  66. public override int Read(int[] docs, int[] freqs)
  67. {
  68. throw new System.NotSupportedException("TermPositions does not support processing multiple documents in one call. Use TermDocs instead.");
  69. }
  70. /// <summary>Called by super.skipTo(). </summary>
  71. protected internal override void  SkipProx(long proxPointer)
  72. {
  73. proxStream.Seek(proxPointer);
  74. proxCount = 0;
  75. }
  76. }
  77. }