MCPcopy Create free account

hub / github.com/featureform/featureform / functions

Functions5,008 in github.com/featureform/featureform

↓ 10 callersFunctioncreateMockOnlineStoreFactory
(recsMap map[provider.ResourceID][]provider.ResourceRecord)
serving/serving_test.go:486
↓ 10 callersMethoddataframe
Return a dataframe from a registered source or transformation **Example:** ```py title="definitions.py" transactions
client/src/featureform/client.py:60
↓ 10 callersMethodgetEquivalent
* * This method is used to get the equivalent resource variant for a given resource variant. readyStatus is used to determine if we should only return
metadata/metadata.go:1756
↓ 10 callersMethodgetResourceTableName
(id ResourceID)
provider/sql.go:105
↓ 10 callersFunctiongetTestBody
(errorTxt = '', buttonTxt = 'Show More')
dashboard/src/components/entitypage/ErrorModal.test.js:28
↓ 10 callersMethodname_variant
(self)
client/src/featureform/register.py:1149
↓ 10 callersMethodregister_user
Register a user. Args: name (str): User to be registered. Returns: UserRegistrar: User
client/src/featureform/register.py:1484
↓ 10 callersMethodtraining_set
Return an iterator that iterates through the specified training set. **Examples**: ``` py client = ff.Client()
client/src/featureform/serving.py:87
↓ 9 callersMethodBucket
Returns the name of the bucket (S3) or container (Azure Blob Storage)
filestore/filepath.go:83
↓ 9 callersMethodCreateTransformation
(config TransformationConfig)
provider/offline.go:275
↓ 9 callersMethodDefaultVariant
()
metadata/metadata_test.go:1665
↓ 9 callersMethodDeleteTable
(feature, variant string)
provider/online.go:39
↓ 9 callersMethodGet
(entity string)
provider/online.go:64
↓ 9 callersMethodGetFeatureVariants
(ctx context.Context, ids []NameVariant)
metadata/client.go:181
↓ 9 callersMethodGetLabelVariants
(ctx context.Context, ids []NameVariant)
metadata/client.go:433
↓ 9 callersFunctionGetOnlineStore
(t pt.Type, c pc.SerializedConfig)
provider/online.go:24
↓ 9 callersMethodGetTransformation
()
lib/sampleproto/metadata.pb.go:2211
↓ 9 callersMethodKeyPrefix
Returns all but the last element in the key (i.e. the directory path)
filestore/filepath.go:91
↓ 9 callersFunctionRegisterFactory
(t pt.Type, f Factory)
provider/provider.go:81
↓ 9 callersFunctionarrange_resources
( provider, source, online_store, tags, properties, resource_type, is_local, i
client/tests/test_tags_and_properties.py:833
↓ 9 callersFunctionassertAndCheck
(assertion, errorMessage)
dashboard/src/components/resource-list/ResourceSlice.js:4
↓ 9 callersMethodconfig
(self)
client/src/featureform/deploy.py:37
↓ 9 callersFunctionrandomFeatureVariant
()
provider/online_test.go:53
↓ 9 callersFunctionregisterRandomResource
(id ResourceID, store *SparkOfflineStore)
provider/spark_test.go:716
↓ 9 callersFunctionunwrapVal
(val *pb.Value)
serving/serving_test.go:570
↓ 8 callersMethodClose
()
metadata/client.go:2259
↓ 8 callersMethodComplete
()
types/types.go:19
↓ 8 callersMethodCredentialsConfig
()
provider/spark.go:68
↓ 8 callersMethodDeleteMaterialization
(id MaterializationID)
provider/offline.go:286
↓ 8 callersMethodFetchVariants
(client *Client, ctx context.Context)
metadata/client.go:1758
↓ 8 callersMethodGetFeatures
()
metadata/client.go:1299
↓ 8 callersMethodGetTrainingSetVariants
(ctx context.Context, ids []NameVariant)
metadata/client.go:574
↓ 8 callersMethodLastUpdated
()
metadata/client.go:1210
↓ 8 callersMethodNames
()
metadata/client.go:64
↓ 8 callersFunctionNewMetadataServer
(config *Config)
metadata/metadata.go:1435
↓ 8 callersMethodParseFilePath
**NOTE**: Due to Azure Blob Storage's unique URI format, we need to re-implement this method on the derived type to ensure we can properly handle the
filestore/filepath.go:341
↓ 8 callersMethodRegisterPrimaryFromSourceTable
(id ResourceID, sourceName string)
provider/offline.go:274
↓ 8 callersMethodReset
()
lib/sampleproto/metadata.pb.go:214
↓ 8 callersMethodSetFoundVariantJSON
(foundVariant VariantResult, err error, c *gin.Context, resourceType string)
metadata/dashboard/dashboard_metadata.go:1340
↓ 8 callersMethodSparkConfig
()
provider/spark.go:67
↓ 8 callersMethodTrainingData
(req *pb.TrainingDataRequest, stream pb.Feature_TrainingDataServer)
serving/serving.go:45
↓ 8 callersFunctionUnionTags
(destination, source *pb.Tags)
metadata/updates.go:30
↓ 8 callersFunctionadd_variant_to_name
(text, replacement)
client/src/featureform/parse.py:4
↓ 8 callersFunctioncheckName
(id ResourceID)
provider/sql.go:98
↓ 8 callersFunctioncreateMockOfflineStoreFactory
(recsMap map[provider.ResourceID][]provider.ResourceRecord, defs []provider.TrainingSetDef)
serving/serving_test.go:507
↓ 8 callersMethodgenericCreate
(ctx context.Context, res Resource, init initParentFn)
metadata/metadata.go:1839
↓ 8 callersMethodgenericList
(t ResourceType, send sendFn)
metadata/metadata.go:2044
↓ 8 callersFunctiongetTestBody
( apiParam = apiDataMock, name = DEFAULT_NAME, variant = DEFAULT_VARIANT, type = 'Source' )
dashboard/src/components/dialog/sourceDialog.test.js:69
↓ 8 callersFunctioninitProvider
(t *testing.T, providerType pt.Type, executorType pc.SparkExecutorType, storeType fs.FileStoreType)
health/health_test.go:293
↓ 8 callersFunctionmakeCronSchedule
(schedule string)
kubernetes/kubernetes.go:57
↓ 8 callersFunctionmergeProperties
(destination, source *pb.Properties)
metadata/updates.go:46
↓ 8 callersMethodmultiset
Set multiple embeddings at once. Take a dictionary of key embedding pairs and set them in the index. Args: embedding_tup
embeddinghub/sdk/python/offlinehub.py:60
↓ 8 callersMethodmust_get_default_owner
(self)
client/src/featureform/register.py:1510
↓ 8 callersMethodname
(self)
embeddinghub/test/benchmark.py:14
↓ 8 callersFunctionnewMockTrainingStream
()
serving/serving_test.go:1113
↓ 8 callersFunctionparquetIteratorFromBytes
(b []byte)
provider/iterators.go:367
↓ 8 callersMethodregister_blob_store
Register an Azure Blob Store provider. Azure Blob Storage can be used as the storage component for Spark or the Featureform Pandas Runner.
client/src/featureform/register.py:2282
↓ 8 callersFunctionresourceNamedSafely
(id ResourceID)
metadata/metadata.go:156
↓ 8 callersMethodtableExists
(id ResourceID)
provider/sql.go:142
↓ 8 callersMethodtableExists
(id ResourceID)
provider/bigquery.go:1336
↓ 8 callersFunctiontestListResources
(t *testing.T, typ ResourceType, tests ResourceTests)
metadata/metadata_test.go:1786
↓ 7 callersMethodCreated
()
metadata/client.go:1197
↓ 7 callersMethodFinish
()
metrics/metrics.go:37
↓ 7 callersMethodGetDescription
()
lib/sampleproto/metadata.pb.go:1915
↓ 7 callersMethodGetEntity
(ctx context.Context, entity string)
metadata/client.go:1034
↓ 7 callersMethodGetJobRunner
(jobName runner.RunnerName, config runner.Config, resourceId metadata.ResourceID)
coordinator/coordinator.go:187
↓ 7 callersMethodGetModel
(ctx context.Context, model string)
metadata/client.go:1108
↓ 7 callersFunctionGetSparkLocalScriptPath
()
config/config.go:46
↓ 7 callersMethodGetVariant
()
lib/sampleproto/metadata.pb.go:1131
↓ 7 callersMethodIsTransformation
()
metadata/client.go:2089
↓ 7 callersMethodLocationColumns
()
metadata/client.go:1832
↓ 7 callersFunctionNewCoordinator
(meta *metadata.Client, logger *zap.SugaredLogger, cli *clientv3.Client, spawner JobSpawner)
coordinator/coordinator.go:236
↓ 7 callersMethodRun
()
provider/online_test.go:28
↓ 7 callersMethodRunSparkJob
(args []string, store SparkFileStore)
provider/spark.go:899
↓ 7 callersMethodScalar
()
provider/value_type.go:15
↓ 7 callersFunctionarrange_resources
(provider, source, online_store, is_local, is_insecure)
client/tests/test_serving_model.py:403
↓ 7 callersMethodcastTableItemType
(v interface{}, t interface{})
provider/sql.go:63
↓ 7 callersFunctionformat_tags_and_properties
(tags, properties)
client/src/featureform/get.py:266
↓ 7 callersMethodgetMaterializationTableName
(id MaterializationID)
provider/sql.go:118
↓ 7 callersMethodgetMaterializationTableName
(id MaterializationID)
provider/clickhouse.go:204
↓ 7 callersMethodgetTrainingSets
(nameVariants []metadata.NameVariant)
metadata/dashboard/dashboard_metadata.go:328
↓ 7 callersFunctionget_args
Gets input arguments from environment variables. Parameters: None Returns: Namespace
provider/scripts/k8s/offline_store_pandas_runner.py:431
↓ 7 callersMethodget_provider
Get a provider. Prints out information on provider, and all resources associated with the provider. **Examples:** ``` py title="Inpu
client/src/featureform/register.py:4305
↓ 7 callersMethodmake_default_owner
(self)
client/src/featureform/register.py:113
↓ 7 callersMethodregister_column_resources
Create features and labels from a source. Used in the register_resources function. Args: source (Union[NameVariant, SourceRegistr
client/src/featureform/register.py:3766
↓ 7 callersFunctionsimpleTrainingSetDefs
()
serving/serving_test.go:401
↓ 7 callersFunctionstartServ
(t *testing.T)
coordinator/coordinator_test.go:89
↓ 7 callersMethodstore_type
(self)
client/src/featureform/resources.py:384
↓ 7 callersMethodtableExists
(id ResourceID)
provider/clickhouse.go:68
↓ 7 callersFunctiontestFetchTrainingSets
(t *testing.T, client *Client, fetcher trainingSetsFetcher)
metadata/metadata_test.go:1861
↓ 6 callersMethodDeserialize
(config SerializedConfig)
provider/provider_config/bigquery_config.go:15
↓ 6 callersMethodDone
()
runner/copy.go:182
↓ 6 callersMethodDownload
(src, dest filestore.Filepath)
backup/providers.go:23
↓ 6 callersMethodError
()
scheduling/storage_providers/storage_provider.go:16
↓ 6 callersMethodGet
()
kubernetes/kubernetes.go:201
↓ 6 callersMethodGetColumns
()
lib/sampleproto/metadata.pb.go:1363
↓ 6 callersMethodGetFirst
()
filestore/filepath.go:481
↓ 6 callersMethodGetLabelVariant
(ctx context.Context, id NameVariant)
metadata/client.go:450
↓ 6 callersMethodGetLocation
()
lib/sampleproto/metadata.pb.go:2728
↓ 6 callersMethodGetMaterialization
(id MaterializationID)
provider/offline.go:284
← previousnext →201–300 of 5,008, ranked by callers