- Sort Score
- Result 10 results
- Languages All
Results 301 - 310 of 796 for Stream$ (0.06 sec)
-
src/main/java/org/codelibs/fess/app/web/api/admin/documents/ApiAdminDocumentsAction.java
final CrawlingInfoHelper crawlingInfoHelper = ComponentUtil.getCrawlingInfoHelper(); final LanguageHelper languageHelper = ComponentUtil.getLanguageHelper(); final List<Map<String, Object>> docList = body.documents.stream().map(doc -> { if (!doc.containsKey(indexFieldContentLength)) { long contentLength = 0; if (doc.get(indexFieldTitle) instanceof final String title) {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Jul 25 01:48:41 UTC 2024 - 7.5K bytes - Viewed (0) -
guava/src/com/google/common/collect/AbstractBiMap.java
@J2ktIncompatible private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(inverse()); } @GwtIncompatible // java.io.ObjectInputStream @J2ktIncompatible @SuppressWarnings("unchecked") // reading data stored by writeObject private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Aug 24 01:40:03 UTC 2023 - 14.6K bytes - Viewed (0) -
android/guava/src/com/google/common/math/StatsAccumulator.java
import static java.lang.Double.isNaN; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import java.util.Iterator; import java.util.stream.DoubleStream; import java.util.stream.IntStream; import java.util.stream.LongStream; /** * A mutable object which accumulates double values and tracks some basic statistics over all the
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 23 16:45:30 UTC 2024 - 15.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/FessApiAction.java
* either express or implied. See the License for the specific language * governing permissions and limitations under the License. */ package org.codelibs.fess.app.web.api; import java.util.Locale; import java.util.stream.Collectors; import org.codelibs.fess.app.service.AccessTokenService; import org.codelibs.fess.app.web.api.ApiResult.ApiErrorResponse; import org.codelibs.fess.app.web.api.ApiResult.Status;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 2.5K bytes - Viewed (0) -
internal/s3select/json/preader.go
if !ok { dst = make([]jstream.KVS, 0, 1000) } d := jstream.NewDecoder(bytes.NewBuffer(in.input), 0).ObjectAsKVS().MaxDepth(100) stream := d.Stream() all := dst[:0] for mv := range stream { var kvs jstream.KVS if mv.ValueType == jstream.Object { // This is a JSON object type (that preserves key // order) kvs = mv.Value.(jstream.KVS)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 6.5K bytes - Viewed (0) -
cmd/bitrot-streaming.go
"io" "sync" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/ringbuffer" ) // Calculates bitrot in chunks and writes the hash into the stream. type streamingBitrotWriter struct { iow io.WriteCloser closeWithErr func(err error) h hash.Hash shardSize int64 canClose *sync.WaitGroup byteBuf []byte }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 21 12:20:54 UTC 2024 - 6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/KeyMatchHelper.java
getAvailableKeyMatchList().stream().forEach(keyMatch -> { try { final BoolQueryBuilder boolQuery = QueryBuilders.boolQuery(); if (logger.isDebugEnabled()) { logger.debug("Loading KeyMatch Query: {}, Size: {}", keyMatch.getQuery(), keyMatch.getMaxSize()); } getDocumentList(keyMatch).stream().map(doc -> {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 8.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/dict/mapping/ApiAdminDictMappingAction.java
import static org.codelibs.fess.app.web.admin.dict.mapping.AdminDictMappingAction.createCharMappingItem; import java.io.File; import java.io.IOException; import java.io.InputStream; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.app.pager.CharMappingPager; import org.codelibs.fess.app.service.CharMappingService;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 7.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/dict/stemmeroverride/ApiAdminDictStemmeroverrideAction.java
import static org.codelibs.fess.app.web.admin.dict.stemmeroverride.AdminDictStemmeroverrideAction.createStemmerOverrideItem; import java.io.File; import java.io.IOException; import java.io.InputStream; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.app.pager.StemmerOverridePager; import org.codelibs.fess.app.service.StemmerOverrideService;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 7.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/entity/FacetQueryView.java
@PostConstruct public void init() { final String filetypeField = ComponentUtil.getFessConfig().getIndexFieldFiletype(); final Collection<String> values = queryMap.values(); if (values.stream().anyMatch(s -> s.startsWith(filetypeField))) { final ResourceBundle resources = ResourceBundle.getBundle("fess_label", Locale.ENGLISH); final String[] fileTypes = ComponentUtil.getFileTypeHelper().getTypes();
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 3K bytes - Viewed (0)