Functions — github.com/featureform/featureform

hub / github.com/featureform/featureform / functions

Functions5,008 in github.com/featureform/featureform

⨍ Functions 5,008◇ Types & classes 913↳ Endpoints 59

↓ 1 callersMethodgetOrCacheFeatureMetadata

(ctx context.Context, name, variant string)

serving/features.go:124

↓ 1 callersMethodgetOrCacheFeatureProvider

(ctx context.Context, meta *metadata.FeatureVariant)

serving/features.go:176

↓ 1 callersFunctiongetPodLogs

(namespace string, name string)

kubernetes/kubernetes.go:238

↓ 1 callersMethodgetPrecomputedValues

(ctx context.Context, entityMap map[string][]string, meta *metadata.FeatureVariant)

serving/features.go:146

↓ 1 callersFunctiongetResourceType

(resourceTypeString string)

metadata/dashboard/dashboard_metadata.go:1395

↓ 1 callersFunctiongetSourceArgs

(variant *SourceVariant)

metadata/metadata.go:2154

↓ 1 callersFunctiongetSourceArgs

(variant *metadata.SourceVariant)

metadata/dashboard/dashboard_metadata.go:321

↓ 1 callersMethodgetSourceDataIterator

(name, variant string, limit int64)

metadata/dashboard/dashboard_metadata.go:1275

↓ 1 callersFunctiongetSourceString

(variant *SourceVariant)

metadata/metadata.go:2136

↓ 1 callersFunctiongetSourceString

(variant *metadata.SourceVariant)

metadata/dashboard/dashboard_metadata.go:301

↓ 1 callersFunctiongetSourceType

(variant *SourceVariant)

metadata/metadata.go:2144

↓ 1 callersFunctiongetSourceType

(variant *metadata.SourceVariant)

metadata/dashboard/dashboard_metadata.go:311

↓ 1 callersFunctiongetSourceVariant

()

metadata/metadata_test.go:2002

↓ 1 callersMethodgetSources

TODO: _possibly_ delete this method in favor of Filepath methods

provider/spark.go:1591

↓ 1 callersMethodgetStepErrorMessage

(clusterId string, stepId string)

provider/spark.go:1227

↓ 1 callersMethodgetTableForReadyIndex

(indexName, feature, variant string)

provider/pinecone.go:124

↓ 1 callersMethodgetTrainingSetIterator

(name, variant string)

serving/serving.go:282

↓ 1 callersMethodgetTrainingSetTestSplitIterator

(name, variant string, testSize float32, shuffle bool, randomState int)

serving/serving.go:308

↓ 1 callersMethodgetValueColumnTypes

(table string)

provider/sql.go:1060

↓ 1 callersMethodgetValueColumnTypes

(tb string)

provider/clickhouse.go:409

↓ 1 callersMethodgetValueIndex

getValueIndex returns the index of the value column in the schema. Returns -1 if an entity column is not found

provider/sql.go:383

↓ 1 callersMethodgetValueIndex

(columns []TableColumn)

provider/bigquery.go:990

↓ 1 callersMethodgetValueIndex

(columns []TableColumn)

provider/clickhouse.go:147

↓ 1 callersMethodgetVectorTable

(ctx context.Context, fv *metadata.FeatureVariant)

serving/serving.go:593

↓ 1 callersMethodget_bigquery

Get a BigQuery provider. The returned object can be used to register additional resources. **Examples**: ``` py bigquery = ff

client/src/featureform/register.py:1961

↓ 1 callersMethodget_blob_store

Get an Azure Blob provider. The returned object can be used to register additional resources. **Examples**: ``` py azure_blob

client/src/featureform/register.py:1766

↓ 1 callersMethodget_clickhouse

