Package com.c12e.cortex.profiles.context
Interface CortexContext
-
- All Known Implementing Classes:
BaseCortexContext
public interface CortexContext
Holds the context information for a CortexSession
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description CortexAuthContext
getAuthContext()
The session's auth contextcom.c12e.cortex.phoenix.Catalog
getCortexCatalog()
The Cortex catalog instanceCortexJobRegistry
getCortexJobRegistry()
The session's job registryCortexSparkReader
getCortexSparkReader()
The spark integrated Cortex reader instanceCortexSparkStreamReader
getCortexSparkStreamReader()
The spark integrated Cortex stream reader instanceCortexSparkStreamWriter
getCortexSparkStreamWriter()
The spark integrated Cortex stream writer instanceCortexSparkWriter
getCortexSparkWriter()
The spark integrated Cortex writer instanceCortexVersionStore
getCortexVersionStore()
Supported versions instanceFeatureCatalog
getFeatureCatalog()
The Cortex FeatureCatalog instance.com.c12e.cortex.phoenix.ProfileEngine
getProfileEngine()
The profile engineorg.apache.spark.sql.SparkSession
getSparkSession()
Spark session instance
-
-
-
Method Detail
-
getSparkSession
org.apache.spark.sql.SparkSession getSparkSession()
Spark session instance- Returns:
-
getCortexVersionStore
CortexVersionStore getCortexVersionStore()
Supported versions instance- Returns:
-
getCortexSparkReader
CortexSparkReader getCortexSparkReader()
The spark integrated Cortex reader instance- Returns:
-
getCortexSparkWriter
CortexSparkWriter getCortexSparkWriter()
The spark integrated Cortex writer instance- Returns:
-
getCortexCatalog
com.c12e.cortex.phoenix.Catalog getCortexCatalog()
The Cortex catalog instance- Returns:
-
getFeatureCatalog
FeatureCatalog getFeatureCatalog()
The Cortex FeatureCatalog instance.- Returns:
-
getCortexSparkStreamReader
CortexSparkStreamReader getCortexSparkStreamReader()
The spark integrated Cortex stream reader instance- Returns:
-
getCortexSparkStreamWriter
CortexSparkStreamWriter getCortexSparkStreamWriter()
The spark integrated Cortex stream writer instance- Returns:
-
getAuthContext
CortexAuthContext getAuthContext()
The session's auth context- Returns:
-
getCortexJobRegistry
CortexJobRegistry getCortexJobRegistry()
The session's job registry- Returns:
-
getProfileEngine
com.c12e.cortex.phoenix.ProfileEngine getProfileEngine()
The profile engine- Returns:
-
-