RuleManager ruleManager = SingletonLaContainer.getComponent(RuleManager.class); L199: final Rule rule = ruleManager.getRule(responseData); L200: if (rule == null) { L201: throw new CrawlingAccessException("No url rule for " + url); L202: } L203: responseData.setRuleId(rule.getRuleId()); L204: final ResponseProcessor responseProcessor = rule.getResponseProcessor(); L205: if (!(responseProcessor instanceof DefaultResponseProcessor))...

int h = cal.get(Calendar.HOUR_OF_DAY); L53: final int m = cal.get(Calendar.MINUTE); L54: final int d = cal.get(Calendar.DAY_OF_WEEK); // SUN(1) - SAT(7) L55: for (final IntervalRule rule : ruleList) { L56: if (rule.isTarget(h, m, d)) { L57: return rule.getDelay(); L58: } L59: } L60: return 0; L61: } L62: L63: protected Calendar getCurrentCal() { L64: final Calendar cal = Calendar.getInstance(); L65: cal.se...

RuleManager ruleManager = SingletonLaContainer.getComponent(RuleManager.class); L232: final Rule rule = ruleManager.getRule(responseData); L233: if (rule == null) { L234: logger.warn("No url rule. Data: {}", dataMap); L235: } else { L236: responseData.setRuleId(rule.getRuleId()); L237: final ResponseProcessor responseProcessor = rule.getResponseProcessor(); L238: if (responseProcessor instanceof DefaultResponseProcessor)...

L6892: L6893: public void setRoles_Equal(String roles) { L6894: setRoles_Term(roles, null); L6895: } L6896: L6897: public void setRoles_Equal(String roles, ConditionOptionCall<TermQueryBuilder> opLambda) { L6898: setRoles_Term(roles, opLambda); L6899: } L6900: L6901: public void setRoles_Term(String roles) { L6902: setRoles_Term(roles, null); L6903: } L6904: L6905: public void setRoles_Term(String roles, ConditionOptionCall<TermQueryBuilder> opLambda) { L6906:...

private boolean existNextPage; L38: L39: private List<Integer> pageNumberList; L40: L41: private int pageSize; L42: L43: private int currentPageNumber; L44: L45: public String id; L46: L47: public String name; L48: L49: public String[] roles; L50: L51: public String[] groups; L52: L53: public String versionNo; L54: L55: public void clear() { L56: allRecordCount = 0; L57: allPageCount = 0; L58: existPrePage = false; L59: existNextPage = false; L60: ...

L89: "type" : "keyword" L90: }, L91: "preferredLanguage" : { L92: "type" : "keyword" L93: }, L94: "registeredAddress" : { L95: "type" : "keyword" L96: }, L97: "roles" : { L98: "type" : "keyword" L99: }, L100: "roomNumber" : { L101: "type" : "keyword" L102: }, L103: "state" : { L104: "type" : "keyword" L105: }, L106: "street"...

L2140: } L2141: L2142: public void setRoles_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda) { L2143: setRoles_Terms("roles", opLambda, null); L2144: } L2145: L2146: public void setRoles_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda, OperatorCall<BsSearchLogCA> aggsLambda) { L2147: setRoles_Terms("roles", opLambda, aggsLambda); L2148: } L2149: L2150: public void setRoles_Terms(String name, ConditionOptionCall<TermsAggregationBuilder> opLambda,...

test methods in this class that create a set with L237: * a "hole" in it so that set tests of {@code ContiguousSet} can suppress them with {@code L238: * FeatureSpecificTestSuiteBuilder.suppressing()}. L239: */ L240: /* L241: * TODO(cpovirk): or we could make HOLES_FORBIDDEN a feature. Or we could declare that L242: * implementations are permitted to throw IAE if a hole is requested, and we could update L243: * test*Hole to permit IAE. (But might this ignore genuine bugs?) But see the...

work on OSX and zsh L3115: - Add best-effort eviction for DaemonSet pods while scaling down non-empty nodes L3116: - Add build support for ARM64 L3117: L3118: ### AliCloud L3119: - Add missing daemonsets and replicasets to ALI example cluster role L3120: L3121: ### Apache CloudStack L3122: - Add support for Apache CloudStack L3123: L3124: ### AWS L3125: - Regenerate list of EC2 instances L3126: - Fix pricing endpoint in AWS China Region L3127: L3128: ### Azure L3129: - Add optional...

queue[minChildIndex] = x; L720: return minChildIndex; L721: } L722: return crossOverUp(index, x); L723: } L724: L725: /** L726: * Fills the hole at {@code index} by moving in the least of its grandchildren to this position, L727: * then recursively filling the new hole created. L728: * L729: * @return the position of the new hole (where the lowest grandchild moved from, that had no L730: * grandchild to replace it) L731: */ L732: int fillHoleAt(int index) { L733:...