- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 595 for iostream (0.25 sec)
-
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.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 14 13:54:47 GMT 2022 - 4.5K bytes - Viewed (0) -
istioctl/pkg/writer/compare/testdata/configdump.json
...
Json - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Mar 12 10:02:09 GMT 2024 - 52K bytes - Viewed (0) -
.github/workflows/mint/nginx.conf
sendfile on; keepalive_timeout 65; # include /etc/nginx/conf.d/*.conf; upstream minio { server minio1:9000; server minio2:9000; server minio3:9000; server minio4:9000; } upstream console { ip_hash; server minio1:9001; server minio2:9001; server minio3:9001; server minio4:9001;
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Mar 31 21:38:10 GMT 2023 - 3K bytes - Viewed (0) -
internal/s3select/sql/jsonpath_test.go
"io" "os" "path/filepath" "reflect" "testing" "github.com/alecthomas/participle" "github.com/bcicen/jstream" ) func getJSONStructs(b []byte) ([]interface{}, error) { dec := jstream.NewDecoder(bytes.NewBuffer(b), 0).ObjectAsKVS() var result []interface{} for parsedVal := range dec.Stream() { result = append(result, parsedVal.Value) } if err := dec.Err(); err != nil { return nil, err }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 2.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/dict/protwords/ApiAdminDictProtwordsAction.java
body.dictId = dictId; validateApi(body, messages -> {}); return protwordsService.getProtwordsFile(body.dictId) .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> { file.writeOut(out); })).orElseGet(() -> {
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 7.2K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/OsddHelperTest.java
osddHelper.setContentType("application/opensearchdescription+xml"); osddHelper.init(); assertFalse(osddHelper.hasOpenSearchFile()); try { osddHelper.asStream(); fail(); } catch (final Exception e) { assertEquals("Unsupported Open Search Description Document response.", e.getMessage()); } }
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/thumbnail/ThumbnailAction.java
} // 404 throw responseManager.new404("Thumbnail for " + form.docId + " is under generating."); } return asStream(form.docId).contentType(getImageMimeType(thumbnailFile)).stream(out -> { try (BufferedInputStream in = new BufferedInputStream(new FileInputStream(thumbnailFile))) { out.write(in); } }); }
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 3.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/dict/stopwords/ApiAdminDictStopwordsAction.java
body.dictId = dictId; validateApi(body, messages -> {}); return stopwordsService.getStopwordsFile(body.dictId) .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> { file.writeOut(out); })).orElseGet(() -> {
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 7.2K bytes - Viewed (0) -
.github/workflows/multipart/nginx-site2.conf
sendfile on; keepalive_timeout 65; # include /etc/nginx/conf.d/*.conf; upstream minio { server site2-minio1:9000; server site2-minio2:9000; server site2-minio3:9000; server site2-minio4:9000; } server { listen 9002; listen [::]:9002; server_name localhost;
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Sep 30 10:13:56 GMT 2023 - 1.7K bytes - Viewed (0) -
buildscripts/upgrade-tests/nginx.conf
sendfile on; #tcp_nopush on; keepalive_timeout 65; #gzip on; # include /etc/nginx/conf.d/*.conf; upstream minio { server minio1:9000; server minio2:9000; server minio3:9000; server minio4:9000; } # main minio server { listen 9000; listen [::]:9000;
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Nov 21 18:41:30 GMT 2021 - 1.7K bytes - Viewed (0)