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
↓ 1 callers
Method
createFormattedStrings
(matchPositions, item)
dashboard/src/components/searchresults/searchengine/SearchEngine.js:8
↓ 1 callers
Function
createIndexAndWait
(t *testing.T, api *pineconeAPI, indexName string, dimension int32, duration time.Duration)
provider/pinecone_test.go:114
↓ 1 callers
Method
createIndexCmd
(key redisIndexKey, vectorType VectorType)
provider/redis.go:219
↓ 1 callers
Function
createJoinQuery
(numFeatures int)
provider/spark.go:766
↓ 1 callers
Function
createMapCopy
(originalMap map[string]interface{})
provider/provider_config/gcs_file_store_config_test.go:119
↓ 1 callers
Method
createNearestCmd
(vector []float32, k int32)
provider/redis.go:431
↓ 1 callers
Function
createPromUrl
()
dashboard/src/components/entitypage/elements/MetricsDropdown.js:113
↓ 1 callers
Function
createRedshiftDatabase
(c pc.RedshiftConfig)
provider/redshift_test.go:77
↓ 1 callers
Function
createSnowflakeDatabase
(c pc.SnowflakeConfig)
provider/snowflake_test.go:81
↓ 1 callers
Function
createSourceWithProvider
(sourceName string, tableName string)
coordinator/scheduletest/main.go:736
↓ 1 callers
Method
createTables
(self)
metadata/dashboard/sqlLite.py:33
↓ 1 callers
Function
createTrainingSetWithProvider
(client *metadata.Client, offlineConfig pc.SerializedConfig, onlineConfig pc.SerializedConfig, sourceName stri
coordinator/coordinator_test.go:1163
↓ 1 callers
Function
createTrainingSetWithProvider
helper functions for creating resources in metadata
coordinator/scheduletest/main.go:592
↓ 1 callers
Function
createTransformationWithProvider
(sourceName string, transformationQuery string, sources []metadata.NameVariant, schedule string)
coordinator/scheduletest/main.go:770
↓ 1 callers
Method
createValuePlaceholderString
(columns []TableColumn)
provider/bigquery.go:45
↓ 1 callers
Method
create_all
(self, stub, client_objs_for_resource: dict = None)
client/src/featureform/resources.py:1903
↓ 1 callers
Method
create_error_message
(self)
client/src/featureform/status_display.py:114
↓ 1 callers
Method
createsqlPrimaryTableQuery
primaryTableCreate creates a query for table creation based on the specified TableSchema. Returns the query if successful. Returns an error if there i
provider/sql.go:293
↓ 1 callers
Method
createsqlPrimaryTableQuery
(name string, schema TableSchema)
provider/clickhouse.go:116
↓ 1 callers
Method
dataframe
Returns the training set as a Pandas DataFrame or Spark DataFrame. Args: - spark_session: Optional(SparkSession) **Examples*
client/src/featureform/serving.py:755
↓ 1 callers
Method
decodeArgs
(t metadata.TransformationArgType, argMap map[string]interface{})
provider/offline.go:246
↓ 1 callers
Method
decodeExecutor
(executorType SparkExecutorType, configMap map[string]interface{})
provider/provider_config/spark_config.go:190
↓ 1 callers
Method
decodeExecutor
(executorType ExecutorType, configMap interface{})
provider/provider_config/k8s_config.go:69
↓ 1 callers
Method
decodeFileStore
(fileStoreType fs.FileStoreType, configMap map[string]interface{})
provider/provider_config/spark_config.go:211
↓ 1 callers
Method
decodeFileStore
(fileStoreType filestore.FileStoreType, configMap map[string]interface{})
provider/provider_config/k8s_config.go:84
↓ 1 callers
Function
deferencePointer
(v interface{})
provider/clickhouse.go:1306
↓ 1 callers
Method
deleteFile
(file os.FileInfo, dir filestore.Filepath)
provider/filestore.go:618
↓ 1 callers
Method
deleteTable
(feature, variant string)
provider/blob_online.go:88
↓ 1 callers
Function
delete_databricks_jobs
List all jobs and trigger their deletion.
scripts/databricks_job_cleanup.py:18
↓ 1 callers
Function
delete_job
Delete a job by job ID.
scripts/databricks_job_cleanup.py:43
↓ 1 callers
Method
deserialize
(key []byte)
provider/redis.go:355
↓ 1 callers
Function
destroyBigQueryDataset
(c pc.BigQueryConfig)
provider/bigquery_test.go:106
↓ 1 callers
Function
destroyRedshiftDatabase
(c pc.RedshiftConfig)
provider/redshift_test.go:91
↓ 1 callers
Function
destroySnowflakeDatabase
(c pc.SnowflakeConfig)
provider/snowflake_test.go:94
↓ 1 callers
Method
dfTransformation
(config TransformationConfig, isUpdate bool)
provider/k8s.go:848
↓ 1 callers
Method
dfTransformation
(config TransformationConfig, isUpdate bool)
provider/spark.go:1534
↓ 1 callers
Method
display
(self)
client/src/featureform/status_display.py:121
↓ 1 callers
Function
display_statuses
(stub: ApiStub, resources: List[Resource], verbose=False)
client/src/featureform/status_display.py:27
↓ 1 callers
Method
doesNotExistsError
(err error)
provider/filestore.go:513
↓ 1 callers
Method
download
Get all values in the space provided. Args: space: The name of the space to retrieve from. Returns: An itera
embeddinghub/sdk/python/embeddinghub.py:193
↓ 1 callers
Function
download_and_split_csv
(file_uri, local_dir_name)
tests/end_to_end/features/steps/filestore_upload.py:66
↓ 1 callers
Method
download_directory
(self, blob_path, directory_path)
provider/scripts/k8s/offline_store_pandas_runner.py:82
↓ 1 callers
Function
download_file
(file_uri, local_file_name, filetype)
tests/end_to_end/features/steps/filestore_upload.py:49
↓ 1 callers
Method
download_file
(self, blob_path, file_path)
provider/scripts/k8s/offline_store_pandas_runner.py:79
↓ 1 callers
Method
download_file
(self, blob_path, local_file_path)
provider/scripts/k8s/offline_store_pandas_runner.py:116
↓ 1 callers
Function
emptyBatchRow
()
serving/serialize.go:49
↓ 1 callers
Function
emptyRow
()
serving/serialize.go:43
↓ 1 callers
Function
emptySourceRow
()
serving/serialize.go:55
↓ 1 callers
Method
entity
(self)
client/src/featureform/serving.py:1091
↓ 1 callers
Function
expectedUpdatedModels
()
metadata/metadata_test.go:1564
↓ 1 callers
Function
expectedUpdatedProviders
()
metadata/metadata_test.go:829
↓ 1 callers
Function
expectedUserUpdates
()
metadata/metadata_test.go:641
↓ 1 callers
Function
extractElementValue
* example proto.value args: double_value:2544 str_value:"C7332112" */
metadata/dashboard/dashboard_metadata.go:1269
↓ 1 callers
Method
extractResourceVariant
extractResourceVariant takes a ResourceVariant request and extracts the concrete type and corresponding ResourceType.
metadata/metadata.go:1806
↓ 1 callers
Method
features
(self)
client/src/featureform/register.py:1037
↓ 1 callers
Method
features
(self)
client/src/featureform/serving.py:995
↓ 1 callers
Method
features
(self)
client/src/featureform/serving.py:1088
↓ 1 callers
Method
features_and_labels
(self)
client/src/featureform/register.py:1127
↓ 1 callers
Method
fetchEntity
(type, title)
dashboard/src/api/resources/Resources.js:221
↓ 1 callers
Method
fetchFeatureFileStats
(name, variant = 'default')
dashboard/src/api/resources/Resources.js:283
↓ 1 callers
Method
fetchMetrics
()
dashboard/src/api/resources/Metrics.js:31
↓ 1 callers
Method
fetchResources
(type)
dashboard/src/api/resources/Resources.js:191
↓ 1 callers
Method
fetchSearch
(query)
dashboard/src/api/resources/Resources.js:263
↓ 1 callers
Method
fetchSourceModalData
(name, variant = 'default')
dashboard/src/api/resources/Resources.js:273
↓ 1 callers
Method
fetchVersionMap
()
dashboard/src/api/resources/Resources.js:244
↓ 1 callers
Function
file_metadata_proto_metadata_proto_init
()
lib/sampleproto/metadata.pb.go:4261
↓ 1 callers
Function
findEquivalent
findEquivalent searches through a slice of Resources to find an equivalent ResourceVariant.
metadata/metadata.go:1782
↓ 1 callers
Method
from_resource
(resource: Resource)
client/src/featureform/status_display.py:52
↓ 1 callers
Function
generateCleanRandomJobName
()
kubernetes/kubernetes.go:345
↓ 1 callers
Function
generateKubernetesEnvVars
(envVars map[string]string)
kubernetes/kubernetes.go:103
↓ 1 callers
Function
generate_data
(num_rows: int, num_features: int, key_space: int)
benchmark/data_generator.py:11
↓ 1 callers
Method
getBaseConnection
()
provider/provider_config/snowflake_config.go:119
↓ 1 callers
Method
getBatchFeatureIterator
(ids []provider.ResourceID)
serving/serving.go:333
↓ 1 callers
Function
getBigQueryConfig
(t *testing.T)
coordinator/coordinator_test.go:967
↓ 1 callers
Method
getColumnNameString
()
provider/sql.go:1025
↓ 1 callers
Method
getColumnType
(name string)
provider/iterators.go:354
↓ 1 callers
Function
getConcurrencyPolicy
()
kubernetes/kubernetes.go:477
↓ 1 callers
Method
getConnectionParameters
()
provider/provider_config/snowflake_config.go:89
↓ 1 callers
Method
getDFArgs
(outputURI string, code string, mapping []SourceMapping, sources []string)
provider/k8s.go:780
↓ 1 callers
Function
getDatabricksOfflineStore
func getSparkOfflineStore(t *testing.T) (*SparkOfflineStore, error) { err := godotenv.Load("../.env") if err != nil { fmt.Println(err) } emrConf
provider/spark_test.go:1532
↓ 1 callers
Method
getDefaultCredentials
()
backup/providers.go:190
↓ 1 callers
Method
getEntityValue
(feature, variant, entity string)
provider/blob_online.go:178
↓ 1 callers
Method
getEntityValues
(ctx context.Context, entities []string, featureTable provider.OnlineStoreTable)
serving/features.go:234
↓ 1 callers
Method
getErrorMessage
(jobId int64)
provider/spark.go:539
↓ 1 callers
Method
getFeatureRows
(ctx context.Context, features []*pb.FeatureID, entityMap map[string][]string)
serving/features.go:24
↓ 1 callers
Method
getFeatureValues
(ctx context.Context, name, variant string, entityMap map[string][]string)
serving/features.go:90
↓ 1 callers
Method
getFileWriter
(path filestore.Filepath)
provider/filestore.go:541
↓ 1 callers
Method
getGenericCommand
(args string)
provider/spark.go:991
↓ 1 callers
Method
getHealthCheckCSVBytes
()
provider/spark.go:837
↓ 1 callers
Function
getImportSourcePath
(t *testing.T, offlineStore OfflineStore, materializationID MaterializationID)
provider/table_import_test.go:245
↓ 1 callers
Function
getInputs
(variant *metadata.SourceVariant)
metadata/dashboard/dashboard_metadata.go:291
↓ 1 callers
Method
getJob
(mtx *concurrency.Mutex, key string)
coordinator/coordinator.go:1055
↓ 1 callers
Method
getLastValueBefore
(entity string, ts time.Time)
provider/offline.go:879
↓ 1 callers
Method
getLogFileMessage
(logFile string)
provider/spark.go:1266
↓ 1 callers
Method
getMoreRecentFile
(newObj *blob.ListObject, expectedFileType filestore.FileType, oldTime time.Time, oldKey string)
provider/filestore.go:804
↓ 1 callers
Method
getNonNullRecords
(rec GenericRecord)
provider/bigquery.go:158
↓ 1 callers
Method
getNumRowsQuery
(tableName string)
provider/bigquery.go:53
↓ 1 callers
Method
getOfflineResourceLocation
(ctx context.Context, name, variant string, resourceType int32)
serving/serving.go:645
↓ 1 callers
Function
getOfflineStore
(t *testing.T, providerName pt.Type, config pc.SerializedConfig)
coordinator/coordinator_test.go:955
↓ 1 callers
Method
getOnlineResourceLocation
(ctx context.Context, name, variant string, resourceType int32)
serving/serving.go:688
← previous
next →
1,401–1,500 of 5,008, ranked by callers