Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/featureform/featureform
/ functions
Functions
5,008 in github.com/featureform/featureform
⨍
Functions
5,008
◇
Types & classes
913
↳
Endpoints
59
↓ 3 callers
Method
Software
()
metadata/client.go:1660
↓ 3 callers
Method
String
()
provider/firestore.go:21
↓ 3 callers
Method
Team
()
metadata/client.go:1664
↓ 3 callers
Method
UpdateMaterialization
(id ResourceID)
provider/offline.go:285
↓ 3 callers
Method
UpdateTrainingSet
(TrainingSetDef)
provider/offline.go:288
↓ 3 callers
Method
Validate
()
filestore/filepath.go:106
↓ 3 callers
Method
Value
()
helpers/struct_iterator/struct_iterator.go:33
↓ 3 callers
Method
Value
()
provider/offline.go:464
↓ 3 callers
Method
__call__
(self, fn: Callable[[], str])
client/src/featureform/register.py:705
↓ 3 callers
Method
__init__
(self, label_name, label_variant, message=None)
client/src/featureform/exceptions.py:32
↓ 3 callers
Method
__init__
(self, store_credentials)
provider/scripts/k8s/offline_store_pandas_runner.py:31
↓ 3 callers
Method
_assert_query_contains_at_least_one_source
(query)
client/src/featureform/register.py:807
↓ 3 callers
Method
_modify_column_name
(self, string_name, df_has_quotes)
client/src/featureform/register.py:1379
↓ 3 callers
Function
arrange_resources
(model_name, is_local, is_insecure)
client/tests/test_getting_model.py:72
↓ 3 callers
Method
checkArgs
(args metadata.TransformationArgs)
provider/k8s.go:840
↓ 3 callers
Method
checkError
(err error, jobName string)
coordinator/coordinator.go:251
↓ 3 callers
Method
checkSchemes
(scheme string)
filestore/filepath.go:242
↓ 3 callers
Function
checkZeroTime
(t time.Time)
provider/clickhouse.go:1318
↓ 3 callers
Function
check_feature_type
(features)
client/src/featureform/serving.py:30
↓ 3 callers
Method
config
(self)
client/src/featureform/resources.py:293
↓ 3 callers
Function
convertToParquetBytes
(schema TableSchema, list []GenericRecord)
provider/k8s_test.go:1050
↓ 3 callers
Method
createJobLock
(jobKey string, s *concurrency.Session)
coordinator/coordinator.go:1129
↓ 3 callers
Function
delete_file
(file_path)
provider/scripts/spark/offline_store_spark_runner.py:645
↓ 3 callers
Method
describeIndex
https://docs.pinecone.io/reference/describe_index
provider/pinecone.go:241
↓ 3 callers
Method
df_transformation
Dataframe transformation decorator. Args: variant (str): Name of variant provider (Union[str, OfflineProvider]): Prov
client/src/featureform/register.py:3519
↓ 3 callers
Function
expectedFeatureVariants
()
metadata/metadata_test.go:1188
↓ 3 callers
Function
expectedModels
()
metadata/metadata_test.go:1505
↓ 3 callers
Function
expectedTrainingSetVariants
()
metadata/metadata_test.go:1435
↓ 3 callers
Function
expectedUsers
()
metadata/metadata_test.go:593
↓ 3 callers
Function
fetch_cluster_version
(version_url="")
client/src/featureform/tls.py:46
↓ 3 callers
Function
getApikey
()
metadata/search/search_test.go:17
↓ 3 callers
Method
getFile
(path filestore.Filepath)
provider/filestore.go:526
↓ 3 callers
Method
getIndexOperationURL
(operation string)
provider/pinecone.go:349
↓ 3 callers
Function
getMockSchemaAndRecords
(length int)
provider/k8s_test.go:445
↓ 3 callers
Function
getPort
()
metadata/search/search_test.go:13
↓ 3 callers
Function
getSourceMapping
(template string, replacements map[string]string)
coordinator/coordinator.go:67
↓ 3 callers
Function
getTableName
(testName string, tableName string)
provider/offline_test.go:3375
↓ 3 callers
Function
getTestVectorEntities
(t *testing.T)
provider/vectorstore_test.go:164
↓ 3 callers
Method
getVectorOperationURL
(indexName, operation string)
provider/pinecone.go:354
↓ 3 callers
Function
get_credentials_dict
(base64_creds)
provider/scripts/spark/offline_store_spark_runner.py:630
↓ 3 callers
Method
get_entity
Get an entity. The returned object can be used to register additional resources. **Examples**: ``` py entity = get_entity("u
client/src/featureform/register.py:2103
↓ 3 callers
Function
instantiateMockRedisClient
(addr string)
provider/redis_test.go:358
↓ 3 callers
Function
isValidBigQueryConfigUpdate
(sa, sb pc.SerializedConfig)
metadata/provider.go:5
↓ 3 callers
Function
isValidPostgresConfigUpdate
(sa, sb pc.SerializedConfig)
metadata/provider.go:101
↓ 3 callers
Function
kubernetesRanScheduledJob
(resID metadata.ResourceID)
coordinator/scheduletest/main.go:294
↓ 3 callers
Method
materializationCreate
(tableName string, sourceName string)
provider/sql.go:47
↓ 3 callers
Method
materializationExists
(tableName string)
provider/bigquery.go:59
↓ 3 callers
Method
monitorJob
(job *bigquery.Job)
provider/bigquery.go:62
↓ 3 callers
Method
name
(self)
client/src/featureform/resources.py:956
↓ 3 callers
Method
nearest_neighbor
Finds N nearest neighbors for a given embedding record. Args: key: The embedding index to get the nearest neighbors of.
embeddinghub/sdk/python/offlinehub.py:98
↓ 3 callers
Function
newParquetIterator
(b []byte, limit int64)
provider/iterators.go:98
↓ 3 callers
Function
newTestStore
()
dashboard/src/components/redux/store/ReduxStore.js:8
↓ 3 callers
Method
pandasRunnerArgs
(outputURI string, updatedQuery string, sources []string, jobType JobType)
provider/k8s.go:768
↓ 3 callers
Function
parseNameVariant
(serialized *pb.NameVariant)
metadata/client.go:39
↓ 3 callers
Method
primaryTableCreate
(name string, columnString string)
provider/sql.go:43
↓ 3 callers
Method
print_training_set
Get a training set. Prints out information on training set, and all variants associated with the training set. If variant is included, print informati
client/src/featureform/register.py:4645
↓ 3 callers
Method
query
https://docs.pinecone.io/reference/query
provider/pinecone.go:322
↓ 3 callers
Function
registerMockIndexRunnerFactory
()
runner/worker/worker_test.go:185
↓ 3 callers
Function
registerRandomResourceGiveTable
(id ResourceID, store *SparkOfflineStore, table interface{}, timestamp bool)
provider/spark_test.go:698
↓ 3 callers
Function
registerRandomResourceGiveTablePath
(id ResourceID, path string, store *SparkOfflineStore, table interface{}, timestamp bool)
provider/spark_test.go:681
↓ 3 callers
Method
register_model
Register a model. Args: name (str): Model to be registered tags (List[str]): Optional grouping mechanism for resource
client/src/featureform/register.py:4060
↓ 3 callers
Method
restart
(self)
client/src/featureform/serving.py:426
↓ 3 callers
Method
runPrimaryTableJob
(source *metadata.SourceVariant, resID metadata.ResourceID, offlineStore provider.OfflineStore, schedule strin
coordinator/coordinator.go:576
↓ 3 callers
Method
runRegisterSourceJob
(resID metadata.ResourceID, schedule string)
coordinator/coordinator.go:595
↓ 3 callers
Function
sanitize
(ident string)
coordinator/scheduletest/main.go:30
↓ 3 callers
Function
set_spark_configs
(spark, configs)
provider/scripts/spark/offline_store_spark_runner.py:600
↓ 3 callers
Method
size
Returns the amount of embeddings in the index
embeddinghub/sdk/python/offlinehub.py:129
↓ 3 callers
Function
split_key_value
(values)
provider/scripts/spark/offline_store_spark_runner.py:667
↓ 3 callers
Function
startServNoPanic
(t *testing.T)
metadata/metadata_test.go:424
↓ 3 callers
Method
tableExists
(feature, variant string)
provider/blob_online.go:57
↓ 3 callers
Function
testResourceUpdates
(t *testing.T, typ ResourceType, arranged, expected ResourceTests, updates []ResourceDef)
metadata/metadata_test.go:1604
↓ 3 callers
Function
testTransform
(t *testing.T, store OfflineStore)
provider/offline_test.go:1909
↓ 3 callers
Method
to_idx
Turn a key into an hnswlib index Args: key: The key to transform Returns: An index to be used in hnswlib
embeddinghub/sdk/python/offlinehub.py:152
↓ 3 callers
Method
trainingSetCreate
(store *sqlOfflineStore, def TrainingSetDef, tableName string, labelName string)
provider/sql.go:59
↓ 3 callers
Method
transformation
(config TransformationConfig, isUpdate bool)
provider/k8s.go:745
↓ 3 callers
Function
unorderedEqual
(first, second []any)
provider/spark_test.go:303
↓ 3 callers
Method
updateQuery
(query string, mapping []SourceMapping)
provider/k8s.go:897
↓ 3 callers
Method
upload_file
(self, file_path, blob_path)
provider/scripts/k8s/offline_store_pandas_runner.py:52
↓ 3 callers
Method
validate
(store_type: str, file_path: str)
client/src/featureform/enums.py:122
↓ 3 callers
Function
wrapInPromise
(arr)
dashboard/__tests__/ResourceSlice.test.js:13
↓ 3 callers
Function
wrapInt32
(val int32)
serving/serialize.go:258
↓ 3 callers
Function
wrapUInt32
(val uint32)
serving/serialize.go:270
↓ 2 callers
Method
AddEnvVars
(envVars map[string]string)
provider/filestore.go:48
↓ 2 callers
Method
AddFeature
(feature interface{})
serving/serialize.go:124
↓ 2 callers
Method
BatchFeatureServe
(req *srv.BatchFeatureServeRequest, stream srv.Feature_BatchFeatureServeServer)
api/main.go:769
↓ 2 callers
Method
ClientString
()
metadata/client.go:35
↓ 2 callers
Method
Columns
()
provider/unit_test_store.go:137
↓ 2 callers
Method
ConnectionString
()
provider/provider_config/snowflake_config.go:63
↓ 2 callers
Function
CreateFileStore
(name string, config Config)
provider/k8s.go:152
↓ 2 callers
Function
CreateSparkFileStore
(fsType filestore.FileStoreType, config Config)
provider/spark.go:84
↓ 2 callers
Method
DFTransformationSources
()
metadata/client.go:2133
↓ 2 callers
Function
DailySchedule
(hour, minute int)
kubernetes/kubernetes.go:73
↓ 2 callers
Method
Delete
(ctx context.Context, key string, opts ...clientv3.OpOption)
backup/backup.go:23
↓ 2 callers
Method
Dependencies
(ResourceLookup)
metadata/metadata.go:193
↓ 2 callers
Method
Deserialize
(config Config)
runner/materialize.go:263
↓ 2 callers
Method
Deserialize
(config Config)
runner/copy.go:252
↓ 2 callers
Method
Deserialize
(config Config)
runner/create_transformation.go:57
↓ 2 callers
Method
Deserialize
(serialized []byte)
metadata/etcd.go:58
↓ 2 callers
Method
Deserialize
(config []byte)
provider/provider_config/executor_config.go:23
↓ 2 callers
Method
Err
()
provider/k8s.go:1314
← previous
next →
601–700 of 5,008, ranked by callers