- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 77 for ekvs (0.04 sec)
-
internal/s3select/json/preader.go
// order) kvs = mv.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: mv.Value}} } all = append(all, kvs) } // We don't need the input any more.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 6.5K bytes - Viewed (0) -
internal/s3select/json/record.go
func (r *Record) Clone(dst sql.Record) sql.Record { other, ok := dst.(*Record) if !ok { other = &Record{} } if len(other.KVS) > 0 { other.KVS = other.KVS[:0] } other.KVS = append(other.KVS, r.KVS...) return other } // Set - sets the value for a column name. func (r *Record) Set(name string, value *sql.Value) (sql.Record, error) { var v interface{}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 5.3K 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}} }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 3.2K bytes - Viewed (0) -
internal/config/browser/browser.go
return cfg, err } hstsIncludeSubdomains := env.Get(EnvBrowserHSTSIncludeSubdomains, kvs.GetWithDefault(browserHSTSIncludeSubdomains, DefaultKVS)) == config.EnableOn hstsPreload := env.Get(EnvBrowserHSTSPreload, kvs.Get(browserHSTSPreload)) == config.EnableOn hstsSeconds, err := strconv.Atoi(env.Get(EnvBrowserHSTSSeconds, kvs.GetWithDefault(browserHSTSSeconds, DefaultKVS)))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 00:58:58 UTC 2024 - 5.9K bytes - Viewed (0) -
internal/config/compress/compress.go
} } return includes, nil } // LookupConfig - lookup compression config. func LookupConfig(kvs config.KVS) (Config, error) { var err error cfg := Config{} if err = config.CheckValidKeys(config.CompressionSubSys, kvs, DefaultKVS); err != nil { return cfg, err } compress := env.Get(EnvCompressState, kvs.Get(config.Enable)) if compress == "" { compress = env.Get(EnvCompress, "") }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5K bytes - Viewed (0) -
internal/config/batch/batch.go
func LookupConfig(kvs config.KVS) (cfg Config, err error) { if err = config.CheckValidKeys(config.BatchSubSys, kvs, DefaultKVS); err != nil { return cfg, err } cfg.ReplicationWorkersWait = 0 cfg.KeyRotationWorkersWait = 0 cfg.ExpirationWorkersWait = 0 rduration, err := time.ParseDuration(env.Get(EnvReplicationWorkersWait, kvs.GetWithDefault(ReplicationWorkersWait, DefaultKVS)))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.7K bytes - Viewed (0) -
internal/config/heal/heal.go
} // LookupConfig - lookup config and override with valid environment settings if any. func LookupConfig(kvs config.KVS) (cfg Config, err error) { if err = config.CheckValidKeys(config.HealSubSys, kvs, DefaultKVS); err != nil { return cfg, err } bitrot := env.Get(EnvBitrot, kvs.GetWithDefault(Bitrot, DefaultKVS)) if _, err = parseBitrotConfig(bitrot); err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.9K bytes - Viewed (0) -
internal/config/identity/tls/config.go
return 0, auth.ErrInvalidDuration } return dur, nil } // Lookup returns a new Config by merging the given K/V config // system with environment variables. func Lookup(kvs config.KVS) (Config, error) { if err := config.CheckValidKeys(config.IdentityTLSSubSys, kvs, DefaultKVS); err != nil { return Config{}, err } cfg := Config{} var err error v := env.Get(EnvIdentityTLSEnabled, "") if v == "" { return cfg, nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 3.6K bytes - Viewed (0) -
ci/official/envs/linux_x86_build
# limitations under the License. # ============================================================================== # Temporary envs file while we migrate to the new docker image. # Once the migration is complete, this file will be removed. source ci/official/envs/linux_x86 TFCI_DOCKER_IMAGE=us-central1-docker.pkg.dev/tensorflow-sigs/tensorflow/ml-build:latest
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Mon Oct 28 17:57:41 UTC 2024 - 1011 bytes - Viewed (0) -
ci/official/envs/linux_x86_cuda_build
# limitations under the License. # ============================================================================== # Temporary envs file while we migrate to the new docker image. # Once the migration is complete, this file will be removed. source ci/official/envs/linux_x86_build TFCI_BAZEL_COMMON_ARGS="--repo_env=HERMETIC_PYTHON_VERSION=$TFCI_PYTHON_VERSION --config release_gpu_linux"
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Mon Oct 28 17:57:41 UTC 2024 - 1.1K bytes - Viewed (0)