Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 779 for asStream (0.12 sec)

  1. src/main/java/org/codelibs/fess/helper/VirtualHostHelper.java

                    }
                }
                return defaultValue;
            }).orElse(defaultValue);
        }
    
        public String[] getVirtualHostPaths() {
            return stream(ComponentUtil.getFessConfig().getVirtualHosts())
                    .get(stream -> stream.map(h -> "/" + h.getValue3()).toArray(n -> new String[n]));
        }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  2. impl/maven-core/src/main/java/org/apache/maven/lifecycle/Lifecycle.java

     * under the License.
     */
    package org.apache.maven.lifecycle;
    
    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.apache.maven.lifecycle.mapping.LifecyclePhase;
    
    import static org.apache.maven.api.Lifecycle.AFTER;
    import static org.apache.maven.api.Lifecycle.BEFORE;
    
    /**
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  3. compat/maven-repository-metadata/src/main/java/org/apache/maven/artifact/repository/metadata/io/xpp3/MetadataXpp3Writer.java

            }
        }
    
        /**
         * Method write.
         *
         * @param stream a stream object
         * @param metadata a Metadata object
         * @throws java.io.IOException java.io.IOException if any
         */
        public void write(OutputStream stream, Metadata metadata) throws java.io.IOException {
            try {
                delegate.write(stream, metadata.getDelegate());
            } catch (XMLStreamException e) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/rank/fusion/DefaultSearcher.java

                                    }
                                    docMap.put(fessConfig.getQueryCollapseInnerHitsName(), StreamUtil.stream(innerSearchHits.getHits())
                                            .get(stream -> stream.map(v -> parseSearchHit(fessConfig, hlPrefix, v)).toArray(n -> new Map[n])));
                                }
                            }
                        }
                    }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Jul 22 06:56:21 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java

                    }
                }
    
                final DuplicateHostHelper duplicateHostHelper = ComponentUtil.getDuplicateHostHelper();
    
                // set urls
                split(urlsStr, "[\r\n]").of(stream -> stream.filter(StringUtil::isNotBlank).map(String::trim).distinct().forEach(urlValue -> {
                    if (!urlValue.startsWith("#") && protocolHelper.isValidWebProtocol(urlValue)) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 22.6K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/io/CharSink.java

    import java.io.Reader;
    import java.io.Writer;
    import java.nio.charset.Charset;
    import java.util.Iterator;
    import java.util.stream.Stream;
    
    /**
     * A destination to which characters can be written, such as a text file. Unlike a {@link Writer}, a
     * {@code CharSink} is not an open, stateful stream that can be written to and closed. Instead, it
     * is an immutable <i>supplier</i> of {@code Writer} instances.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/es/client/CrawlerEngineClient.java

        @Override
        protected Client createClient() {
            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            final String[] hosts =
                    split(address, ",").get(stream -> stream.map(String::trim).filter(StringUtil::isNotEmpty).toArray(n -> new String[n]));
            final Builder builder = Settings.builder().putList("http.hosts", hosts).put("processors", fessConfig.getCrawlerHttpProcessors())
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  8. guava/src/com/google/common/collect/ImmutableListMultimap.java

      private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        Serialization.writeMultimap(this, stream);
      }
    
      @GwtIncompatible // java.io.ObjectInputStream
      @J2ktIncompatible
      private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
        stream.defaultReadObject();
        int keyCount = stream.readInt();
        if (keyCount < 0) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 16 20:20:32 UTC 2024
    - 19K bytes
    - Viewed (0)
  9. impl/maven-core/src/main/java/org/apache/maven/ReactorReader.java

            }
        }
    
        /**
         * Retrieve a stream of the project's artifacts
         */
        private Stream<Artifact> getProjectArtifacts(MavenProject project) {
            Stream<org.apache.maven.artifact.Artifact> artifacts = Stream.concat(
                    Stream.concat(
                            // pom artifact
                            Stream.of(new ProjectArtifact(project)),
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  10. internal/s3select/parquet/reader.go

    		}
    		return nil, errParquetParsingError(err)
    	}
    
    	kvs := jstream.KVS{}
    	for _, col := range pr.r.Columns() {
    
    		var value interface{}
    		if v, ok := nextRow[col.FlatName()]; ok {
    			value, err = convertFromAnnotation(col.Element(), v)
    			if err != nil {
    				return nil, errParquetParsingError(err)
    			}
    		}
    		kvs = append(kvs, jstream.KV{Key: col.FlatName(), Value: value})
    	}
    
    	// Reuse destination if we can.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.5K bytes
    - Viewed (0)
Back to top