protected int defaultRowSize = 100; L46: L47: protected long requestInterval = 500; L48: L49: public void sendDocuments(final SearchEngineClient searchEngineClient, final DocList docList) { L50: if (docList.isEmpty()) { L51: return; L52: } L53: final FessConfig fessConfig = ComponentUtil.getFessConfig(); L54: final SystemHelper systemHelper = ComponentUtil.getSystemHelper(); L55: final long execTime = systemHelper.getCurrentTimeAsLong(); L56: ...

/** The value of current page number. */ L37: protected int currentPageNumber; L38: L39: protected long allRecordCount; L40: L41: protected String allRecordCountRelation; L42: L43: protected int allPageCount; L44: L45: protected boolean existNextPage; L46: L47: protected boolean existPrevPage; L48: L49: protected long currentStartRecordNumber; L50: L51: protected long currentEndRecordNumber; L52: L53: protected List<String> pageNumberList; L54: L55: protected String...

favoriteLogBhv; L86: L87: @Resource L88: protected SystemHelper systemHelper; L89: L90: @Resource L91: protected IndexingHelper indexingHelper; L92: L93: protected boolean finishCrawling = false; L94: L95: protected long executeTime; L96: L97: protected long documentSize; L98: L99: protected int maxIndexerErrorCount = 0; L100: L101: protected int maxErrorCount = 2; L102: L103: protected List<String> finishedSessionIdList = new ArrayList<>(); L104: L105: private final List<DocBoostMatcher>...

ry(ComponentUtil.getSearchEngineClient(), suggester.settings(), suggester.getIndex(), boolQueryBuilder); L271: } L272: L273: public long getAllWordsNum() { L274: return suggester.getAllWordsNum(); L275: } L276: L277: public long getDocumentWordsNum() { L278: return suggester.getDocumentWordsNum(); L279: } L280: L281: public long getQueryWordsNum() { L282: return suggester.getQueryWordsNum(); L283: } L284: L285: public boolean deleteAllWords() { L286: ...

class CommandGenerator extends BaseThumbnailGenerator { L40: private static final Logger logger = LogManager.getLogger(CommandGenerator.class); L41: L42: protected List<String> commandList; L43: L44: protected long commandTimeout = 30 * 1000L;// 30sec L45: L46: protected long commandDestroyTimeout = 5 * 1000L;// 5sec L47: L48: protected File baseDir; L49: L50: private Timer destoryTimer; L51: L52: @PostConstruct L53: public void init() { L54: if (logger.isDebugEnabled())...

protected int pageNumber; L159: protected long recordCount; L160: protected String recordCountRelation; L161: protected int pageCount; L162: protected boolean nextPage; L163: protected boolean prevPage; L164: protected long startRecordNumber; L165: protected long endRecordNumber; L166: protected List<String> pageNumbers; L167: protected boolean partial; L168: protected long queryTime; L169: protected String searchQuery;...

L28: protected volatile boolean crawlerRunning = true; L29: L30: protected long crawlerWaitMillis = 10000; L31: L32: protected List<IntervalRule> ruleList = new ArrayList<>(); L33: L34: public void checkCrawlerStatus() { L35: while (!crawlerRunning) { L36: ThreadUtil.sleepQuietly(crawlerWaitMillis); L37: } L38: } L39: L40: public void delayByRules() { L41: final long delay = getDelay(); L42: if (delay > 0) { L43: ThreadUtil.sleep(delay);...

boolean prevPage = data.isExistPrevPage(); L324: final long startRecordNumber = data.getCurrentStartRecordNumber(); L325: final long endRecordNumber = data.getCurrentEndRecordNumber(); L326: final List<String> pageNumbers = data.getPageNumberList(); L327: final boolean partial = data.isPartialResults(); L328: final String searchQuery = data.getSearchQuery(); L329: final long requestedTime = data.getRequestedTime(); L330: L331: ...

WebFsIndexHelper { L49: L50: private static final Logger logger = LogManager.getLogger(WebFsIndexHelper.class); L51: L52: private static final String DISABLE_URL_ENCODE = "#DISABLE_URL_ENCODE"; L53: L54: protected long maxAccessCount = Long.MAX_VALUE; L55: L56: protected long crawlingExecutionInterval = Constants.DEFAULT_CRAWLING_EXECUTION_INTERVAL; L57: L58: protected int indexUpdaterPriority = Thread.MAX_PRIORITY; L59: L60: protected int crawlerPriority = Thread.NORM_PRIORITY; L61:...

(bulkRequestBuilder.numberOfActions() > requestCacheSize) { L81: flush(); L82: } L83: return (long) ids.length; L84: }; L85: L86: public abstract long process(); L87: L88: protected void enable() { L89: final ScoreUpdater scoreUpdater = ComponentUtil.getComponent("scoreUpdater"); L90: scoreUpdater.addScoreBooster(this); L91: } L92: L93: protected long updateScore(final Map<String, Object> params) { L94: return requestHandler.apply(params); L95: }...