Merge remote-tracking branch 'origin/feature/feature-store-marketplace-operator' into feature/feature-store-marketplace-operator

Author: harsh97

ads/feature_store/docs/source/feature_group.rst

@@ -145,6 +145,28 @@ The ``.materialise_stream()`` method takes the following parameter:
     - ``write_options``: Extra write options for Spark as key-value pairs.
         - Defaults to ``{}``.
 
+.. code-block:: python3
+
+  from ads.feature_store.feature_group import FeatureGroup
+
+  from ads.feature_store.common.spark_session_singleton import SparkSessionSingleton
+  from pyspark.sql.types import StructType
+
+  # Get the spark session managed by the feature store
+  spark = SparkSessionSingleton(metastore_id=metastore_id).get_spark_session()
+
+  df = spark.readStream \
+    .option("sep", ",") \
+    .option("header", True) \
+    .csv(f"{stream_data_dir}/")
+
+  feature_group = FeatureGroup.from_id("<unique_id>")
+
+  query = fg.materialise_stream(input_dataframe=df, checkpoint_dir=f"{stream_data_dir}chec")
+
+  query.awaitTermination()
+
+
 .. seealso::
    :ref:`Feature Group Job`
 

ads/feature_store/docs/source/notebook.rst

@@ -49,6 +49,23 @@ Big data operations using OCI DataFlow
       - | * Ingestion of data using Spark Magic.
         | * Querying and exploration of data using Spark Magic.
 
+Streaming operations using Spark Streaming
+##########################################
+
+.. admonition:: Notebook Examples
+  :class: note
+
+  .. list-table::
+    :widths: 50 50
+    :header-rows: 1
+
+    * - Jupyter Notebook
+      - Description
+
+    * - `Streaming operations with feature store <https://github.com/oracle-samples/oci-data-science-ai-samples/blob/main/notebook_examples/feature_store_streaming_data_frame.ipynb>`__
+      - | * Ingestion of data using spark streaming.
+        | * Modes of ingestion: ``COMPLETE`` and ``APPEND``.
+
 LLM Use cases
 #############