- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 62 for jetstream (5.99 sec)
-
internal/s3select/json/preader.go
continue } dst, ok := r.kvDstPool.Get().([]jstream.KVS) if !ok { dst = make([]jstream.KVS, 0, 1000) } d := jstream.NewDecoder(bytes.NewBuffer(in.input), 0).ObjectAsKVS() 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
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 6.4K bytes - Viewed (0) -
.cm/summary_table.cm
# Total number of files changed total: {{ branch.diff.files_metadata | length }} is: requested: {{ (pr.comments | match(attr='content', term='@bot-gitstream check all') | some) or (pr.comments | match(attr='content', term='@bot-gitstream check summary') | some) }} author: using_gitstream: {{ (pr.author | isEnabledUser ) }}
Plain Text - Registered: Wed Apr 17 11:36:08 GMT 2024 - Last Modified: Thu Feb 08 15:20:44 GMT 2024 - 6.5K bytes - Viewed (0) -
build-logic-commons/basics/src/test/kotlin/gradlebuild/basics/tasks/PackageListGeneratorIntegrationTest.kt
val entryName = dir.relativize(file).joinToString(separator = "/") { it.toString() } jarStream.putNextEntry(JarEntry(entryName)) Files.copy(file, jarStream) jarStream.closeEntry() return FileVisitResult.CONTINUE } }) }
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Sat Sep 30 16:17:28 GMT 2023 - 4.8K bytes - Viewed (0) -
internal/s3select/json/reader.go
} return nil, io.EOF } var kvs jstream.KVS if v.ValueType == jstream.Object { // This is a JSON object type (that preserves key // order) kvs = v.Value.(jstream.KVS) } else { // To be AWS S3 compatible Select for JSON needs to // output non-object JSON as single column value // i.e. a map with `_1` as key and value as the // non-object. kvs = jstream.KVS{jstream.KV{Key: "_1", Value: v.Value}} }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 24 03:58:53 GMT 2022 - 3K bytes - Viewed (0) -
.cm/plugins/filters/isEnabledAutomation/index.js
* </ul> * * or * * <ul> * <li>Someone has commented `@bot-gitstream run <NAME_OF_AUTOMATION>` (the file name, without the `.cm` suffix) on the PR.</li> * </ul> * * @param {string} automationName - The automation name (*.cm file name containing the automation) to check. * @param {Map} pr - The gitStream PR instance to check (includes metadata related to the pull request).
JavaScript - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Fri Apr 12 13:42:16 GMT 2024 - 3.1K bytes - Viewed (0) -
internal/s3select/sql/jsonpath.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package sql import ( "errors" "github.com/bcicen/jstream" "github.com/minio/simdjson-go" ) var ( errKeyLookup = errors.New("Cannot look up key in non-object value") errIndexLookup = errors.New("Cannot look up array index in non-array value")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 3.4K bytes - Viewed (0) -
.cm/plugins/filters/byCodeowner/index.js
/** * @module byCodeowner * @description Groups the PR's files' by owner based on the CODEOWNERs file. * @param {string[]} files - the gitStream's files context variable * @param {Object} pr - the gitStream's pr context variable * @param {string} token - access token with repo:read scope, used to read the CODEOWNERS file * @param {string} pathToCodeOwners - path from repo root to CODEOWNERS file * @returns {Map} - Map from owner name to list of files they own
JavaScript - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Mon Apr 22 19:12:32 GMT 2024 - 2.8K bytes - Viewed (0) -
internal/grid/grid_test.go
t.Fatalf("Unexpected error: %v, %T", err, err) } // Streams should not be able to set up until registered. // Thus, the error is a local error. _, err = remoteConn.NewStream(context.Background(), handlerTest, []byte(testPayload)) if !errors.Is(err, ErrUnknownHandler) { t.Fatalf("Unexpected error: %v, %T", err, err) } }) } func TestSingleRoundtripGenerics(t *testing.T) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K 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.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 14 13:54:47 GMT 2022 - 4.5K bytes - Viewed (0) -
.cm/plugins/filters/isEnabledUser/index.js
const jvm = ["big-guy", "ghale", "jvandort", "octylFractal", "tresat"]; /** * @module isEnabledUser * @description Returns true if the username that is passed to this function is a member of the Gradle BT Team who has opted into gitStream automations. * @param {string} Input - The GitHub username to check. * @returns {boolean} Returns true if the user is specified in any of the lists of Gradle BT team members above, otherwise false.
JavaScript - Registered: Wed Apr 17 11:36:08 GMT 2024 - Last Modified: Mon Feb 05 22:00:34 GMT 2024 - 923 bytes - Viewed (0)