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
↓ 6 callersFunctionGetOfflineStore
(t pt.Type, c pc.SerializedConfig)
provider/offline.go:127
↓ 6 callersMethodGetOwner
()
lib/sampleproto/metadata.pb.go:1328
↓ 6 callersFunctionGetSparkRemoteScriptPath
()
config/config.go:50
↓ 6 callersMethodIsPrimaryDataSQLTable
()
metadata/client.go:2165
↓ 6 callersMethodIsVector
()
provider/value_type.go:16
↓ 6 callersFunctionNewFilePathGroup
Currently, grouping files by date time directory written out by Spark is the only use case for grouping files; however, this method can be extended to
filestore/filepath.go:498
↓ 6 callersMethodPackages
()
provider/spark.go:69
↓ 6 callersMethodRun
()
provider/offline_test.go:32
↓ 6 callersMethodRunSearch
(q string)
metadata/search/search.go:18
↓ 6 callersMethodSerialize
()
provider/provider_config/postgres_config.go:26
↓ 6 callersMethodSerialized
()
serving/serialize.go:111
↓ 6 callersMethodServeOnListener
(lis net.Listener)
metadata/metadata.go:1470
↓ 6 callersMethodSet
(key string, value string)
scheduling/storage_providers/storage_provider.go:8
↓ 6 callersMethodSparkSubmitArgs
(destPath filestore.Filepath, cleanQuery string, sourceList []string, jobType JobType, store SparkFileStore)
provider/spark.go:902
↓ 6 callersFunctionUnregisterFactory
(name RunnerName)
runner/library.go:51
↓ 6 callersMethod__init__
(self, resources: Dict[str, ColumnResource])
client/src/featureform/register.py:1158
↓ 6 callersMethod__init__
(self)
embeddinghub/test/benchmark.py:214
↓ 6 callersMethod_verify_yarn_config
(self)
client/src/featureform/resources.py:2176
↓ 6 callersMethodatomicUpdate
(client *bigquery.Client, tableName string, tempName string, query string)
provider/bigquery.go:69
↓ 6 callersFunctioncheckTimestamp
checkTimestamp checks the timestamp of a record. If the record has the default initialization value of 0001-01-01 00:00:00 +0000 UTC, it is changed to
provider/offline.go:988
↓ 6 callersFunctioncreateNewCoordinator
(addr string)
coordinator/coordinator_test.go:119
↓ 6 callersFunctioncreateQuotedIdentifier
Spark SQL _seems_ to have some issues with double quotes in column names based on troubleshooting the offline tests. Given this, we will use backticks
provider/spark.go:600
↓ 6 callersMethodgetFeatures
(nameVariants []metadata.NameVariant)
metadata/dashboard/dashboard_metadata.go:343
↓ 6 callersMethodgetResourceTableName
(id ResourceID)
provider/bigquery.go:1415
↓ 6 callersMethodgetValueColumnTypes
(tableName string)
provider/sql.go:45
↓ 6 callersMethodget_model
Get a model. Prints out information on model, and all resources associated with the model. Args: name (str): Name of model to be
client/src/featureform/register.py:4289
↓ 6 callersMethodhasJob
(id metadata.ResourceID)
coordinator/coordinator.go:1117
↓ 6 callersMethodinit
()
metadata/etcd_test.go:32
↓ 6 callersMethodkwargs
(self)
client/src/featureform/resources.py:947
↓ 6 callersMethodmaterializationExists
()
provider/sql.go:49
↓ 6 callersMethodname_variant
(self)
client/src/featureform/resources.py:935
↓ 6 callersFunctionnewsqlBatchFeatureIterator
Need to figure out columntype
provider/sql.go:531
↓ 6 callersMethodoperation_type
()
client/src/featureform/resources.py:889
↓ 6 callersFunctionrandomStringNBytes
(size int, t *testing.T)
provider/spark_test.go:3381
↓ 6 callersFunctionremoveEspaceCharacters
(values []string)
provider/spark.go:1380
↓ 6 callersMethodrequest
(method, url string, payload interface{}, expectedStatus int)
provider/pinecone.go:359
↓ 6 callersMethodresult
(self, timeout=None)
embeddinghub/sdk/python/embeddinghub.py:282
↓ 6 callersFunctiontestFetchFeatures
(t *testing.T, client *Client, fetcher featuresFetcher)
metadata/metadata_test.go:1807
↓ 6 callersMethodto_source
(self)
client/src/featureform/register.py:871
↓ 6 callersMethodtype
()
dashboard/src/api/resources/Resource.js:131
↓ 6 callersFunctionupload_single_file
( connection_string, container_name, local_file_name, upload_file_path )
tests/end_to_end/features/steps/filestore_upload.py:93
↓ 6 callersFunctionwrapValue
(value interface{})
serving/serialize.go:186
↓ 5 callersMethodCreateIndex
(feature, variant string, vectorType VectorType)
provider/online.go:68
↓ 5 callersMethodCreateModel
(ctx context.Context, def ModelDef)
metadata/client.go:1146
↓ 5 callersMethodDeleteAll
(dir filestore.Filepath)
provider/filestore.go:40
↓ 5 callersMethodFromFilestorePath
TODO: add unit tests
provider/offline.go:78
↓ 5 callersMethodGetDFTransformation
()
lib/sampleproto/metadata.pb.go:2394
↓ 5 callersMethodGetEntities
(ctx context.Context, entities []string)
metadata/client.go:1042
↓ 5 callersMethodGetLabel
(ctx context.Context, label string)
metadata/client.go:356
↓ 5 callersMethodGetProviders
(ctx context.Context, providers []string)
metadata/client.go:960
↓ 5 callersFunctionGetTableName
(keyspace, feature, variant string)
provider/cassandra.go:101
↓ 5 callersFunctionGetTestGinContext
(mockRecorder *httptest.ResponseRecorder)
metadata/dashboard/dashboard_metadata_test.go:21
↓ 5 callersMethodGetValue
()
lib/sampleproto/metadata.pb.go:686
↓ 5 callersMethodIsDir
()
filestore/filepath.go:93
↓ 5 callersMethodLookup
(ResourceID)
metadata/metadata.go:211
↓ 5 callersFunctionNewLocalFileStore
(config Config)
provider/filestore.go:65
↓ 5 callersFunctionNewMeilisearch
(params *MeilisearchParams)
metadata/search/search.go:32
↓ 5 callersFunctionNewMockOnlineStore
()
runner/copy_test.go:740
↓ 5 callersMethodParseResource
Takes a populated ETCD storage struct and a resource Checks to make sure the given ETCD Storage Object contains a Resource, not job Deserializes Resou
metadata/etcd.go:227
↓ 5 callersMethodProto
()
metadata/metadata.go:656
↓ 5 callersMethodResource
()
types/types.go:9
↓ 5 callersMethodRun
()
kubernetes/kubernetes.go:323
↓ 5 callersMethodRunSQL
()
provider/offline_test.go:76
↓ 5 callersMethodServeRow
()
metrics/metrics.go:36
↓ 5 callersMethodSetScheme
(scheme string)
filestore/filepath.go:80
↓ 5 callersMethodSources
()
metadata/metadata_test.go:1839
↓ 5 callersMethodSubmap
([]ResourceID)
metadata/metadata.go:214
↓ 5 callersMethodTransformationArgs
()
metadata/client.go:2150
↓ 5 callersMethodUpload
**NOTE:** Upload accepts strings instead of filestore.Filepath because the store, which could create a filestore-specific filepath, is not exposed by
backup/providers.go:22
↓ 5 callersMethodUpsert
(ResourceDoc)
metadata/search/search.go:17
↓ 5 callersMethodWatch
()
kubernetes/kubernetes.go:204
↓ 5 callersFunction_get_and_set_equivalent_variant
( resource_variant_proto, variant_field, stub )
client/src/featureform/resources.py:2210
↓ 5 callersMethodcreateEmptyResource
Returns an empty Resource Object of the given type to unmarshal etcd value into
metadata/etcd.go:248
↓ 5 callersMethoddownload
(self, blob_path, file_path)
provider/scripts/k8s/offline_store_pandas_runner.py:58
↓ 5 callersMethodgetContext
()
provider/bigquery.go:334
↓ 5 callersMethodgetLabels
(nameVariants []metadata.NameVariant)
metadata/dashboard/dashboard_metadata.go:358
↓ 5 callersMethodgetMaterializationTableName
(id MaterializationID)
provider/bigquery.go:1069
↓ 5 callersMethodgetResourceTableName
(id ResourceID)
provider/clickhouse.go:48
↓ 5 callersMethodgetTablePrefix
()
provider/bigquery.go:322
↓ 5 callersMethodgetTrainingSetName
(id ResourceID)
provider/sql.go:127
↓ 5 callersMethodgetTrainingSetName
(id ResourceID)
provider/bigquery.go:1428
↓ 5 callersMethodgetValueColumnType
(t *sql.ColumnType)
provider/sql.go:64
↓ 5 callersFunctionget_random_name
(sep="_")
client/src/featureform/variant_names_generator.py:491
↓ 5 callersFunctionget_resource_info
(stub, resource_type, name)
client/src/featureform/get.py:57
↓ 5 callersMethodget_source
get_source() can be used to get a reference to an already registered primary source or transformation. The returned object can be use
client/src/featureform/register.py:1618
↓ 5 callersMethodget_training_set
(self, name, variant)
client/src/featureform/register.py:4622
↓ 5 callersMethodgetbqResourceTable
(id ResourceID)
provider/bigquery.go:1051
↓ 5 callersMethodgetsqlResourceTable
(id ResourceID)
provider/sql.go:969
↓ 5 callersMethodgetsqlResourceTable
(id ResourceID)
provider/clickhouse.go:173
↓ 5 callersMethodlabel
(self)
client/src/featureform/serving.py:969
↓ 5 callersMethodlist_models
List all models. Prints a list of all models. Returns: models (List[Model]): List of Model Objects
client/src/featureform/register.py:5164
↓ 5 callersMethodmap_client_object_to_resource
( self, client_obj, resource_variant: ResourceVariant )
client/src/featureform/register.py:1473
↓ 5 callersFunctionmodifyTransformationConfig
(t *testing.T, testName, tableName string, providerType pt.Type, config *TransformationConfig)
provider/offline_test.go:3396
↓ 5 callersFunctionparse_proto_value
parse_proto_value is used to parse the one of Value message
client/src/featureform/serving.py:1036
↓ 5 callersMethodproto
(self)
client/src/featureform/resources.py:1237
↓ 5 callersFunctionreadAndUploadFile
(filePath filestore.Filepath, storePath filestore.Filepath, store SparkFileStore)
provider/spark.go:366
↓ 5 callersMethodregister_primary_data
Register a primary data source. Args: name (str): Name of source variant (str): Name of variant location
client/src/featureform/register.py:3307
↓ 5 callersMethodregister_snowflake
Register a Snowflake provider. **Examples**: ``` snowflake = ff.register_snowflake( name="snowflake-quickstart",
client/src/featureform/register.py:2871
↓ 5 callersMethodrepeat
Repeats the Dataset for the specified number of times **Examples**: ``` py client = ff.Client() dataset = cli
client/src/featureform/serving.py:869
↓ 5 callersMethodrunFeatureMaterializeJob
(resID metadata.ResourceID, schedule string)
coordinator/coordinator.go:709
← previousnext →301–400 of 5,008, ranked by callers