パッケージ org.codelibs.fess.suggest.index.contents.document

クラス ESSourceReader

  • すべての実装されたインタフェース:
    java.io.Closeable, java.lang.AutoCloseable, DocumentReader
    public class ESSourceReader
extends java.lang.Object
implements DocumentReader

    • フィールドの詳細

      • queue

        protected final java.util.Queue<java.util.Map<java.lang.String,​java.lang.Object>> queue

      • isFinished

        protected final java.util.concurrent.atomic.AtomicBoolean isFinished

      • random

        protected final java.util.Random random

      • client

        protected final org.elasticsearch.client.Client client

      • indexName

        protected final java.lang.String indexName

      • typeName

        protected final java.lang.String typeName

      • supportedFields

        protected final java.lang.String[] supportedFields

      • scrollSize

        protected int scrollSize

      • maxRetryCount

        protected int maxRetryCount

      • limitOfDocumentSize

        protected long limitOfDocumentSize

      • queryBuilder

        protected org.elasticsearch.index.query.QueryBuilder queryBuilder

      • limitPercentage

        protected int limitPercentage

      • limitNumber

        protected long limitNumber

      • sortList

        protected java.util.List<org.elasticsearch.search.sort.SortBuilder<?>> sortList

      • scrollId

        protected java.lang.String scrollId

      • docCount

        protected final java.util.concurrent.atomic.AtomicLong docCount

      • totalDocNum

        protected final long totalDocNum

    • コンストラクタの詳細

      • ESSourceReader

        public ESSourceReader​(org.elasticsearch.client.Client client,
                      SuggestSettings settings,
                      java.lang.String indexName,
                      java.lang.String typeName)

    • メソッドの詳細

      • read

        public java.util.Map<java.lang.String,​java.lang.Object> read()
        定義:
        read インタフェース内 DocumentReader

      • close

        public void close()
        定義:
        close インタフェース内 java.lang.AutoCloseable
        定義:
        close インタフェース内 java.io.Closeable
        定義:
        close インタフェース内 DocumentReader

      • setScrollSize

        public void setScrollSize​(int scrollSize)

      • setLimitOfDocumentSize

        public void setLimitOfDocumentSize​(long limitOfDocumentSize)

      • setQuery

        public void setQuery​(org.elasticsearch.index.query.QueryBuilder queryBuilder)

      • addSort

        public void addSort​(org.elasticsearch.search.sort.SortBuilder<?> sortBuilder)

      • setLimitDocNumPercentage

        public void setLimitDocNumPercentage​(java.lang.String limitPercentage)

      • setLimitNumber

        public void setLimitNumber​(long limitNumber)

      • addDocumentToQueue

        protected void addDocumentToQueue()

      • getLimitDocNum

        protected static long getLimitDocNum​(long total,
                                     long limitPercentage,
                                     long limitNumber)

      • getTotal

        protected long getTotal()