- Sort Score
- Result 10 results
- Languages All
Results 501 - 510 of 835 for streams (0.08 sec)
-
internal/s3select/csv/record.go
w.Flush() return w.Error() } // WriteJSON - encodes to JSON data. func (r *Record) WriteJSON(writer io.Writer) error { var kvs jstream.KVS = make([]jstream.KV, 0, len(r.columnNames)) for i, cn := range r.columnNames { if i < len(r.csvRecord) { kvs = append(kvs, jstream.KV{Key: cn, Value: r.csvRecord[i]}) } } return json.NewEncoder(writer).Encode(kvs) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 4.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java
stats.put("fs", getFsObj()); return asJson(new ApiStatsResponse().stats(stats).status(ApiResult.Status.OK).result()); } private FsObj[] getFsObj() { return Arrays.stream(File.listRoots()).map(f -> { final FsObj fsObj = new FsObj(); fsObj.path = f.getAbsolutePath(); fsObj.free = f.getFreeSpace(); fsObj.total = f.getTotalSpace();
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 12.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/reqheader/ApiAdminReqheaderAction.java
*/ package org.codelibs.fess.app.web.api.admin.reqheader; import static org.codelibs.fess.app.web.admin.reqheader.AdminReqheaderAction.getRequestHeader; import java.util.List; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.app.pager.ReqHeaderPager; import org.codelibs.fess.app.service.RequestHeaderService;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 6.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/webauth/ApiAdminWebauthAction.java
*/ package org.codelibs.fess.app.web.api.admin.webauth; import static org.codelibs.fess.app.web.admin.webauth.AdminWebauthAction.getWebAuthentication; import java.util.List; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.app.pager.WebAuthPager; import org.codelibs.fess.app.service.WebAuthenticationService;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 6.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/TreeMultiset.java
private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(elementSet().comparator()); Serialization.writeMultiset(this, stream); } @J2ktIncompatible @GwtIncompatible // java.io.ObjectInputStream private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException { stream.defaultReadObject();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 20:24:49 UTC 2024 - 34.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/TestCharSink.java
} @Override public boolean wasStreamClosed() { return byteSink.wasStreamClosed(); } @Override public Writer openStream() throws IOException { // using TestByteSink's output stream to get option behavior, so flush to it on every write return new FilterWriter(new OutputStreamWriter(byteSink.openStream(), UTF_8)) { @Override public void write(int c) throws IOException { super.write(c);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jul 23 14:22:54 UTC 2024 - 2K bytes - Viewed (0) -
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) -
internal/s3select/csv/args.go
args.QuoteEscapeCharacter = defaultQuoteEscapeCharacter args.CommentCharacter = defaultCommentCharacter args.AllowQuotedRecordDelimiter = false for { // Read tokens from the XML document in a stream. t, err := d.Token() if err != nil { if err == io.EOF { break } return err } if se, ok := t.(xml.StartElement); ok { tagName := se.Name.Local switch tagName {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 20 18:31:45 UTC 2024 - 5.7K bytes - Viewed (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/props/MavenProperties.java
saveLayout(writer, typed); } /** * Store a properties into a output stream, preserving comments, special character, etc. * This method is mainly to be compatible with the java.util.Properties class. * * @param os an output stream. * @param comment this parameter is ignored as this Properties * @throws IOException If storing fails */
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 38.2K bytes - Viewed (0) -
guava/src/com/google/common/collect/TreeMultiset.java
private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(elementSet().comparator()); Serialization.writeMultiset(this, stream); } @J2ktIncompatible @GwtIncompatible // java.io.ObjectInputStream private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException { stream.defaultReadObject();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 20:24:49 UTC 2024 - 34.5K bytes - Viewed (0)