MCPcopy Create free account

hub / github.com/featureform/featureform / functions

Functions5,008 in github.com/featureform/featureform

⨍ Functions 5,008◇ Types & classes 913↳ Endpoints 59
↓ 2 callersMethodget_format
(cls, file_path: str, default: str = "")
client/src/featureform/enums.py:145
↓ 2 callersFunctionget_package_version
()
client/src/featureform/version.py:8
↓ 2 callersMethodget_postgres
Get a Postgres provider. The returned object can be used to register additional resources. **Examples**: ``` py postgres = ff
client/src/featureform/register.py:1800
↓ 2 callersFunctionget_postgres_redis_configs
(postgres_resource, redis_resource, is_local)
client/tests/test_updating_provider.py:226
↓ 2 callersMethodget_redis
Get a Redis provider. The returned object can be used to register additional resources. **Examples**: ``` py redis = ff.get_r
client/src/featureform/register.py:1676
↓ 2 callersMethodget_resources_by_type
( self, resource_type: str )
client/src/featureform/register.py:5328
↓ 2 callersFunctionget_s3_object
(file_path, credentials)
provider/scripts/spark/offline_store_spark_runner.py:554
↓ 2 callersMethodget_user
Get a user. Prints out name of user, and all resources associated with the user. **Examples:** ``` py title="Input" featuref
client/src/featureform/register.py:4181
↓ 2 callersMethodget_values
(cls)
client/src/featureform/enums.py:44
↓ 2 callersMethodgrpc_channel
(host="0.0.0.0", port=7462)
embeddinghub/sdk/python/embeddinghub.py:24
↓ 2 callersMethodhandleError
(err error)
health/health.go:49
↓ 2 callersFunctionhandleSearch
(searchArg = '')
dashboard/src/components/tasks/tableDataWrapper.js:48
↓ 2 callersMethodhas_value
(cls, value)
client/src/featureform/enums.py:36
↓ 2 callersMethodinRange
()
helpers/struct_iterator/struct_iterator.go:25
↓ 2 callersFunctioninit_feature
(input)
client/tests/resources_test.py:452
↓ 2 callersFunctioninit_label
(input)
client/tests/resources_test.py:497
↓ 2 callersFunctioninsecure_channel
(host)
client/src/featureform/tls.py:10
↓ 2 callersMethodisDefaultImage
isDefaultImage checks that the current image name (excluding the tag) is the same as the default image name config.PandasBaseImage. It also validates
provider/k8s.go:301
↓ 2 callersFunctionisDirectDependency
(lookup ResourceLookup, dependency, parent Resource)
metadata/metadata.go:201
↓ 2 callersMethodisPublic
()
helpers/struct_iterator/struct_iterator.go:48
↓ 2 callersMethodisTable
()
metadata/client.go:1828
↓ 2 callersFunctionisValidCassandraConfigUpdate
(sa, sb pc.SerializedConfig)
metadata/provider.go:21
↓ 2 callersFunctionisValidClickHouseConfigUpdate
(sa, sb pc.SerializedConfig)
metadata/provider.go:117
↓ 2 callersMethodisValidConfigUpdate
(configUpdate pc.SerializedConfig)
metadata/metadata.go:1330
↓ 2 callersFunctionisValidDynamoConfigUpdate
(sa, sb pc.SerializedConfig)
metadata/provider.go:37
↓ 2 callersFunctionisValidK8sConfigUpdate
(sa, sb pc.SerializedConfig)
metadata/provider.go:181
↓ 2 callersFunctionisValidMongoConfigUpdate
(sa, sb pc.SerializedConfig)
metadata/provider.go:69
↓ 2 callersFunctionisValidRedisConfigUpdate
(sa, sb pc.SerializedConfig)
metadata/provider.go:133
↓ 2 callersFunctionisValidRedshiftConfigUpdate
(sa, sb pc.SerializedConfig)
metadata/provider.go:165
↓ 2 callersFunctionisValidSnowflakeConfigUpdate
(sa, sb pc.SerializedConfig)
metadata/provider.go:149
↓ 2 callersFunctionisValidSparkConfigUpdate
(sa, sb pc.SerializedConfig)
metadata/provider.go:197
↓ 2 callersMethodis_finished
(self)
client/src/featureform/status_display.py:40
↓ 2 callersFunctionlabelShallowMap
(variant *metadata.LabelVariant)
metadata/dashboard/dashboard_metadata.go:235
↓ 2 callersFunctionlist
(client *Client, t ResourceType)
metadata/metadata_test.go:260
↓ 2 callersFunctionlist_name_status
(stub, resource_type)
client/src/featureform/list.py:24
↓ 2 callersFunctionlist_name_variant_status
(stub, resource_type)
client/src/featureform/list.py:58
↓ 2 callersFunctionlist_name_variant_status_desc
(stub, resource_type)
client/src/featureform/list.py:91
↓ 2 callersFunctionmain
Executes the Transformation Job: Parameters: args: (argparse.Namespace) arguments passed to the script Returns: outp
provider/scripts/k8s/offline_store_pandas_runner.py:211
↓ 2 callersFunctionmain
(args)
provider/scripts/spark/offline_store_spark_runner.py:255
↓ 2 callersMethodmaterialization
(id ResourceID, isUpdate bool)
provider/k8s.go:1326
↓ 2 callersMethodmaterializationDrop
(tableName string)
provider/sql.go:50
↓ 2 callersMethodmaterializationIterateSegment
(tableName string)
provider/sql.go:53
↓ 2 callersMethodmaterializationUpdate
(db *sql.DB, tableName string, sourceName string)
provider/sql.go:48
↓ 2 callersFunctionmaterializeFeatureWithProvider
(client *metadata.Client, offlineConfig pc.SerializedConfig, onlineConfig pc.SerializedConfig, featureName str
coordinator/coordinator_test.go:1028
↓ 2 callersFunctionmaterializeFeatureWithProvider
(featureName string, sourceName string, originalTableName string, schedule string)
coordinator/scheduletest/main.go:671
↓ 2 callersFunctionminutesToMilliseconds
(minutes)
dashboard/src/components/entitypage/elements/PrometheusGraph.js:13
↓ 2 callersMethodmonitorJob
(job *bigquery.Job)
provider/bigquery.go:398
↓ 2 callersMethodmultiget
Get multiple embeddings at once. Args: keys: An iterator of embedding indices for retrieval. Returns: A list
embeddinghub/sdk/python/offlinehub.py:87
↓ 2 callersFunctionnewJobSpec
(config KubernetesRunnerConfig, rsrcReqs v1.ResourceRequirements)
kubernetes/kubernetes.go:145
↓ 2 callersFunctionnewMultipleFileParquetIterator
(files []filestore.Filepath, store FileStore, limit int64)
provider/iterators.go:179
↓ 2 callersMethodnewSQLOfflineTable
(name string, columnType string)
provider/sql.go:54
↓ 2 callersMethodnumRows
(n interface{})
provider/sql.go:65
↓ 2 callersMethodnum_runs
(self)
embeddinghub/test/benchmark.py:21
↓ 2 callersMethodnum_runs
(self)
embeddinghub/test/benchmark.py:61
↓ 2 callersMethodnum_runs
(self)
embeddinghub/test/benchmark.py:136
↓ 2 callersMethodnum_runs
(self)
embeddinghub/test/benchmark.py:167
↓ 2 callersMethodnum_runs
(self)
embeddinghub/test/benchmark.py:206
↓ 2 callersMethodnum_runs
(self)
embeddinghub/test/benchmark.py:242
↓ 2 callersFunctionparquetIteratorOverMultipleFiles
(fileParts []filestore.Filepath, store FileStore)
provider/iterators.go:224
↓ 2 callersMethodparseEntityStream
(stream entityStream)
metadata/client.go:1086
↓ 2 callersMethodparseFeatureStream
(stream featureStream)
metadata/client.go:316
↓ 2 callersMethodparseKubernetesArgs
()
metadata/client.go:2015
↓ 2 callersMethodparseLabelStream
(stream labelStream)
metadata/client.go:462
↓ 2 callersMethodparseModelStream
(stream modelStream)
metadata/client.go:1163
↓ 2 callersMethodparsePath
(fullPath string)
filestore/filepath.go:251
↓ 2 callersMethodparseProviderStream
(stream providerStream)
metadata/client.go:1012
↓ 2 callersMethodparseSourceStream
(stream sourceStream)
metadata/client.go:840
↓ 2 callersMethodparseTrainingSetStream
(stream trainingSetStream)
metadata/client.go:595
↓ 2 callersMethodparseUserStream
(stream userStream)
metadata/client.go:930
↓ 2 callersFunctionparse_args
(args=None)
provider/scripts/spark/offline_store_spark_runner.py:679
↓ 2 callersMethodprepareTrainingSetQuery
(id ResourceID)
provider/clickhouse.go:960
↓ 2 callersMethodprimaryTableRegister
(tableName string, sourceName string)
provider/sql.go:42
↓ 2 callersMethodprint_feature
Get a feature. Prints out information on feature, and all variants associated with the feature. If variant is included, print information on that spec
client/src/featureform/register.py:4404
↓ 2 callersMethodprint_label
Get a label. Prints out information on label, and all variants associated with the label. If variant is included, print information on that specific v
client/src/featureform/register.py:4523
↓ 2 callersMethodreadFromFeature
(feature *metadata.Feature, deepCopy bool)
metadata/dashboard/dashboard_metadata.go:388
↓ 2 callersMethodreadFromLabel
(label *metadata.Label, deepCopy bool)
metadata/dashboard/dashboard_metadata.go:488
↓ 2 callersMethodreadFromSource
(source *metadata.Source, deepCopy bool)
metadata/dashboard/dashboard_metadata.go:438
↓ 2 callersMethodreadFromTrainingSet
(trainingSet *metadata.TrainingSet, deepCopy bool)
metadata/dashboard/dashboard_metadata.go:413
↓ 2 callersFunctionread_file
(filename)
tests/end_to_end/serving.py:18
↓ 2 callersMethodregisterResources
(client *bigquery.Client, tableName string, schema ResourceSchema, timestamp bool)
provider/bigquery.go:46
↓ 2 callersFunctionregisterValidSW
(swUrl, config)
dashboard/src/serviceWorker.js:57
↓ 2 callersMethodregister_hdfs
Register a HDFS store provider. This has the functionality of an offline store and can be used as a parameter to a k8s or spark provi
client/src/featureform/register.py:2496
↓ 2 callersMethodregister_mongodb
Register a MongoDB provider. **Examples**: ``` mongodb = ff.register_mongodb( name="mongodb-quickstart",
client/src/featureform/register.py:2734
↓ 2 callersMethodregisteredResourceSchema
(id ResourceID)
provider/k8s.go:1426
↓ 2 callersMethodregistrar
(self)
client/src/featureform/register.py:589
↓ 2 callersMethodrunSQLTransformationJob
(transformSource *metadata.SourceVariant, resID metadata.ResourceID, offlineStore provider.OfflineStore, sched
coordinator/coordinator.go:482
↓ 2 callersMethodrunTransformationJob
(transformationConfig provider.TransformationConfig, resID metadata.ResourceID, schedule string, sourceProvide
coordinator/coordinator.go:412
↓ 2 callersFunctionsave_to_file
(filename, data)
tests/end_to_end/dontrun/spark_generic_hdfs_definitions.py:22
↓ 2 callersFunctionsave_to_file
(filename, data)
tests/end_to_end/definitions/kcf_s3_definition.py:23
↓ 2 callersFunctionsave_to_file
(filename, data)
tests/end_to_end/definitions/spark_generic_gcs_definitions.py:22
↓ 2 callersFunctionsave_to_file
(filename, data)
tests/end_to_end/definitions/spark_emr_s3_definitions.py:22
↓ 2 callersFunctionsave_to_file
(filename, data)
tests/end_to_end/definitions/ondemand_features_definitions.py:22
↓ 2 callersFunctionsave_to_file
(filename, data)
tests/end_to_end/definitions/spark_generic_s3_definitions.py:22
↓ 2 callersFunctionsave_to_file
(filename, data)
tests/end_to_end/definitions/spark_generic_azure_definitions.py:22
↓ 2 callersFunctionsave_to_file
(filename, data)
tests/end_to_end/definitions/kcf_custom_image_definitions.py:23
↓ 2 callersFunctionsave_to_file
(filename, data)
tests/end_to_end/definitions/spark_chained_transformations_definitions.py:22
↓ 2 callersFunctionsave_to_file
(filename, data)
tests/end_to_end/definitions/spark_databricks_azure_definitions.py:22
↓ 2 callersFunctionsave_to_file
(filename, data)
tests/end_to_end/definitions/lag_features_definition.py:21
↓ 2 callersFunctionscale
(value)
dashboard/src/components/entitypage/elements/ExponentialTimeSlider.js:63
↓ 2 callersFunctionscaleValues
(valueArray)
dashboard/src/components/entitypage/elements/ExponentialTimeSlider.js:60
← previousnext →901–1,000 of 5,008, ranked by callers