Get a ClickHouse provider. The returned object can be used to register additional resources. **Examples**: ``` py clickhouse

client/src/featureform/register.py:1833

↓ 1 callersMethodget_client

(self)

provider/scripts/k8s/offline_store_pandas_runner.py:39

↓ 1 callersMethodget_client_objects_for_resource

(self)

client/src/featureform/register.py:1478

↓ 1 callersFunctionget_code_from_file

Reads the code from a pkl file into a python code object. Then this object will be used to execute the transformation. Parameters:

provider/scripts/k8s/offline_store_pandas_runner.py:371

↓ 1 callersFunctionget_code_from_file

(file_path, store_type=None, credentials=None)

provider/scripts/spark/offline_store_spark_runner.py:469

↓ 1 callersFunctionget_entity_info

(stub, name)

client/src/featureform/get.py:29

↓ 1 callersMethodget_feature

(self, name, variant)

client/src/featureform/register.py:4383

↓ 1 callersFunctionget_feature_variant_info

(stub, name, variant)

client/src/featureform/get.py:91

↓ 1 callersFunctionget_file_rows

(local_file_name, filetype)

tests/end_to_end/features/steps/filestore_upload.py:76

↓ 1 callersFunctionget_filename_and_uri

(filesize, filetype)

tests/end_to_end/features/steps/filestore_upload.py:19

↓ 1 callersMethodget_gcs

(self, name)

client/src/featureform/register.py:2088

↓ 1 callersMethodget_kubernetes

Get a k8s provider. The returned object can be used to register additional resources. **Examples**: ``` py k8s = ff

client/src/featureform/register.py:2022

↓ 1 callersMethodget_label

(self, name, variant)

client/src/featureform/register.py:4503

↓ 1 callersFunctionget_label_variant_info

(stub, name, variant)

client/src/featureform/get.py:122

↓ 1 callersMethodget_mongodb

Get a MongoDB provider. The returned object can be used to register additional resources. **Examples**: ``` py mongodb = ff.g

client/src/featureform/register.py:1735

↓ 1 callersFunctionget_numpy_array_type

(types)

client/src/featureform/serving.py:1054

↓ 1 callersFunctionget_provider_info

(stub, name)

client/src/featureform/get.py:227

↓ 1 callersFunctionget_random_string

()

tests/end_to_end/dontrun/spark_generic_hdfs_definitions.py:15

↓ 1 callersFunctionget_random_string

()

tests/end_to_end/definitions/kcf_s3_definition.py:16

↓ 1 callersFunctionget_random_string

()

tests/end_to_end/definitions/spark_generic_gcs_definitions.py:15

↓ 1 callersFunctionget_random_string

()

tests/end_to_end/definitions/spark_emr_s3_definitions.py:15

↓ 1 callersFunctionget_random_string

()

tests/end_to_end/definitions/ondemand_features_definitions.py:15

↓ 1 callersFunctionget_random_string

()

tests/end_to_end/definitions/spark_generic_s3_definitions.py:15

↓ 1 callersFunctionget_random_string

()

tests/end_to_end/definitions/spark_generic_azure_definitions.py:15

↓ 1 callersFunctionget_random_string

()

tests/end_to_end/definitions/kcf_custom_image_definitions.py:16

↓ 1 callersFunctionget_random_string

()

tests/end_to_end/definitions/spark_chained_transformations_definitions.py:15

↓ 1 callersFunctionget_random_string

()

tests/end_to_end/definitions/spark_databricks_azure_definitions.py:15

↓ 1 callersFunctionget_random_string

()

tests/end_to_end/definitions/lag_features_definition.py:14

↓ 1 callersFunctionget_random_string

()

tests/end_to_end/databricks/databricks.py:12

↓ 1 callersMethodget_redshift

Get a Redshift provider. The returned object can be used to register additional resources. **Examples**: ``` py redshift = ff

client/src/featureform/register.py:1933

↓ 1 callersMethodget_resources

(self)

client/src/featureform/register.py:1481

↓ 1 callersMethodget_s3

Get a S3 provider. The returned object can be used with other providers such as Spark and Databricks. **Examples**: ``` py

client/src/featureform/register.py:2050

↓ 1 callersMethodget_snowflake

Get a Snowflake provider. The returned object can be used to register additional resources. **Examples**: ``` py snowflake =

client/src/featureform/register.py:1866

↓ 1 callersMethodget_snowflake_legacy

Get a Snowflake provider. The returned object can be used to register additional resources. **Examples**: ``` py snowflake =

client/src/featureform/register.py:1899

↓ 1 callersMethodget_source

(self, name, variant)

client/src/featureform/register.py:4736

↓ 1 callersFunctionget_source_variant_info

(stub, name, variant)

client/src/featureform/get.py:153

↓ 1 callersMethodget_spark

Get a Spark provider. The returned object can be used to register additional resources. **Examples**: ``` py spark = ff.get_s

client/src/featureform/register.py:1994

↓ 1 callersMethodget_status

(self)

client/src/featureform/resources.py:1470

↓ 1 callersFunctionget_training_set_variant_info

(stub, name, variant)

client/src/featureform/get.py:198

