String>>) propMap.get(CRAWLER_METADATA_NAME_MAPPING); L958: if (params == null) { L959: params = split(getCrawlerMetadataNameMapping(), "\n").get(stream -> stream.filter(StringUtil::isNotBlank).map(v -> { L960: final String[] values = v.split("="); L961: if (values.length == 2) { L962: final String[] subValues = values[1].split(":", 3); L963: if (subValues.length == 3) { L964: return new Tuple4<>(values[0],...

defineLocale("af",{months:"Januarie_Februarie_Maart_April_Mei_Junie_Julie_Augustus_September_Oktober_November_Desember".split("_"),monthsShort:"Jan_Feb_Mrt_Apr_Mei_Jun_Jul_Aug_Sep_Okt_Nov_Des".split("_"),weekdays:"Sondag_Maandag_Dinsdag_Woensdag_Donderdag_Vrydag_Saterdag".split("_"),weekdaysShort:"Son_Maa_Din_Woe_Don_Vry_Sat".split("_"),weekdaysMin:"So_Ma_Di_Wo_Do_Vr_Sa".split("_"),meridiemParse:/vm|nm/i,isPM:function(e){return/^nm$/i.test(e)},meridiem:function(e,a,t){return e<12?t?"vm":"VM":t?"...

leName()); L92: } L93: fessConfig = ComponentUtil.getFessConfig(); L94: split(fessConfig.getSuggestFieldContents(), ",") L95: .of(stream -> stream.filter(StringUtil::isNotBlank).forEach(contentFieldNameSet::add)); L96: split(fessConfig.getSuggestFieldTags(), ",").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(tagFieldNameSet::add)); L97: split(fessConfig.getSuggestFieldRoles(), ",").of(stream -> stream.filter(StringUtil::isNotBlank).f...

either express or implied. See the License for the specific language L14: * governing permissions and limitations under the License. L15: */ L16:package org.codelibs.fess.app.web.base.login; L17: L18:import static org.codelibs.core.stream.StreamUtil.split; L19:import static org.codelibs.core.stream.StreamUtil.stream; L20: L21:import java.util.HashSet; L22:import java.util.Map; L23:import java.util.Set; L24: L25:import org.codelibs.core.lang.StringUtil; L26:import org.codelibs.fess.entity.FessUser; L27:import...

fessConfig.getIndexFieldUrl(), // L254: fessConfig.getIndexFieldVersion())); L255: } L256: split(fessConfig.getQueryAdditionalAnalyzedFields(), ",") L257: .of(stream -> stream.map(String::trim).filter(StringUtil::isNotBlank).forEach(s -> notAnalyzedFieldSet.remove(s))); L258: split(fessConfig.getQueryAdditionalDefaultFields(), ",").of(stream -> stream.filter(StringUtil::isNotBlank).map(s -> { L259: final Pair<String,...

System.getProperty("java.version"); L50: int version = 8; L51: if (javaVersion != null) { L52: final String[] split = javaVersion.split("[\\._]"); L53: if (split.length > 0) { L54: version = Integer.parseInt(split[0]); L55: if (version == 1 && split.length > 1) { L56: version = Integer.parseInt(split[1]); L57: } L58: } L59: } L60: return version; L61: } L62:}...

protected Map<String, String> mimetypeMap = new LinkedHashMap<>(); L36: L37: @PostConstruct L38: public void init() { L39: StreamUtil.split(ComponentUtil.getFessConfig().getIndexFiletype(), "\n") L40: .of(stream -> stream.filter(StringUtil::isNotBlank).forEach(s -> { L41: final String[] values = StringUtils.split(s, "=", 2); L42: if (values.length == 2) { L43: mimetypeMap.put(values[0], values[1]); L44: ...

(StringUtil.isNotBlank(includedPaths)) { L248: final StringBuilder buf = new StringBuilder(100); L249: char split = 0; L250: for (final String path : includedPaths.split("\n")) { L251: if (split == 0) { L252: split = '|'; L253: } else { L254: buf.append(split); L255: } L256: final String normalizePath = systemHelper.normalizeConfigPath(path); L257:...

KIND, L13: * either express or implied. See the License for the specific language L14: * governing permissions and limitations under the License. L15: */ L16:package org.codelibs.fess.helper; L17: L18:import static org.codelibs.core.stream.StreamUtil.split; L19: L20:import java.util.ArrayList; L21:import java.util.Collections; L22:import java.util.List; L23:import java.util.Map; L24:import java.util.concurrent.atomic.AtomicBoolean; L25:import java.util.regex.Pattern; L26: L27:import org.apache.loggi...

final String slackWebhookUrls = fessConfig.getSlackWebhookUrls(); L46: if (StringUtil.isBlank(slackWebhookUrls)) { L47: return; L48: } L49: final String body = toSlackMessage(discloser); L50: StreamUtil.split(slackWebhookUrls, "[,\\s]").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(url -> { L51: try (CurlResponse response = Curl.post(url).header("Content-Type", "application/json").body(body).execute()) { L52: if (...