Ingestion to Online Feature Store

import hsfs
connection = hsfs.connection()
fs = connection.get_feature_store()
from hops import hdfs
from pyspark.sql import functions as F

stores_csv = spark.read\
             .option("inferSchema", "true")\
             .option("header", "true")\
             .format("csv")\
             .load("hdfs:///Projects/{}/Jupyter/hsfs/archive/stores data-set.csv".format(hdfs.project_name()))
online_store_fg_meta = fs.create_feature_group(name="online_store_fg",
                                       version=1,
                                       primary_key=['store'],
                                       description="Store related features",
                                       online_enabled=True,
                                       time_travel_format=None,
                                       statistics_config={"enabled": True, "histograms": True, "correlations": True})
online_store_fg_meta.save(stores_csv)