↓ 1 callersFunctionget_user_info

(stub, name)

client/src/featureform/get.py:7

↓ 1 callersFunctionget_version_hosted

(host)

client/src/featureform/tls.py:59

↓ 1 callersFunctiongroupByDateTimeDirectory

(files []Filepath)

filestore/filepath.go:511

↓ 1 callersMethodhandleFinishedIterator

( stream pb.Feature_TrainingTestSplitServer, reqType pb.RequestType, isTestFinished *bool, isTrainFinished

serving/serving.go:213

↓ 1 callersFunctionhandleNewTag

(event)

dashboard/src/components/entitypage/elements/TagBox.js:44

↓ 1 callersMethodhandleNoOnlineStore

()

runner/materialize.go:231

↓ 1 callersFunctionhandleSearch

(event)

dashboard/src/components/search/SearchBar.js:73

↓ 1 callersMethodhandleSplitDataRequest

( stream pb.Feature_TrainingTestSplitServer, req *pb.TrainingTestSplitRequest, trainIterator *provider.Trai

serving/serving.go:164

↓ 1 callersMethodhandleSplitInitializeRequest

( stream pb.Feature_TrainingTestSplitServer, req *pb.TrainingTestSplitRequest, trainIterator *provider.Trai

serving/serving.go:123

↓ 1 callersFunctionhandleStatusBtnSelect

(statusType = STATUS_ALL)

dashboard/src/components/tasks/tableDataWrapper.js:39

↓ 1 callersFunctionhealthCheck

(client *ms.Client)

metadata/search/search.go:55

↓ 1 callersMethodid

(self)

client/src/featureform/register.py:583

↓ 1 callersMethodincrementJobAttempts

(mtx *concurrency.Mutex, job *metadata.CoordinatorJob, jobKey string)

coordinator/coordinator.go:1079

↓ 1 callersFunctioninit

()

provider/k8s.go:164

↓ 1 callersFunctioninitClient

(t *testing.T, addr string)

health/health_test.go:190

↓ 1 callersFunctioninitMetadataServer

(t *testing.T)

health/health_test.go:167

↓ 1 callersFunctioninitSpark

(t *testing.T, executorType pc.SparkExecutorType, storeType fs.FileStoreType)

health/health_test.go:207

↓ 1 callersMethodinitializeCollection

()

metadata/search/search.go:100

↓ 1 callersMethodinitializeFeatureProvider

(ctx context.Context, meta *metadata.FeatureVariant)

serving/features.go:189

↓ 1 callersFunctioninitializeResourceTablesForTrainingSet

training set helper functions

coordinator/scheduletest/main.go:237

↓ 1 callersFunctioninitializeTestingEnvironment

()

coordinator/scheduletest/main.go:119

↓ 1 callersFunctioninvalidFeatureRecords

()

serving/serving_test.go:71

↓ 1 callersFunctioninvalidLabelRecords

()

serving/serving_test.go:94

↓ 1 callersFunctioninvalidTypeFeatureRecords

()

serving/serving_test.go:117

↓ 1 callersMethodisEquivalent

(newRes Resource, existing Resource)

metadata/metadata.go:1943

↓ 1 callersMethodisMoreRecentFile

(newFileTime, oldFileTime time.Time, fileType filestore.FileType, path string)

provider/filestore.go:658

↓ 1 callersMethodisMostRecentFile

(listObj *blob.ListObject, time time.Time)

provider/filestore.go:863

↓ 1 callersMethodisPartialPath

(prefix, path string)

provider/filestore.go:650

↓ 1 callersMethodisPrimaryData

()

metadata/client.go:708

↓ 1 callersMethodisPrimaryData

()

metadata/client.go:2161

↓ 1 callersFunctionisResourceReady

isResourceReady checks if a Resource's status is 'ready'.

metadata/metadata.go:1822

↓ 1 callersFunctionisSourceProtoDefinitionEqual

(thisDef, otherDef *pb.SourceVariant_Transformation)

metadata/metadata.go:521

↓ 1 callersFunctionisValidFirestoreConfigUpdate

(sa, sb pc.SerializedConfig)

metadata/provider.go:53

↓ 1 callersFunctionisValidResponse

(resources, hasVariants)

dashboard/src/components/resource-list/ResourceSlice.js:9

↓ 1 callersMethodis_empty

(self)

client/src/featureform/resources.py:1873

← previous next →1,501–1,600 of 5,008, ranked by callers