MCPcopy Create free account

hub / github.com/featureform/featureform / endpoints

Endpoints59 in github.com/featureform/featureform

Routeaverage_daily_transaction
spark.df_transformation( inputs=[("total_paid_per_customer_per_day", "default")], variant="default" )
tests/end_to_end/databricks/databricks.py:None
Routeaverage_user_transaction
provider.df_transformation( variant="quickstart", inputs=[("transactions", "quickstart")]
client/tests/test_serving_model.py:None
Routeaverage_user_transaction
provider.df_transformation( variant="quickstart", inputs=[("transactions", "quickstart")]
client/tests/test_source_dataframe.py:None
Routeaverage_user_transaction
provider.df_transformation( variant="quickstart", inputs=[("transactions", "quickstart")]
client/tests/test_resource_registration.py:None
Routeaverage_user_transaction
postgres.sql_transformation(variant="quickstart")
client/tests/quickstart.py:None
Routeaverage_user_transaction
provider.df_transformation( variant="quickstart", inputs=[("transactions", "quickstart")]
client/tests/test_class_api.py:None
Routeaverage_user_transaction
provider.df_transformation( variant="quickstart", inputs=[("transactions", "quickstart")]
client/tests/test_training_set_dataframe.py:None
Routeaverage_user_transaction
provider.df_transformation( variant="quickstart", inputs=[("transactions", "quickstart")]
client/tests/test_search.py:None
Routeaverage_user_transaction
provider.df_transformation( variant="quickstart", inputs=[("transactions", "quickstart")]
client/tests/test_tags_and_properties.py:None
Routeaverage_user_transaction
local.df_transformation(inputs=["transactions"])
client/examples/local_quickstart.py:None
Routeaverage_user_transaction
local_provider_get.df_transformation( variant="quickstart", inputs=[("transactions", "quickstart")] )
client/examples/local_quickstart_get.py:None
Routeaverage_user_transaction
postgres_get.sql_transformation(variant="quickstart")
client/examples/quickstart_get.py:None
Routeaverage_user_transaction_v1
provider.df_transformation( variant=variant, inputs=[("transactions", "quickstart")],
client/tests/test_tags_and_properties.py:None
Routeaverage_user_transaction_v2
provider.df_transformation( variant=variant, inputs=[("transactions", "quickstart")],
client/tests/test_tags_and_properties.py:None
Routeaverage_user_transactions
postgres.sql_transformation(variant="quickstart")
client/examples/quickstart.py:None
Routeget_month_1_customer_spend
spark.sql_transformation( name="get_month_1_customer_spend", variant="default", description="Get m
tests/end_to_end/databricks/databricks.py:None
Routeget_month_6_customer_spend
spark.sql_transformation( name="get_month_6_customer_spend", variant="default", description="Get m
tests/end_to_end/databricks/databricks.py:None
Routeice_cream_chained_transformation
spark.df_transformation( name=f"ice_cream_chained_transformation_{VERSION}", variant=VERSION, inpu
tests/end_to_end/definitions/spark_chained_transformations_definitions.py:None
Routeice_cream_entity_transformation
k8s.df_transformation( name=f"ice_cream_entity_{VERSION}", variant=VERSION, inputs=[ice_cream] )
tests/end_to_end/definitions/kcf_s3_definition.py:None
Routeice_cream_entity_transformation
k8s.df_transformation( name=f"ice_cream_entity_{VERSION}", variant=VERSION, inputs=[ice_cream] )
tests/end_to_end/definitions/kcf_custom_image_definitions.py:None
Routeice_cream_entity_transformation
k8s.df_transformation( name=f"ice_cream_entity_{VERSION}", variant=VERSION, inputs=[(f"ice_cream_{
tests/end_to_end/definitions/lag_features_definition.py:None
Routeice_cream_transformation
spark.df_transformation( name=f"ice_cream_transformation_{VERSION}", variant=VERSION, inputs=[(f"i
tests/end_to_end/dontrun/spark_generic_hdfs_definitions.py:None
Routeice_cream_transformation
spark.df_transformation( name=f"ice_cream_transformation_{VERSION}", variant=VERSION, inputs=[(f"i
tests/end_to_end/definitions/spark_generic_gcs_definitions.py:None
Routeice_cream_transformation
spark.df_transformation( name=f"ice_cream_transformation_{VERSION}", variant=VERSION, inputs=[(f"i
tests/end_to_end/definitions/spark_emr_s3_definitions.py:None
Routeice_cream_transformation
spark.df_transformation( name=f"ice_cream_transformation_{VERSION}", variant=VERSION, inputs=[ice_
tests/end_to_end/definitions/ondemand_features_definitions.py:None
Routeice_cream_transformation
spark.df_transformation( name=f"ice_cream_transformation_{VERSION}", variant=VERSION, inputs=[(f"i
tests/end_to_end/definitions/spark_generic_s3_definitions.py:None
Routeice_cream_transformation
spark.df_transformation( name=f"ice_cream_transformation_{VERSION}", variant=VERSION, inputs=[(f"i
tests/end_to_end/definitions/spark_generic_azure_definitions.py:None
Routeice_cream_transformation
spark.df_transformation( name=f"ice_cream_transformation_{VERSION}", variant=VERSION, inputs=[(f"i
tests/end_to_end/definitions/spark_databricks_azure_definitions.py:None
Routeice_cream_transformation
k8s.df_transformation( name=f"ice_cream_transformation_{VERSION}", variant=VERSION, inputs=[(f"ice
tests/end_to_end/definitions/lag_features_definition.py:None
Routemock_transform
k8s.df_transformation( owner="mock-owner", docker_image=image, inputs=[("df", "var")] )
client/tests/resources_test.py:None
Routeordering_transformation_1
k8s.df_transformation(variant=VERSION, inputs=[ice_cream])
tests/end_to_end/definitions/kcf_s3_definition.py:None
Routeordering_transformation_2
k8s.df_transformation(variant=VERSION, inputs=[ice_cream])
tests/end_to_end/definitions/kcf_s3_definition.py:None
Routeordering_transformation_3
k8s.df_transformation(variant=VERSION, inputs=[ice_cream])
tests/end_to_end/definitions/kcf_s3_definition.py:None
Routereviews_by_order
spark.sql_transformation( name="reviews_by_order", variant="default", description="get reviews by order" )
tests/end_to_end/databricks/databricks.py:None
Routescikit_test
k8s.df_transformation( name=f"ice_cream_transformation_{VERSION}", variant=VERSION, inputs=[(f"ice
tests/end_to_end/definitions/kcf_custom_image_definitions.py:None
Routesome_function
registrar.df_transformation( name="test", owner="default_user", provider="", i
client/tests/test_autogenerated_variants.py:None
Routesome_transformation
context.spark.df_transformation( name=name, inputs=source_list, )
tests/end_to_end/features/steps/spark_registeration.py:None
Routestep_impl
when('I get the provider with name "{name}"')
tests/end_to_end/features/steps/get.py:None
Routestep_impl
when("I register postgres")
tests/end_to_end/features/steps/multifeature_registration.py:None
Routestep_impl
then("I can get a list containing the entity name and a tuple with all the features")
tests/end_to_end/features/steps/serving.py:None
Routetest_check_feature_type
pytest.mark.parametrize( "test_input,expected", [ ([("name", "variant")], [("name", "variant")
client/tests/serving_test.py:None
Routetest_clean_name
pytest.mark.parametrize( "input_str, expected_str", [ ("column1", "column1"), ('"colum
client/tests/test_multi_feature.py:None
Routetest_df_transformation
pytest.mark.parametrize( "name,variant,inputs,transformation", [ ("test_input", "primary_datas
client/tests/test_spark_provider.py:None
Routetest_execute_df_job
pytest.mark.parametrize( "variables,expected_output", [ ( "local_df_variables_succ
provider/scripts/k8s/tests/test_offline_store_pandas_runner.py:None
Routetest_execute_df_job
pytest.mark.parametrize( "arguments,expected_output", [ ("df_local_all_arguments", f"{dir_path
provider/scripts/spark/tests/test_offline_store_spark_runner.py:None
Routetest_execute_sql_job
pytest.mark.parametrize( "variables,expected_output", [ ( "local_variables_success
provider/scripts/k8s/tests/test_offline_store_pandas_runner.py:None
Routetest_execute_sql_query
pytest.mark.parametrize( "arguments,expected_output", [ ("sql_local_all_arguments", f"{dir_pat
provider/scripts/spark/tests/test_offline_store_spark_runner.py:None
Routetest_get_snowflake_functions
pytest.mark.parametrize( "provider_name,func", [("snowflake", ff.get_snowflake), ("snowflake_legacy",
client/tests/register_test.py:None
Routetest_get_spark_dataframe
pytest.mark.parametrize( "location,format", [ ("client/tests/test_files/input_files/transactio
client/tests/serving_test.py:None
Routetest_modify_column_name
pytest.mark.parametrize( "input_str, has_quotes, expected_str", [ ("column1", True, '"column1"
client/tests/test_multi_feature.py:None
Routetest_ordering
k8s.df_transformation( variant=VERSION, inputs=[ ordering_transformation_1, ordering_t
tests/end_to_end/definitions/kcf_s3_definition.py:None
Routetest_register_file
pytest.mark.parametrize( "test_name,file_path", [ ("file", "abfss://test_files/input/transacti
client/tests/test_spark_provider.py:None
Routetest_row_to_numpy
mock.patch( "featureform.serving.parse_proto_value", mock.MagicMock(side_effect=side_effect) )
client/tests/serving_test.py:None
Routetest_sql_transformation_inputs_error
pytest.mark.parametrize( "fn, inputs, error_message", [ ( lambda arg1, arg2, arg3:
client/tests/register_test.py:None
Routetest_sql_transformation_inputs_valid
pytest.mark.parametrize( "sql_query, expected_query, inputs", [ ( "SELECT * FROM {
client/tests/register_test.py:None
Routetest_valid_feature_column_types
pytest.mark.parametrize( "input,fail", [ ("int", False), ("int32", False), ("i
client/tests/resources_test.py:None
Routetest_valid_label_column_types
pytest.mark.parametrize( "input,fail", [ ("int", False), ("int32", False), ("i
client/tests/resources_test.py:None
Routetotal_paid_per_customer_per_day
spark.sql_transformation( name="total_paid_per_customer_per_day", variant="default", description="
tests/end_to_end/databricks/databricks.py:None
Routetotal_paid_per_day
spark.sql_transformation( name="total_paid_per_day", variant="default", description="Get the daily
tests/end_to_end/databricks/databricks.py:None