Package com.c12e.cortex.profiles.context

Class BaseCortexContext

java.lang.Object

com.c12e.cortex.profiles.context.BaseCortexContext

All Implemented Interfaces:

CortexContext

public class BaseCortexContext
extends java.lang.Object
implements CortexContext

Default CortexContext, holds the context information for a CortexSession

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BaseCortexContext(org.apache.spark.sql.SparkSession sparkSession, CortexVersionStore cortexVersionStore, CortexSparkReader cortexSparkReader, CortexSparkWriter cortexSparkWriter, com.c12e.cortex.phoenix.Catalog catalog, CortexSparkStreamReader cortexSparkStreamReader, CortexSparkStreamWriter cortexSparkStreamWriter, CortexJobRegistry cortexJobRegistry, FeatureCatalog featureCatalog, CortexAuthContext cortexAuthContext, com.c12e.cortex.phoenix.ProfileEngine profileEngine)

Method Summary

Modifier and Type	Method	Description
protected void	checkCompatibility(org.apache.spark.sql.SparkSession sparkSession)
CortexAuthContext	getAuthContext()	The session's auth context
com.c12e.cortex.phoenix.Catalog	getCortexCatalog()	The Cortex catalog instance
CortexJobRegistry	getCortexJobRegistry()	The session's job registry
CortexSparkReader	getCortexSparkReader()	The spark integrated Cortex reader instance
CortexSparkStreamReader	getCortexSparkStreamReader()	The spark integrated Cortex stream reader instance
CortexSparkStreamWriter	getCortexSparkStreamWriter()	The spark integrated Cortex stream writer instance
CortexSparkWriter	getCortexSparkWriter()	The spark integrated Cortex writer instance
CortexVersionStore	getCortexVersionStore()	Supported versions instance
FeatureCatalog	getFeatureCatalog()	The Cortex FeatureCatalog instance.
com.c12e.cortex.phoenix.ProfileEngine	getProfileEngine()	The profile engine
org.apache.spark.sql.SparkSession	getSparkSession()	Spark session instance

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BaseCortexContext

@Inject
protected BaseCortexContext(org.apache.spark.sql.SparkSession sparkSession,
                            CortexVersionStore cortexVersionStore,
                            CortexSparkReader cortexSparkReader,
                            CortexSparkWriter cortexSparkWriter,
                            com.c12e.cortex.phoenix.Catalog catalog,
                            CortexSparkStreamReader cortexSparkStreamReader,
                            CortexSparkStreamWriter cortexSparkStreamWriter,
                            CortexJobRegistry cortexJobRegistry,
                            FeatureCatalog featureCatalog,
                            CortexAuthContext cortexAuthContext,
                            com.c12e.cortex.phoenix.ProfileEngine profileEngine)

Method Detail

checkCompatibility

protected void checkCompatibility(org.apache.spark.sql.SparkSession sparkSession)

getSparkSession

public org.apache.spark.sql.SparkSession getSparkSession()

Description copied from interface: CortexContext

Spark session instance

Specified by:

getSparkSession in interface CortexContext

Returns:

getCortexVersionStore

public CortexVersionStore getCortexVersionStore()

Description copied from interface: CortexContext

Supported versions instance

Specified by:

getCortexVersionStore in interface CortexContext

Returns:

getCortexSparkReader

public CortexSparkReader getCortexSparkReader()

Description copied from interface: CortexContext

The spark integrated Cortex reader instance

Specified by:

getCortexSparkReader in interface CortexContext

Returns:

getCortexSparkWriter

public CortexSparkWriter getCortexSparkWriter()

Description copied from interface: CortexContext

The spark integrated Cortex writer instance

Specified by:

getCortexSparkWriter in interface CortexContext

Returns:

getCortexSparkStreamReader

public CortexSparkStreamReader getCortexSparkStreamReader()

Description copied from interface: CortexContext

The spark integrated Cortex stream reader instance

Specified by:

getCortexSparkStreamReader in interface CortexContext

Returns:

getCortexSparkStreamWriter

public CortexSparkStreamWriter getCortexSparkStreamWriter()

Description copied from interface: CortexContext

The spark integrated Cortex stream writer instance

Specified by:

getCortexSparkStreamWriter in interface CortexContext

Returns:

getCortexCatalog

public com.c12e.cortex.phoenix.Catalog getCortexCatalog()

Description copied from interface: CortexContext

The Cortex catalog instance

Specified by:

getCortexCatalog in interface CortexContext

Returns:

getFeatureCatalog

public FeatureCatalog getFeatureCatalog()

Description copied from interface: CortexContext

The Cortex FeatureCatalog instance.

Specified by:

getFeatureCatalog in interface CortexContext

Returns:

getAuthContext

public CortexAuthContext getAuthContext()

Description copied from interface: CortexContext

The session's auth context

Specified by:

getAuthContext in interface CortexContext

Returns:

getCortexJobRegistry

public CortexJobRegistry getCortexJobRegistry()

Description copied from interface: CortexContext

The session's job registry

Specified by:

getCortexJobRegistry in interface CortexContext

Returns:

getProfileEngine

public com.c12e.cortex.phoenix.ProfileEngine getProfileEngine()

Description copied from interface: CortexContext

The profile engine

Specified by:

getProfileEngine in interface CortexContext

Returns: