Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 375 for jstream (0.12 sec)

  1. src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java

                        } else {
                            ignoreFields = new String[] { Constants.INDEXING_TARGET, Constants.SESSION_ID };
                        }
                        stream(ignoreFields).of(stream -> stream.map(String::trim).forEach(s -> dataMap.remove(s)));
    
                        indexUpdateCallback.store(paramMap, dataMap);
                        crawlerStatsHelper.record(keyObj, StatsAction.PROCESSED);
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/timer/HotThreadMonitorTarget.java

     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.timer;
    
    import java.util.stream.Collectors;
    
    import org.apache.commons.text.StringEscapeUtils;
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.Constants;
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/entity/QueryContext.java

        public void setQueryBuilder(final QueryBuilder queryBuilder) {
            this.queryBuilder = queryBuilder;
        }
    
        public void addSorts(final SortBuilder<?>... sortBuilders) {
            stream(sortBuilders).of(stream -> stream.forEach(sortBuilder -> sortBuilderList.add(sortBuilder)));
        }
    
        public boolean hasSorts() {
            return !sortBuilderList.isEmpty();
        }
    
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/crawler/transformer/AbstractFessFileTransformer.java

            stream(crawlingConfig.getPermissions()).of(stream -> stream.forEach(p -> roleTypeList.add(p)));
            putResultDataBody(dataMap, fessConfig.getIndexFieldRole(), roleTypeList);
            // virtualHosts
            putResultDataBody(dataMap, fessConfig.getIndexFieldVirtualHost(),
                    stream(crawlingConfig.getVirtualHosts()).get(stream -> stream.filter(StringUtil::isNotBlank).collect(Collectors.toList())));
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/job/PythonJob.java

            return this;
        }
    
        public PythonJob arg(final String value) {
            argList.add(value);
            return this;
        }
    
        public PythonJob args(final String... values) {
            stream(values).of(stream -> stream.forEach(argList::add));
            return this;
        }
    
        @Override
        public String execute() {
            final StringBuilder resultBuf = new StringBuilder();
    
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/helper/SystemHelper.java

            return designJspFileNameMap.entrySet().stream().map(e -> new Pair<>(e.getKey(), e.getValue())).toArray(n -> new Pair[n]);
        }
    
        public List<Path> refreshDesignJspFiles() {
            final List<Path> fileList = new ArrayList<>();
            stream(ComponentUtil.getVirtualHostHelper().getVirtualHostPaths())
                    .of(stream -> stream.filter(s -> s != null && !"/".equals(s)).forEach(key -> {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Oct 17 12:10:08 UTC 2024
    - 27.2K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/crawler/transformer/FessXpathTransformer.java

            stream(crawlingConfig.getPermissions()).of(stream -> stream.forEach(p -> roleTypeList.add(p)));
            putResultDataBody(dataMap, fessConfig.getIndexFieldRole(), roleTypeList);
            // virtualHosts
            putResultDataBody(dataMap, fessConfig.getIndexFieldVirtualHost(),
                    stream(crawlingConfig.getVirtualHosts()).get(stream -> stream.filter(StringUtil::isNotBlank).collect(Collectors.toList())));
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Oct 24 13:01:38 UTC 2024
    - 42.9K bytes
    - Viewed (0)
  8. cmd/metacache-set.go

    // io.ErrUnexpectedEOF is returned if the place containing the marker hasn't been scanned yet.
    // io.EOF indicates the marker is beyond the end of the stream and does not exist.
    func (o *listPathOptions) findFirstPart(fi FileInfo) (int, error) {
    	search := o.Marker
    	if search == "" {
    		search = o.Prefix
    	}
    	if search == "" {
    		return 0, nil
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/helper/QueryHelper.java

        }
    
        public void addDefaultSort(final String fieldName, final String order) {
            final List<SortBuilder<?>> list = new ArrayList<>();
            if (defaultSortBuilders != null) {
                stream(defaultSortBuilders).of(stream -> stream.forEach(builder -> list.add(builder)));
            }
            list.add(createFieldSortBuilder(fieldName, SortOrder.DESC.toString().equalsIgnoreCase(order) ? SortOrder.DESC : SortOrder.ASC));
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/entity/FacetInfo.java

            if (StringUtil.isNotBlank(fessConfig.getQueryFacetFields())) {
                field = StreamUtil.split(fessConfig.getQueryFacetFields(), ",")
                        .get(stream -> stream.map(String::trim).filter(StringUtil::isNotEmpty).distinct().toArray(n -> new String[n]));
            }
            if (StringUtil.isNotBlank(fessConfig.getQueryFacetFieldsSize())) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 3.6K bytes
    - Viewed (0)
Back to top