A B C D E F G H I J L M N O P Q R S T U V W
All Classes All Packages

A

addToPlan(String, String, String) - Method in class com.c12e.cortex.profiles.intercept.GraphPlan

Pop on method exit

agentmain(String, Instrumentation) - Static method in class com.c12e.cortex.profiles.module.connection.jdbc.JvmClasspathAgent

AMP_BUCKET - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

AMP_BUCKET_JSON_PATH - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

AMP_BUCKET_PROP - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

ANONYMOUS - Static variable in class com.c12e.cortex.profiles.auth.CortexAuthContext

Default user

appendJarFile(JarFile) - Static method in class com.c12e.cortex.profiles.module.connection.jdbc.JvmClasspathAgent

Application - Class in com.c12e.cortex.profiles.cli

CLI application entrypoint for interacting with profiles, data sources, and feature catalog resources.

Application() - Constructor for class com.c12e.cortex.profiles.cli.Application

ArrayFeatureBuilder - Class in com.c12e.cortex.profiles.featurecatalog.featurebuilder

Implementation of a BaseFeatureBuilder for handling general Array types by wrapping an existing FeatureBuilder.

ArrayFeatureBuilder(FeatureBuilder) - Constructor for class com.c12e.cortex.profiles.featurecatalog.featurebuilder.ArrayFeatureBuilder

Creates the ArrayFeatureBuilder.

ASSUME_AWS_IAM - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

ASSUME_AWS_IAM_JSON_PATH - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

ASSUME_AWS_IAM_PROP - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

AWS_ACCESS_KEY_ID - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

AWS_ACCESS_KEY_ID_JSON_PATH - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

AWS_ACCESS_KEY_ID_PROP - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

AWS_REGION - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

AWS_REGION_JSON_PATH - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

AWS_REGION_PROP - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

AWS_SECRET_KEY - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

AWS_SECRET_KEY_JSON_PATH - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

AWS_SECRET_KEY_PROP - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

B

BaseCortexContext - Class in com.c12e.cortex.profiles.context

Default CortexContext, holds the context information for a CortexSession

BaseCortexContext(SparkSession, CortexVersionStore, CortexSparkReader, CortexSparkWriter, Catalog, CortexSparkStreamReader, CortexSparkStreamWriter, CortexJobRegistry, FeatureCatalog, CortexAuthContext, ProfileEngine) - Constructor for class com.c12e.cortex.profiles.context.BaseCortexContext

BaseFeatureBuilder - Class in com.c12e.cortex.profiles.featurecatalog.featurebuilder

Base implementation of a FeatureBuilder that provides setters for Feature attributes, and

BaseFeatureBuilder() - Constructor for class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

build() - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

build() - Method in interface com.c12e.cortex.profiles.featurecatalog.featurebuilder.FeatureBuilder

Build and creates an instantiated Feature instance.

buildProfile(String, String, CortexContext) - Method in interface com.c12e.cortex.profiles.module.job.CortexJobRegistry

Creates an instance of the BuildProfileJob to run with the supplied parameters

buildProfile(String, String, CortexContext) - Method in class com.c12e.cortex.profiles.module.job.DefaultCortexJobRegistry

BuildProfileJob - Class in com.c12e.cortex.profiles.module.job

Job that builds a ProfileSchema

BuildProfileJob(String, String, CortexContext) - Constructor for class com.c12e.cortex.profiles.module.job.BuildProfileJob

Constructor

buildProfiles() - Method in class com.c12e.cortex.profiles.cli.ProfileCommand

buildProfileStream() - Method in class com.c12e.cortex.profiles.cli.ProfileCommand

C

catalog() - Method in interface com.c12e.cortex.profiles.CortexCatalogReaderWriter

catalog() - Method in class com.c12e.cortex.profiles.CortexSession

CATALOG_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

CDATA_CHECKSUM_SECRET - Static variable in interface com.c12e.cortex.profiles.module.connection.jdbc.JdbcSparkAdapter

CDATA_OEM_KEY_SECRET - Static variable in interface com.c12e.cortex.profiles.module.connection.jdbc.JdbcSparkAdapter

CDATA_SHARED_PROJECT - Static variable in interface com.c12e.cortex.profiles.module.connection.jdbc.JdbcSparkAdapter

checkCompatibility(SparkSession) - Method in class com.c12e.cortex.profiles.context.BaseCortexContext

checkDriverInClassPath(String) - Method in class com.c12e.cortex.profiles.module.connection.jdbc.DriverLoadingJdbcAdapter

checkDriverInClassPath(String) - Method in interface com.c12e.cortex.profiles.module.connection.jdbc.JdbcSparkAdapter

Checks if the JDBC driver is in the class path.

checkDriverInClassPath(String) - Method in class com.c12e.cortex.profiles.module.connection.jdbc.NonLoadingJdbcAdapter

classLoader - Variable in class com.c12e.cortex.profiles.CortexSession.CortexSessionModule

closeOldFileSystem(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

closeOldFileSystem(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader

com.c12e.cortex.profiles - package com.c12e.cortex.profiles

com.c12e.cortex.profiles.auth - package com.c12e.cortex.profiles.auth

com.c12e.cortex.profiles.catalog - package com.c12e.cortex.profiles.catalog

com.c12e.cortex.profiles.cli - package com.c12e.cortex.profiles.cli

com.c12e.cortex.profiles.client - package com.c12e.cortex.profiles.client

com.c12e.cortex.profiles.context - package com.c12e.cortex.profiles.context

com.c12e.cortex.profiles.featurecatalog - package com.c12e.cortex.profiles.featurecatalog

com.c12e.cortex.profiles.featurecatalog.featurebuilder - package com.c12e.cortex.profiles.featurecatalog.featurebuilder

com.c12e.cortex.profiles.intercept - package com.c12e.cortex.profiles.intercept

com.c12e.cortex.profiles.logging - package com.c12e.cortex.profiles.logging

com.c12e.cortex.profiles.module - package com.c12e.cortex.profiles.module

com.c12e.cortex.profiles.module.connection - package com.c12e.cortex.profiles.module.connection

com.c12e.cortex.profiles.module.connection.jdbc - package com.c12e.cortex.profiles.module.connection.jdbc

com.c12e.cortex.profiles.module.datasource - package com.c12e.cortex.profiles.module.datasource

com.c12e.cortex.profiles.module.job - package com.c12e.cortex.profiles.module.job

com.c12e.cortex.profiles.module.profile - package com.c12e.cortex.profiles.module.profile

com.c12e.cortex.profiles.reader - package com.c12e.cortex.profiles.reader

com.c12e.cortex.profiles.storage - package com.c12e.cortex.profiles.storage

com.c12e.cortex.profiles.streamReader - package com.c12e.cortex.profiles.streamReader

com.c12e.cortex.profiles.streamWriter - package com.c12e.cortex.profiles.streamWriter

com.c12e.cortex.profiles.validator - package com.c12e.cortex.profiles.validator

com.c12e.cortex.profiles.version - package com.c12e.cortex.profiles.version

com.c12e.cortex.profiles.writer - package com.c12e.cortex.profiles.writer

CommonOptionMixin - Class in com.c12e.cortex.profiles.cli

Mixin meant to store common options for CLI commands, namely the "-p"/"--project" flag and a catch-all List<String> args.

CommonOptionMixin() - Constructor for class com.c12e.cortex.profiles.cli.CommonOptionMixin

compactProfiles() - Method in class com.c12e.cortex.profiles.cli.ProfileCommand

compactSource() - Method in class com.c12e.cortex.profiles.cli.DataSourceCommand

computeDataSourceFeatures(String, String, Dataset<Row>, Boolean) - Method in class com.c12e.cortex.profiles.featurecatalog.DefaultFeatureReportCalculator

computeDataSourceFeatures(String, String, Dataset<Row>, Boolean) - Method in interface com.c12e.cortex.profiles.featurecatalog.FeatureReportCalculator

Computes the Features associated with a DataSource from the given Dataset.

computeFeatureReport(String, String, Dataset<Row>, boolean, List<Row>, String) - Method in class com.c12e.cortex.profiles.featurecatalog.DefaultFeatureReportCalculator

computeFeatureReport(String, String, Dataset<Row>, boolean, List<Row>, String) - Method in interface com.c12e.cortex.profiles.featurecatalog.FeatureReportCalculator

Computes the Features associated with a given DataSource and ProfileGroup from a sample of the data.

computePreviewFeatures(String, String, Dataset<Row>) - Method in class com.c12e.cortex.profiles.featurecatalog.DefaultFeatureReportCalculator

computePreviewFeatures(String, String, Dataset<Row>) - Method in interface com.c12e.cortex.profiles.featurecatalog.FeatureReportCalculator

Computes the Features from an explicit sample of the DataSource.

computeProfileFeatures(String, String, String, Dataset<Row>, Boolean) - Method in class com.c12e.cortex.profiles.featurecatalog.DefaultFeatureReportCalculator

computeProfileFeatures(String, String, String, Dataset<Row>, Boolean) - Method in interface com.c12e.cortex.profiles.featurecatalog.FeatureReportCalculator

Computes the Features associated with a DataSource and specific ProfileGroup.

configure() - Method in class com.c12e.cortex.profiles.CortexSession.CortexSessionModule

connection - Variable in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader.CortexReadParameters

connection - Variable in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader.CortexReadStreamParameters

connection(Connection) - Method in interface com.c12e.cortex.profiles.reader.CortexSparkReader

Read a dataset from a Cortex Connection

connection(Connection) - Method in class com.c12e.cortex.profiles.reader.DefaultCortexSparkReader

connection(String, String) - Method in interface com.c12e.cortex.profiles.reader.CortexSparkReader

Read a dataset from a Cortex Connection

connection(String, String) - Method in class com.c12e.cortex.profiles.reader.DefaultCortexSparkReader

connection(Dataset<Row>, Connection) - Method in interface com.c12e.cortex.profiles.writer.CortexSparkWriter

Write a dataset to a Cortex Connection

connection(Dataset<Row>, Connection) - Method in class com.c12e.cortex.profiles.writer.DefaultCortexSparkWriter

connection(Dataset<Row>, String, String) - Method in interface com.c12e.cortex.profiles.writer.CortexSparkWriter

Write a dataset to a Cortex Connection

connection(Dataset<Row>, String, String) - Method in class com.c12e.cortex.profiles.writer.DefaultCortexSparkWriter

connectionByName(String, String) - Method in class com.c12e.cortex.profiles.client.GeneratedPhoenixClient

Retrieves a Connection

connectionName - Variable in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader.CortexReadParameters

connectionName - Variable in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader.CortexReadStreamParameters

CONTENT_BUCKET - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

CONTENT_BUCKET_JSON_PATH - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

CONTENT_BUCKET_PROP - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

contentKeyForDriver(String) - Method in class com.c12e.cortex.profiles.module.connection.jdbc.DriverLoadingJdbcAdapter

contentKeyForDriver(String) - Method in interface com.c12e.cortex.profiles.module.connection.jdbc.JdbcSparkAdapter

Returns the corresponding Key in Managed Content for the JDBC driver name.

contentKeyForDriver(String) - Method in class com.c12e.cortex.profiles.module.connection.jdbc.NonLoadingJdbcAdapter

CORTEX_OUTPUT_FILENAME_OPTION - Static variable in class com.c12e.cortex.profiles.intercept.GraphingRequestInterceptor

Key in Cortex config options for specifying the filename the call graph should be written too.

CORTEX_OUTPUT_FILENAME_OPTION - Static variable in class com.c12e.cortex.profiles.intercept.TracingTimingMethodInterceptor

Key in Cortex config options for specifying the filename the call durations should be written too.

CORTEX_TOKEN - Static variable in class com.c12e.cortex.profiles.auth.CortexAuthContext

Token env var location

CortexAuthContext - Class in com.c12e.cortex.profiles.auth

Holds the token retrieved from env var or spark session properties and decodes the user information

CortexAuthContext() - Constructor for class com.c12e.cortex.profiles.auth.CortexAuthContext

Default auth context constructor, retrieves token from CORTEX_TOKEN

CortexAuthContext(String) - Constructor for class com.c12e.cortex.profiles.auth.CortexAuthContext

Spark session property based token constructor, set in CortexSession.CortexSessionModule

CortexCatalogReaderWriter - Interface in com.c12e.cortex.profiles

Exposes the Cortex Catalog

CortexConnectionReader - Interface in com.c12e.cortex.profiles.module.connection

CortexReader extension

CortexConnectionReaderModule - Interface in com.c12e.cortex.profiles.module.connection

Module for reading a dataset from Cortex Connection

CortexConnectionStreamReader - Interface in com.c12e.cortex.profiles.module.connection

CortexReader extension

CortexConnectionStreamReaderModule - Interface in com.c12e.cortex.profiles.module.connection

Module for reading a dataset from Cortex Connection

CortexConnectionWriter - Interface in com.c12e.cortex.profiles.module.connection

CortexWriter extension

CortexConnectionWriterModule - Interface in com.c12e.cortex.profiles.module.connection

Module for writing a dataset to Cortex Connection

CortexContext - Interface in com.c12e.cortex.profiles.context

Holds the context information for a CortexSession

cortexDataSourcePair - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

CortexDataSourcePair - Class in com.c12e.cortex.profiles.module

A pair of DataFrames that represent a static and stream pair, returned from CortexConnectionStreamReaderModule

CortexDataSourcePair(Dataset<Row>, Dataset<Row>) - Constructor for class com.c12e.cortex.profiles.module.CortexDataSourcePair

CortexDataSourceReader - Interface in com.c12e.cortex.profiles.module.datasource

CortexReader extension

CortexDataSourceReaderModule - Interface in com.c12e.cortex.profiles.module.datasource

Module for reading a dataset from Cortex Connection

CortexDataSourceStreamWriter - Interface in com.c12e.cortex.profiles.module.datasource

CortexDataSourceStreamWriterModule - Interface in com.c12e.cortex.profiles.module.datasource

Module for writing a CortexDataSourcePair to a DataSource

CortexDataSourceWriter - Interface in com.c12e.cortex.profiles.module.datasource

CortexWriter extension

CortexDataSourceWriterModule - Interface in com.c12e.cortex.profiles.module.datasource

Module for writing a dataset to Cortex DataSource

CortexDeltaMergeBuilder - Class in com.c12e.cortex.profiles.module

Handles a DeltaTable merge operation

CortexDeltaMergeBuilder() - Constructor for class com.c12e.cortex.profiles.module.CortexDeltaMergeBuilder

CortexInterceptor - Interface in com.c12e.cortex.profiles.intercept

Interface for Cortex specific MethodInterceptor's that need to perform final operation after the desired call stack has been captured.

CortexJobBuilder - Interface in com.c12e.cortex.profiles

Exposes the Cortex Job Registry

CortexJobRegistry - Interface in com.c12e.cortex.profiles.module.job

Registry of Cortex Jobs, implemented by @DefaultCortexJobRegistry

CortexModule<T> - Interface in com.c12e.cortex.profiles.module

A built module to execute a Cortex process flow

cortexPhoenixClient - Variable in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

CortexProfileReader - Interface in com.c12e.cortex.profiles.module.profile

CortexReader extension

CortexProfileReaderModule - Interface in com.c12e.cortex.profiles.module.profile

Module for reading a dataset from Cortex ProfileSchema

CortexProfileWriter - Interface in com.c12e.cortex.profiles.module.profile

CortexWriter extension

CortexProfileWriterModule - Interface in com.c12e.cortex.profiles.module.profile

Module for writing a dataset to Cortex ProfileSchema

CortexReader<ReturnType,T extends CortexReader> - Interface in com.c12e.cortex.profiles.module

Common interface of reader builder parameters

CortexReadParameters() - Constructor for class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader.CortexReadParameters

CortexReadParameters() - Constructor for class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader.CortexReadParameters

CortexReadParameters() - Constructor for class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader.CortexReadParameters

CortexReadStreamParameters() - Constructor for class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader.CortexReadStreamParameters

CortexRemoteCatalog - Class in com.c12e.cortex.profiles.catalog

Catalog interface adapter to a graphql phoenix client

CortexRemoteCatalog(GeneratedPhoenixClient) - Constructor for class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

CortexRemoteStorageClient - Interface in com.c12e.cortex.profiles.client

Client to Cortex Phoenix REST Service

CortexSecretsClient - Interface in com.c12e.cortex.profiles.client

Client to Cortex Secrets Service

CortexSession - Class in com.c12e.cortex.profiles

CortexSession is a managed interface to Cortex which utilizes spark for custom processing of profile data.

CortexSession.CortexSessionModule - Class in com.c12e.cortex.profiles

Guice backed @see com.google.inject.Module handling configuration options for creating a CortexSession.

CortexSessionModule(SparkSession, Map<String, String>) - Constructor for class com.c12e.cortex.profiles.CortexSession.CortexSessionModule

CortexSparkReader - Interface in com.c12e.cortex.profiles.reader

Interface to Cortex dataset readers.

CortexSparkReaderWriter - Interface in com.c12e.cortex.profiles

Entrypoint into the cortex supported spark flows

CortexSparkStreamReader - Interface in com.c12e.cortex.profiles.streamReader

CortexSparkStreamWriter - Interface in com.c12e.cortex.profiles.streamWriter

Interface to Cortex streaming dataset writer.

CortexSparkWriter - Interface in com.c12e.cortex.profiles.writer

Interface to Cortex dataset writers.

CortexValidator - Interface in com.c12e.cortex.profiles.validator

Validates a validatee

cortexVersion - Variable in class com.c12e.cortex.profiles.version.EnvironmentCortexVersions

CortexVersionStore - Interface in com.c12e.cortex.profiles.version

Stores the tracked Cortex and Spark dependency versions

CortexWriteParameters() - Constructor for class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter.CortexWriteParameters

CortexWriteParameters() - Constructor for class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

CortexWriteParameters() - Constructor for class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

CortexWriter<T extends CortexWriter> - Interface in com.c12e.cortex.profiles.module

Common interface of writer builder parameters

CortexWriteStreamParameters() - Constructor for class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

COUNT - Static variable in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.StringFeatureBuilder

createConnection(Connection) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

createDataSource(DataSource) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

createProfileSchema(ProfileSchema) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

D

dataSource - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader.CortexReadParameters

dataSource - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

dataSource(DataSource) - Method in interface com.c12e.cortex.profiles.reader.CortexSparkReader

Read a dataset from a Cortex DataSource

dataSource(DataSource) - Method in class com.c12e.cortex.profiles.reader.DefaultCortexSparkReader

dataSource(String, String) - Method in interface com.c12e.cortex.profiles.reader.CortexSparkReader

Read a dataset from a Cortex DataSource

dataSource(String, String) - Method in class com.c12e.cortex.profiles.reader.DefaultCortexSparkReader

dataSource(Dataset<Row>, DataSource) - Method in interface com.c12e.cortex.profiles.writer.CortexSparkWriter

Write a dataset to a Cortex DataSource Assumed correctly formatted dataset, use IngestDataSourceJob to ingest a data source from a connection

dataSource(Dataset<Row>, DataSource) - Method in class com.c12e.cortex.profiles.writer.DefaultCortexSparkWriter

dataSource(Dataset<Row>, String, String) - Method in interface com.c12e.cortex.profiles.writer.CortexSparkWriter

Write a dataset to a Cortex DataSource Assumed correctly formatted dataset, use IngestDataSourceJob to ingest a data source from a connection

dataSource(Dataset<Row>, String, String) - Method in class com.c12e.cortex.profiles.writer.DefaultCortexSparkWriter

dataSourceByName(String, String) - Method in class com.c12e.cortex.profiles.client.GeneratedPhoenixClient

Retrieves a DataSource

DataSourceCommand - Class in com.c12e.cortex.profiles.cli

DataSourceCommand() - Constructor for class com.c12e.cortex.profiles.cli.DataSourceCommand

dataSourceName - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader.CortexReadParameters

dataSourceName - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

dataSourceName - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

DataSourceWriteValidator - Class in com.c12e.cortex.profiles.validator

DataSourceWriteValidator() - Constructor for class com.c12e.cortex.profiles.validator.DataSourceWriteValidator

DEFAULT_CDATA_CHECKSUM_SECRET - Static variable in interface com.c12e.cortex.profiles.module.connection.jdbc.JdbcSparkAdapter

DEFAULT_CDATA_OEM_KEY_SECRET - Static variable in interface com.c12e.cortex.profiles.module.connection.jdbc.JdbcSparkAdapter

DEFAULT_CDATA_SHARED_PROJECT - Static variable in interface com.c12e.cortex.profiles.module.connection.jdbc.JdbcSparkAdapter

DEFAULT_DATASOURCE_FORMATTER - Static variable in class com.c12e.cortex.profiles.module.job.IngestDataSourceJob

DEFAULT_PROFILE_GROUP - Static variable in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

DefaultCortexConnectionReader - Class in com.c12e.cortex.profiles.module.connection

Default implementation of DefaultCortexConnectionReader

DefaultCortexConnectionReader(CortexContext, Catalog, CortexValidator, PhoenixRemoteStorage, CortexSecretsClient, JdbcSparkAdapter) - Constructor for class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

DefaultCortexConnectionReader.CortexReadParameters - Class in com.c12e.cortex.profiles.module.connection

DefaultCortexConnectionStreamReader - Class in com.c12e.cortex.profiles.module.connection

DefaultCortexConnectionStreamReader(CortexContext, Catalog, CortexValidator, CortexSecretsClient, PhoenixRemoteStorage, CortexConnectionReaderModule) - Constructor for class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader

DefaultCortexConnectionStreamReader.CortexReadStreamParameters - Class in com.c12e.cortex.profiles.module.connection

DefaultCortexConnectionWriter - Class in com.c12e.cortex.profiles.module.connection

Default implementation of CortexConnectionWriterModule

DefaultCortexConnectionWriter(Catalog, CortexValidator, PhoenixRemoteStorage, CortexSecretsClient, CortexAuthContext, SparkSession, JdbcSparkAdapter) - Constructor for class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter

DefaultCortexConnectionWriter.CortexWriteParameters - Class in com.c12e.cortex.profiles.module.connection

DefaultCortexDataSourceReader - Class in com.c12e.cortex.profiles.module.datasource

Default implementation of DefaultCortexDataSourceReader

DefaultCortexDataSourceReader(CortexContext, Catalog, CortexValidator, PhoenixRemoteStorage, CortexConnectionReaderModule) - Constructor for class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader

DefaultCortexDataSourceReader.CortexReadParameters - Class in com.c12e.cortex.profiles.module.datasource

DefaultCortexDataSourceStreamWriter - Class in com.c12e.cortex.profiles.module.datasource

DefaultCortexDataSourceStreamWriter(PhoenixRemoteStorage, CortexContext, CortexConnectionReaderModule, Catalog, CortexValidator, CortexDataSourceWriterModule, FeatureCatalog) - Constructor for class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter

DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters - Class in com.c12e.cortex.profiles.module.datasource

DefaultCortexDataSourceWriter - Class in com.c12e.cortex.profiles.module.datasource

Default implementation of CortexDataSourceWriterModule

DefaultCortexDataSourceWriter(Catalog, FeatureCatalog, CortexValidator, PhoenixRemoteStorage, CortexConnectionWriterModule) - Constructor for class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter

DefaultCortexDataSourceWriter.CortexWriteParameters - Class in com.c12e.cortex.profiles.module.datasource

DefaultCortexFeatureCatalog - Class in com.c12e.cortex.profiles.featurecatalog

DefaultCortexFeatureCatalog(Catalog, FeatureReportCalculator) - Constructor for class com.c12e.cortex.profiles.featurecatalog.DefaultCortexFeatureCatalog

DefaultCortexJobRegistry - Class in com.c12e.cortex.profiles.module.job

CortexJobRegistry implementation

DefaultCortexJobRegistry() - Constructor for class com.c12e.cortex.profiles.module.job.DefaultCortexJobRegistry

DefaultCortexProfileReader - Class in com.c12e.cortex.profiles.module.profile

Default implementation of CortexProfileReaderModule

DefaultCortexProfileReader(CortexContext, Catalog, CortexValidator, PhoenixRemoteStorage, CortexConnectionReaderModule) - Constructor for class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader

DefaultCortexProfileReader.CortexReadParameters - Class in com.c12e.cortex.profiles.module.profile

DefaultCortexProfileWriter - Class in com.c12e.cortex.profiles.module.profile

Default implementation of CortexProfileWriterModule

DefaultCortexProfileWriter(Catalog, CortexValidator, FeatureCatalog, PhoenixRemoteStorage, CortexConnectionWriterModule) - Constructor for class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter

DefaultCortexProfileWriter.CortexWriteParameters - Class in com.c12e.cortex.profiles.module.profile

DefaultCortexSparkReader - Class in com.c12e.cortex.profiles.reader

Default implementation with reader builder retrieval and mandatory options set.

DefaultCortexSparkReader(CortexConnectionReaderModule, CortexDataSourceReaderModule, CortexProfileReaderModule) - Constructor for class com.c12e.cortex.profiles.reader.DefaultCortexSparkReader

DefaultCortexSparkStreamReader - Class in com.c12e.cortex.profiles.streamReader

Default implementation with stream reader builder retrieval and mandatory options set.

DefaultCortexSparkStreamReader(CortexConnectionStreamReaderModule) - Constructor for class com.c12e.cortex.profiles.streamReader.DefaultCortexSparkStreamReader

DefaultCortexSparkStreamWriter - Class in com.c12e.cortex.profiles.streamWriter

Default implementation with stream writer builder retrieval and mandatory options set.

DefaultCortexSparkStreamWriter(CortexDataSourceStreamWriterModule) - Constructor for class com.c12e.cortex.profiles.streamWriter.DefaultCortexSparkStreamWriter

DefaultCortexSparkWriter - Class in com.c12e.cortex.profiles.writer

Default implementation with writer builder retrieval and mandatory options set.

DefaultCortexSparkWriter(CortexDataSourceWriterModule, CortexConnectionWriterModule, CortexProfileWriterModule) - Constructor for class com.c12e.cortex.profiles.writer.DefaultCortexSparkWriter

DefaultCortexValidator - Class in com.c12e.cortex.profiles.validator

Default validator, always passes.

DefaultCortexValidator() - Constructor for class com.c12e.cortex.profiles.validator.DefaultCortexValidator

DefaultFeatureReportCalculator - Class in com.c12e.cortex.profiles.featurecatalog

DefaultFeatureReportCalculator() - Constructor for class com.c12e.cortex.profiles.featurecatalog.DefaultFeatureReportCalculator

defaultWriterOptions - Variable in class com.c12e.cortex.profiles.module.job.BuildProfileJob

Default writer options, remove option with by returning dws

defaultWriterOptions - Variable in class com.c12e.cortex.profiles.module.job.IngestDataSourceJob

Default writer options, remove option by returning dsw

deleteAllProfiles() - Method in class com.c12e.cortex.profiles.cli.ProfileCommand

deleteConnection(String, String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

deleteDataSink(String, String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

deleteDataSource(String, String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

deleteFavoriteQuery(String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

deleteFeatureCatalog() - Method in class com.c12e.cortex.profiles.cli.DataSourceCommand

deleteProfileLinks(ProfileLinkFilter) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

deleteProfiles() - Method in class com.c12e.cortex.profiles.cli.ProfileCommand

deleteProfileSchema(String, String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

deleteProject(String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

deleteSource() - Method in class com.c12e.cortex.profiles.cli.DataSourceCommand

DELIMITER - Static variable in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.StringFeatureBuilder

deltaMerge(CortexDeltaMergeBuilder) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter.CortexWriteParameters

deltaMerge(CortexDeltaMergeBuilder) - Method in interface com.c12e.cortex.profiles.module.CortexWriter

An instance of a builder to perform delta table merge.

deltaMerge(CortexDeltaMergeBuilder) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

deltaMerge(CortexDeltaMergeBuilder) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

deltaMerge(CortexDeltaMergeBuilder) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

deltaMergeBuilder - Variable in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

deltaTable - Variable in class com.c12e.cortex.profiles.module.CortexDeltaMergeBuilder

Existing DeltaTable

deltaTable - Variable in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

deltaTable(DeltaTable) - Method in interface com.c12e.cortex.profiles.module.profile.CortexProfileWriter

The delta table to write

deltaTable(DeltaTable) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

deltaVersion - Variable in class com.c12e.cortex.profiles.version.EnvironmentCortexVersions

documentContext - Variable in class com.c12e.cortex.profiles.client.LocalRemoteStorageClient

doubleToFloat(Double) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

DOWNLOADS_DIRECTORY - Static variable in interface com.c12e.cortex.profiles.module.connection.jdbc.JdbcSparkAdapter

DriverLoadingJdbcAdapter - Class in com.c12e.cortex.profiles.module.connection.jdbc

JDBC Spark Adapter that supports parsing Connection Plugin Properties and attempts to modify the classpath.

DriverLoadingJdbcAdapter(Map<String, String>, CortexSecretsClient, String, String) - Constructor for class com.c12e.cortex.profiles.module.connection.jdbc.DriverLoadingJdbcAdapter

ds - Variable in class com.c12e.cortex.profiles.module.CortexDeltaMergeBuilder

Incoming DataFrame

ds - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

ds - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

ds - Variable in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

E

EnvironmentCortexVersions - Class in com.c12e.cortex.profiles.version

Versions retrieved from the current processing environment

EnvironmentCortexVersions(SparkSession) - Constructor for class com.c12e.cortex.profiles.version.EnvironmentCortexVersions

Retrieves Spark versions from the environment

execute(DeltaTable, Dataset<Row>) - Method in class com.c12e.cortex.profiles.module.CortexDeltaMergeBuilder

existing - Variable in class com.c12e.cortex.profiles.module.CortexDeltaMergeBuilder

existing DeltaTable alias

exportProfiles() - Method in class com.c12e.cortex.profiles.cli.ProfileCommand

F

FeatureBuilder - Interface in com.c12e.cortex.profiles.featurecatalog.featurebuilder

Interface for building a Cortex Feature corresponding to a Spark DataType and Cortex FeatureType.

FeatureCatalog - Interface in com.c12e.cortex.profiles.featurecatalog

Interface for service maintaining the set of Features associated with a DataSource.

FeatureReport - Class in com.c12e.cortex.profiles.featurecatalog

POJO holding inferred feature information, a reference to the Dataset (sample) it was inferred from, and a separate preview of the Dataset.

FeatureReport(List<Feature>, Dataset<Row>, List<Row>) - Constructor for class com.c12e.cortex.profiles.featurecatalog.FeatureReport

Creates a FeatureReport.

FeatureReportCalculator - Interface in com.c12e.cortex.profiles.featurecatalog

Interface for computing Feature information (@see FeatureReport) from a Cortex DataSource and source data.

featureSetBySourceName(String, String) - Method in class com.c12e.cortex.profiles.client.GeneratedPhoenixClient

FILE_BASE_DIR - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

FILE_BASE_DIR_PROP - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

fileMustExist(File, CommandLine) - Static method in class com.c12e.cortex.profiles.cli.ValidationUtils

Verifies the file instance exists, otherwise raises a CommandLine.ParameterException.

FloatFeatureBuilder - Class in com.c12e.cortex.profiles.featurecatalog.featurebuilder

Implementation of a BaseFeatureBuilder for handling non-integral data types.

FloatFeatureBuilder() - Constructor for class com.c12e.cortex.profiles.featurecatalog.featurebuilder.FloatFeatureBuilder

formatDatasetForDataSource - Static variable in class com.c12e.cortex.profiles.module.job.IngestDataSourceJob

transform on DataSource DataFrame to alter Timestamp and Date type columns to String Timestamp and Date type columns are not supported in Phoenix at this time

formatLine(String, String, String, String) - Method in class com.c12e.cortex.profiles.intercept.GraphPlan

G

GCS_AUTH_TYPE - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

GCS_AUTH_TYPE_JSON_PATH - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

GCS_AUTH_TYPE_PROP - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

GCS_SERVICE_ACCOUNT_KEY - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

GCS_SERVICE_ACCOUNT_KEY_JSON_PATH - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

GCS_SERVICE_ACCOUNT_KEY_PROP - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

GCS_SERVICE_PATH - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

GCS_SERVICE_PATH_JSON_PATH - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

GCS_SERVICE_PATH_PROP - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

GCS_STORAGE_ROOT - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

GCS_STORAGE_ROOT_JSON_PATH - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

GCS_STORAGE_ROOT_PROP - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

GeneratedPhoenixClient - Class in com.c12e.cortex.profiles.client

Client to remote phoenix service, exposes a GraphQL API

GeneratedPhoenixClient(String, String) - Constructor for class com.c12e.cortex.profiles.client.GeneratedPhoenixClient

get() - Method in class com.c12e.cortex.profiles.storage.RemoteStorageEnvLocator

getAuthContext() - Method in class com.c12e.cortex.profiles.context.BaseCortexContext

getAuthContext() - Method in interface com.c12e.cortex.profiles.context.CortexContext

The session's auth context

getBuilder() - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

getBuilder() - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader

getBuilder() - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter

getBuilder() - Method in interface com.c12e.cortex.profiles.module.CortexModule

Create module specific builder

getBuilder() - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader

getBuilder() - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter

getBuilder() - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter

getBuilder() - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader

getBuilder() - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter

getConnection(String, String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

getConnection(DefaultCortexConnectionReader.CortexReadParameters) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

getConnection(DefaultCortexConnectionStreamReader.CortexReadStreamParameters) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader

getConnection(DefaultCortexConnectionWriter.CortexWriteParameters) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter

getConnectionOptions(DefaultCortexConnectionReader.CortexReadParameters) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

getConnectionType() - Method in class com.c12e.cortex.profiles.storage.RemoteStorageEnvLocator

getContext() - Method in class com.c12e.cortex.profiles.CortexSession

getContext() - Method in interface com.c12e.cortex.profiles.CortexSparkReaderWriter

getCortexCatalog() - Method in class com.c12e.cortex.profiles.context.BaseCortexContext

getCortexCatalog() - Method in interface com.c12e.cortex.profiles.context.CortexContext

The Cortex catalog instance

getCortexJobRegistry() - Method in class com.c12e.cortex.profiles.context.BaseCortexContext

getCortexJobRegistry() - Method in interface com.c12e.cortex.profiles.context.CortexContext

The session's job registry

getCortexSparkReader() - Method in class com.c12e.cortex.profiles.context.BaseCortexContext

getCortexSparkReader() - Method in interface com.c12e.cortex.profiles.context.CortexContext

The spark integrated Cortex reader instance

getCortexSparkStreamReader() - Method in class com.c12e.cortex.profiles.context.BaseCortexContext

getCortexSparkStreamReader() - Method in interface com.c12e.cortex.profiles.context.CortexContext

The spark integrated Cortex stream reader instance

getCortexSparkStreamWriter() - Method in class com.c12e.cortex.profiles.context.BaseCortexContext

getCortexSparkStreamWriter() - Method in interface com.c12e.cortex.profiles.context.CortexContext

The spark integrated Cortex stream writer instance

getCortexSparkWriter() - Method in class com.c12e.cortex.profiles.context.BaseCortexContext

getCortexSparkWriter() - Method in interface com.c12e.cortex.profiles.context.CortexContext

The spark integrated Cortex writer instance

getCortexVersion() - Method in interface com.c12e.cortex.profiles.version.CortexVersionStore

Cortex version

getCortexVersion() - Method in class com.c12e.cortex.profiles.version.EnvironmentCortexVersions

getCortexVersion() - Method in class com.c12e.cortex.profiles.version.SupportedCortexVersions

getCortexVersionStore() - Method in class com.c12e.cortex.profiles.context.BaseCortexContext

getCortexVersionStore() - Method in interface com.c12e.cortex.profiles.context.CortexContext

Supported versions instance

getDataset - Variable in class com.c12e.cortex.profiles.module.job.BuildProfileJob

getDataSink(String, String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

getDataSource(String, String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

getDataSource(DefaultCortexDataSourceReader.CortexReadParameters) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader

getDataSource(DefaultCortexDataSourceWriter.CortexWriteParameters) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter

getDataSourceFromStreamParams(DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter

getDataStreamStatus(String, ResourceType, String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

getDataType() - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.ArrayFeatureBuilder

getDataType() - Method in interface com.c12e.cortex.profiles.featurecatalog.featurebuilder.FeatureBuilder

String representation of the Spark DataType for the feature.

getDataType() - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.FloatFeatureBuilder

getDataType() - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.IntFeatureBuilder

getDataType() - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.StringFeatureBuilder

getDataType() - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.UnknownFeatureBuilder

getDeltaVersion() - Method in interface com.c12e.cortex.profiles.version.CortexVersionStore

Delta version

getDeltaVersion() - Method in class com.c12e.cortex.profiles.version.EnvironmentCortexVersions

getDeltaVersion() - Method in class com.c12e.cortex.profiles.version.SupportedCortexVersions

getDf() - Method in class com.c12e.cortex.profiles.featurecatalog.FeatureReport

Dataset the features were inferred from

getFavoriteQuery(String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

getFeatureCatalog() - Method in class com.c12e.cortex.profiles.context.BaseCortexContext

getFeatureCatalog() - Method in interface com.c12e.cortex.profiles.context.CortexContext

The Cortex FeatureCatalog instance.

getFeatures() - Method in class com.c12e.cortex.profiles.featurecatalog.FeatureReport

Returns the list of features

getFeatureSetBySourceName(String, String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

getFeatureType() - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.ArrayFeatureBuilder

getFeatureType() - Method in interface com.c12e.cortex.profiles.featurecatalog.featurebuilder.FeatureBuilder

String representation of the feature type in Cortex (e.g.

getFeatureType() - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.FloatFeatureBuilder

getFeatureType() - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.IntFeatureBuilder

getFeatureType() - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.StringFeatureBuilder

getFeatureType() - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.UnknownFeatureBuilder

getHadoopVersion() - Method in interface com.c12e.cortex.profiles.version.CortexVersionStore

Hadoop version

getHadoopVersion() - Method in class com.c12e.cortex.profiles.version.EnvironmentCortexVersions

getHadoopVersion() - Method in class com.c12e.cortex.profiles.version.SupportedCortexVersions

getInstance() - Static method in class com.c12e.cortex.profiles.module.CortexDeltaMergeBuilder

Get a new instance

getOptions() - Method in class com.c12e.cortex.profiles.module.SparkOptionsHandler

Retrieve current options

getOrDefault(Supplier<T>, T) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

getOrDefault(Supplier<T>, T) - Method in class com.c12e.cortex.profiles.storage.RemoteStorageEnvLocator

getPhoenixAmpConnection() - Method in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

getPhoenixAmpConnection() - Method in class com.c12e.cortex.profiles.storage.RemoteStorageEnvLocator

getPhoenixManagedContentConnection() - Method in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

getPhoenixManagedContentConnection() - Method in class com.c12e.cortex.profiles.storage.RemoteStorageEnvLocator

getPhoenixProfileConnection(String) - Method in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

getPhoenixProfileConnection(String) - Method in class com.c12e.cortex.profiles.storage.RemoteStorageEnvLocator

getPreviewCollection() - Method in class com.c12e.cortex.profiles.featurecatalog.FeatureReport

Explicit preview of the Dataset

getProfileEngine() - Method in class com.c12e.cortex.profiles.context.BaseCortexContext

getProfileEngine() - Method in interface com.c12e.cortex.profiles.context.CortexContext

The profile engine

getProfileLink(ProfileLink) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

getProfileSchema(String, String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

getProfileSchema(DefaultCortexProfileReader.CortexReadParameters) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader

getProfileSchema(DefaultCortexProfileWriter.CortexWriteParameters) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter

getProject(String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

getReadConnection(String, String) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader

getReadConnection(String, String) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader

getRecordCount() - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

getSecret(String, String) - Method in interface com.c12e.cortex.profiles.client.CortexSecretsClient

Retrieve a secret value by project and key path

getSecret(String, String) - Method in class com.c12e.cortex.profiles.client.LocalSecretClient

getSharedCDataKey() - Method in class com.c12e.cortex.profiles.module.connection.jdbc.DriverLoadingJdbcAdapter

getSharedCDataKey() - Method in interface com.c12e.cortex.profiles.module.connection.jdbc.JdbcSparkAdapter

Returns options for the CData Keys in the Shared Cortex Project.

getSharedCDataKey() - Method in class com.c12e.cortex.profiles.module.connection.jdbc.NonLoadingJdbcAdapter

getSparkSession() - Method in class com.c12e.cortex.profiles.context.BaseCortexContext

getSparkSession() - Method in interface com.c12e.cortex.profiles.context.CortexContext

Spark session instance

getSparkVersion() - Method in interface com.c12e.cortex.profiles.version.CortexVersionStore

Spark version

getSparkVersion() - Method in class com.c12e.cortex.profiles.version.EnvironmentCortexVersions

getSparkVersion() - Method in class com.c12e.cortex.profiles.version.SupportedCortexVersions

getStaticDf() - Method in class com.c12e.cortex.profiles.module.CortexDataSourcePair

The static DataFrame

getStorageConfig() - Method in interface com.c12e.cortex.profiles.client.CortexRemoteStorageClient

Retrieves the storage configuration from a remote service

getStorageConfig() - Method in class com.c12e.cortex.profiles.client.LocalRemoteStorageClient

getStreamDf() - Method in class com.c12e.cortex.profiles.module.CortexDataSourcePair

The stream DataFrame

getToken() - Method in class com.c12e.cortex.profiles.auth.CortexAuthContext

The set token

getUser() - Method in class com.c12e.cortex.profiles.auth.CortexAuthContext

The user, decoded from the token or anonymous if token not found

getWriteConnection(DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter

getWriteConnection(String, String) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter

getWriteConnection(String, String) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter

GraphingRequestInterceptor - Class in com.c12e.cortex.profiles.intercept

Intercepts proxied methods by scope and generates a dot notated request plan.

GraphingRequestInterceptor() - Constructor for class com.c12e.cortex.profiles.intercept.GraphingRequestInterceptor

Creates an interceptor instance with a new GraphPlan instance and default method access modifier scope of Any

GraphingRequestInterceptor(GraphPlan) - Constructor for class com.c12e.cortex.profiles.intercept.GraphingRequestInterceptor

Creates an interceptor instance with the given GraphPlan and default method access modifier scope of Any

GraphingRequestInterceptor(GraphPlan, Integer) - Constructor for class com.c12e.cortex.profiles.intercept.GraphingRequestInterceptor

Create an interceptor instance with graph plan and trace method access modifier scope, either Public -> Protected -> Any.

GraphPlan - Class in com.c12e.cortex.profiles.intercept

Storage for traced plan of a series of CortexSession requests

GraphPlan() - Constructor for class com.c12e.cortex.profiles.intercept.GraphPlan

GUICE_ENHANCED - Static variable in class com.c12e.cortex.profiles.intercept.GraphingRequestInterceptor

GUICE_ENHANCED - Static variable in class com.c12e.cortex.profiles.intercept.TracingMethodInterceptor

GUICE_ENHANCED - Static variable in class com.c12e.cortex.profiles.intercept.TracingTimingMethodInterceptor

H

hadoopVersion - Variable in class com.c12e.cortex.profiles.version.EnvironmentCortexVersions

handleFileConnection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

handleFileConnection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter

handleGCPFileStreamConnection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader

handleGcsConnection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

handleGcsConnection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter

handleHiveConnection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

handleHiveConnection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter

handleJdbcCDataConnection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

handleJdbcCDataConnection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter

handleJdbcConnection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

handleJdbcConnection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter

handleJdbcGenericConnection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

handleJdbcGenericConnection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter

handleMongoConnection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

handleMongoConnection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter

handleOther(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

handleOther(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader

handleOther(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter

handleS3Connection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

handleS3Connection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter

handleS3FileStreamConnection(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader

hear(TypeLiteral<I>, TypeEncounter<I>) - Method in class com.c12e.cortex.profiles.logging.LogTypeListener

I

includeDriverInClassPath(String, String) - Method in class com.c12e.cortex.profiles.module.connection.jdbc.DriverLoadingJdbcAdapter

includeDriverInClassPath(String, String) - Method in interface com.c12e.cortex.profiles.module.connection.jdbc.JdbcSparkAdapter

Checks if the JDBC Driver is in the class path and if not includes the corresponding Jar file from Managed Content to the current classpath.

includeDriverInClassPath(String, String) - Method in class com.c12e.cortex.profiles.module.connection.jdbc.NonLoadingJdbcAdapter

incoming - Variable in class com.c12e.cortex.profiles.module.CortexDeltaMergeBuilder

incoming DataFrame alias

inferFromSample(Dataset<Row>, String) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

Computes Feature attributes from the provided sample data, specifically Feature#uniqueCount and Feature#pctNull.

inferFromSample(Dataset<Row>, String) - Method in interface com.c12e.cortex.profiles.featurecatalog.featurebuilder.FeatureBuilder

Infers feature properties based on the Dataset sample.

inferFromSample(Dataset<Row>, String) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.FloatFeatureBuilder

inferFromSample(Dataset<Row>, String) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.IntFeatureBuilder

inferFromSample(Dataset<Row>, String) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.StringFeatureBuilder

inferFromSample(Dataset<Row>, String) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.UnknownFeatureBuilder

ingest() - Method in class com.c12e.cortex.profiles.cli.DataSourceCommand

ingestDataSource(String, String, CortexContext) - Method in interface com.c12e.cortex.profiles.module.job.CortexJobRegistry

Creates an instance of the IngestDataSourceJob to run with the supplied parameters

ingestDataSource(String, String, CortexContext) - Method in class com.c12e.cortex.profiles.module.job.DefaultCortexJobRegistry

IngestDataSourceJob - Class in com.c12e.cortex.profiles.module.job

Ingest a DataSource

IngestDataSourceJob(String, String, CortexContext) - Constructor for class com.c12e.cortex.profiles.module.job.IngestDataSourceJob

Constructor

InjectLogger - Annotation Type in com.c12e.cortex.profiles.logging

Annotation for Guice injection of logger instance, based on: https://github.com/google/guice/wiki/CustomInjections.

instrumentation - Static variable in class com.c12e.cortex.profiles.module.connection.jdbc.JvmClasspathAgent

IntFeatureBuilder - Class in com.c12e.cortex.profiles.featurecatalog.featurebuilder

Implementation of a BaseFeatureBuilder for handling general integral data types.

IntFeatureBuilder() - Constructor for class com.c12e.cortex.profiles.featurecatalog.featurebuilder.IntFeatureBuilder

invoke(MethodInvocation) - Method in class com.c12e.cortex.profiles.intercept.GraphingRequestInterceptor

invoke(MethodInvocation) - Method in class com.c12e.cortex.profiles.intercept.TracingMethodInterceptor

invoke(MethodInvocation) - Method in class com.c12e.cortex.profiles.intercept.TracingTimingMethodInterceptor

isSupported(CortexVersionStore) - Method in interface com.c12e.cortex.profiles.version.CortexVersionStore

Boolean check of version support.

isSupported(CortexVersionStore) - Method in class com.c12e.cortex.profiles.version.EnvironmentCortexVersions

isSupported(CortexVersionStore) - Method in class com.c12e.cortex.profiles.version.SupportedCortexVersions

isTracingScope(Method) - Method in class com.c12e.cortex.profiles.intercept.GraphingRequestInterceptor

J

JacksonAnnotation - Annotation Type in org.codehaus.jackson.annotate

Meta-annotation (annotations used on other annotations) used for marking all annotations that are part of Jackson package.

JDBC_ADAPTER_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

JdbcSparkAdapter - Interface in com.c12e.cortex.profiles.module.connection.jdbc

Adapter utils for converting Cortex CData Connections to Spark properties.

jdbcUrlFromDriver(String) - Method in interface com.c12e.cortex.profiles.module.connection.jdbc.JdbcSparkAdapter

Creates a default URL from the JDBC driver

job() - Method in interface com.c12e.cortex.profiles.CortexJobBuilder

job() - Method in class com.c12e.cortex.profiles.CortexSession

JsonRawValue - Annotation Type in org.codehaus.jackson.annotate

Marker annotation that indicates that the annotated method or field should be serialized by including literal String value of the property as is, without quoting of characters.

JvmClasspathAgent - Class in com.c12e.cortex.profiles.module.connection.jdbc

Java agent to add jar to classpath at runtime

JvmClasspathAgent() - Constructor for class com.c12e.cortex.profiles.module.connection.jdbc.JvmClasspathAgent

L

listConnections(String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

listDataSinks(String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

listDataSources(String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

listFavoriteQueries(FavoriteQuery) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

listProfileLinks(String, ProfileLinkFilter) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

listProfileSchemas(String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

listProjects(String, String, String, String) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

listSecrets(String) - Method in interface com.c12e.cortex.profiles.client.CortexSecretsClient

List all secret keys for a project

listSecrets(String) - Method in class com.c12e.cortex.profiles.client.LocalSecretClient

load() - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader.CortexReadParameters

load() - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader.CortexReadStreamParameters

load() - Method in interface com.c12e.cortex.profiles.module.CortexReader

Completes building and begins read process

load() - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader.CortexReadParameters

load() - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader.CortexReadParameters

loadDeltaTable() - Method in interface com.c12e.cortex.profiles.module.connection.CortexConnectionReader

Loads the data as a delta table if ContentType is delta

loadDeltaTable() - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader.CortexReadParameters

LOCAL_CATALOG_DIR_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

Local Catalog Read Dir

localFeatureFromRemote(Feature) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

localFeaturesFromRemote(Iterable<Feature>) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

LocalRemoteStorageClient - Class in com.c12e.cortex.profiles.client

Reads storage configuration from a DocumentContext

LocalRemoteStorageClient() - Constructor for class com.c12e.cortex.profiles.client.LocalRemoteStorageClient

LocalRemoteStorageClient(DocumentContext) - Constructor for class com.c12e.cortex.profiles.client.LocalRemoteStorageClient

LocalSecretClient - Class in com.c12e.cortex.profiles.client

LocalSecretClient(LocalSecretClient.LocalSecrets) - Constructor for class com.c12e.cortex.profiles.client.LocalSecretClient

LocalSecretClient.LocalSecrets - Class in com.c12e.cortex.profiles.client

localSecrets - Variable in class com.c12e.cortex.profiles.client.LocalSecretClient

LocalSecrets() - Constructor for class com.c12e.cortex.profiles.client.LocalSecretClient.LocalSecrets

logger - Variable in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

logger - Variable in class com.c12e.cortex.profiles.module.connection.jdbc.DriverLoadingJdbcAdapter

logger - Variable in class com.c12e.cortex.profiles.module.connection.jdbc.NonLoadingJdbcAdapter

logger - Variable in class com.c12e.cortex.profiles.storage.RemoteStorageEnvLocator

LogTypeListener - Class in com.c12e.cortex.profiles.logging

LogTypeListener() - Constructor for class com.c12e.cortex.profiles.logging.LogTypeListener

M

main(String[]) - Static method in class com.c12e.cortex.profiles.cli.Application

makeRequest(GraphQLQuery, BaseProjectionNode, Class<T>) - Method in class com.c12e.cortex.profiles.client.GeneratedPhoenixClient

Generic request structure, use with catalog extensions

MANAGED_CONTENT_ENDPOINT - Static variable in interface com.c12e.cortex.profiles.module.connection.jdbc.JdbcSparkAdapter

MANAGED_CONTENT_KEY - Static variable in interface com.c12e.cortex.profiles.module.connection.jdbc.JdbcSparkAdapter

Connection Property for managed content key reference.

mapAttributeTag(AttributeTag) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

mapDataSourceSelection(DataSourceSelection) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

mapJoins(JoinSourceSelection) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

mapProfileSchemaAttributes(ProfileSchema) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

mapProfileSchemaAttributeTags(AttributeTag) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

mapProfileSchemaDataSourceSelection(DataSourceSelection) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

mapProfileSchemaJoinSourceSelection(JoinSourceSelection) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

mapProfileSchemaNames(ProfileNames) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

mapProfileSchemaTimestampSpec(TimestampSpec) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

merge - Variable in class com.c12e.cortex.profiles.module.CortexDeltaMergeBuilder

Delta merge builder

mergeBuilder - Variable in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter.CortexWriteParameters

mergeBuilder - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

mergeBuilder - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

mergeMap(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.SparkOptionsHandler

Merges new options with overwrite of existing options

METHOD_PROXY_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

MIN_SAMPLE_SIZE - Static variable in class com.c12e.cortex.profiles.featurecatalog.DefaultFeatureReportCalculator

mode - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

mode - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

mode - Variable in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

mode(SaveMode) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter.CortexWriteParameters

mode(SaveMode) - Method in interface com.c12e.cortex.profiles.module.CortexWriter

Spark save mode

mode(SaveMode) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

mode(SaveMode) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

mode(SaveMode) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

N

newSession(SparkSession) - Static method in class com.c12e.cortex.profiles.CortexSession

Create a new CortexSession instance with the given spark session

newSession(SparkSession, Map<String, String>) - Static method in class com.c12e.cortex.profiles.CortexSession

Create a new CortexSession instance with the given spark session and additional options.

NonLoadingJdbcAdapter - Class in com.c12e.cortex.profiles.module.connection.jdbc

JDBC Spark Adapter that supports parsing Connection Plugin Properties, but DOES NOT attempt to modify the classpath.

NonLoadingJdbcAdapter(Map<String, String>, CortexSecretsClient) - Constructor for class com.c12e.cortex.profiles.module.connection.jdbc.NonLoadingJdbcAdapter

O

onCondition - Variable in class com.c12e.cortex.profiles.module.CortexDeltaMergeBuilder

Merge On Condition - "existing.%s = incoming.%s"

option(String, String) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader.CortexReadParameters

option(String, String) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader.CortexReadStreamParameters

option(String, String) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter.CortexWriteParameters

option(String, String) - Method in interface com.c12e.cortex.profiles.module.CortexReader

Overwrites value at key

option(String, String) - Method in interface com.c12e.cortex.profiles.module.CortexWriter

Overwrites value at key

option(String, String) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader.CortexReadParameters

option(String, String) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

option(String, String) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

option(String, String) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader.CortexReadParameters

option(String, String) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

options(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader.CortexReadParameters

options(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader.CortexReadStreamParameters

options(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter.CortexWriteParameters

options(Map<String, String>) - Method in interface com.c12e.cortex.profiles.module.CortexReader

Merges new options with current options

options(Map<String, String>) - Method in interface com.c12e.cortex.profiles.module.CortexWriter

Merges new options with current options

options(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader.CortexReadParameters

options(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

options(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

options(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader.CortexReadParameters

options(Map<String, String>) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

org.codehaus.jackson.annotate - package org.codehaus.jackson.annotate

P

parseCDataPluginProperties(String) - Method in interface com.c12e.cortex.profiles.module.connection.jdbc.JdbcSparkAdapter

Parses the CDATA driver specific plugin_properties Connection paramter.

partitionBy(String...) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter.CortexWriteParameters

partitionBy(String...) - Method in interface com.c12e.cortex.profiles.module.CortexWriter

Create partitions on column name(s)

partitionBy(String...) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

partitionBy(String...) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

partitionBy(String...) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

partitionColumns - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

partitionColumns - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

partitionColumns - Variable in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

performAggregation - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

performAggregation(Boolean) - Method in interface com.c12e.cortex.profiles.module.datasource.CortexDataSourceStreamWriter

Perform groupBy aggregation on primary key, an expensive operation that should be turned off if the micro-batch dataset from the streaming data source always contains unique keys

performAggregation(Boolean) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

performFeatureCatalogCalculations - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

performFeatureCatalogCalculations - Variable in class com.c12e.cortex.profiles.module.job.BuildProfileJob

Perform FeatureCatalog calculations, is an expensive operation and may be set to false depending on the dataset

performFeatureCatalogCalculations - Variable in class com.c12e.cortex.profiles.module.job.IngestDataSourceJob

Perform FeatureCatalog calculations, is an expensive operation and may be set to false depending on the dataset

performFeatureCatalogCalculations(Boolean) - Method in interface com.c12e.cortex.profiles.module.datasource.CortexDataSourceStreamWriter

Perform feature catalog calculations FeatureCatalog

performFeatureCatalogCalculations(Boolean) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

PHOENIX_CLIENT_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

PHOENIX_CLIENT_URL_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

Phoenix Client URL Key Path

PHOENIX_TOKEN_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

Phoenix Token Key Path

PhoenixRemoteStorage - Interface in com.c12e.cortex.profiles.storage

Interface storing and providing remote storage configuration objects for Cortex.

plan - Variable in class com.c12e.cortex.profiles.intercept.GraphingRequestInterceptor

postIntercept(Map<String, String>) - Method in interface com.c12e.cortex.profiles.intercept.CortexInterceptor

Performs final operations after all calls have been captured.

postIntercept(Map<String, String>) - Method in class com.c12e.cortex.profiles.intercept.GraphingRequestInterceptor

Saves the call graph to an output file based on the given session options.

postIntercept(Map<String, String>) - Method in class com.c12e.cortex.profiles.intercept.TracingTimingMethodInterceptor

Saves the captured method timings to an output file based on the given session option.

PREFIX - Static variable in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.StringFeatureBuilder

premain(String, Instrumentation) - Static method in class com.c12e.cortex.profiles.module.connection.jdbc.JvmClasspathAgent

prepareDataset(DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter

prepareDataset(DefaultCortexDataSourceWriter.CortexWriteParameters) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter

prepareSourceFrame(Dataset<Row>) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter

profile(ProfileSchema) - Method in interface com.c12e.cortex.profiles.reader.CortexSparkReader

Read a dataset from a Cortex ProfileSchema

profile(ProfileSchema) - Method in class com.c12e.cortex.profiles.reader.DefaultCortexSparkReader

profile(String, String) - Method in interface com.c12e.cortex.profiles.reader.CortexSparkReader

Read a dataset from a Cortex ProfileSchema

profile(String, String) - Method in class com.c12e.cortex.profiles.reader.DefaultCortexSparkReader

profile(Dataset<Row>, ProfileSchema) - Method in interface com.c12e.cortex.profiles.writer.CortexSparkWriter

Write a dataset to a Cortex ProfileSchema Assumed correctly formatted dataset, use BuildProfileJob to build a profile schema

profile(Dataset<Row>, ProfileSchema) - Method in class com.c12e.cortex.profiles.writer.DefaultCortexSparkWriter

profile(Dataset<Row>, String, String) - Method in interface com.c12e.cortex.profiles.writer.CortexSparkWriter

Write a dataset to a Cortex ProfileSchema Assumed correctly formatted dataset, use BuildProfileJob to build a profile schema

profile(Dataset<Row>, String, String) - Method in class com.c12e.cortex.profiles.writer.DefaultCortexSparkWriter

PROFILE_ID_FIELD - Static variable in class com.c12e.cortex.profiles.featurecatalog.DefaultFeatureReportCalculator

ProfileCommand - Class in com.c12e.cortex.profiles.cli

ProfileCommand() - Constructor for class com.c12e.cortex.profiles.cli.ProfileCommand

profileDeltaTablePath(String, String) - Method in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

PROFILES_BUCKET - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

PROFILES_BUCKET_JSON_PATH - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

PROFILES_BUCKET_PROP - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

profileSchema - Variable in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader.CortexReadParameters

profileSchema - Variable in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

profileSchemaByName(String, String) - Method in class com.c12e.cortex.profiles.client.GeneratedPhoenixClient

Retrieves a ProfileSchema

profileSchemaName - Variable in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader.CortexReadParameters

profileSchemaName - Variable in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

project - Variable in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader.CortexReadParameters

project - Variable in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader.CortexReadStreamParameters

project - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader.CortexReadParameters

project - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

project - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

project - Variable in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader.CortexReadParameters

project - Variable in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

project(String) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader.CortexReadParameters

project(String) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader.CortexReadStreamParameters

project(String) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter.CortexWriteParameters

project(String) - Method in interface com.c12e.cortex.profiles.module.CortexReader

Sets the project

project(String) - Method in interface com.c12e.cortex.profiles.module.CortexWriter

Sets the project

project(String) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader.CortexReadParameters

project(String) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

project(String) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

project(String) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader.CortexReadParameters

project(String) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

pruneProfiles() - Method in class com.c12e.cortex.profiles.cli.ProfileCommand

pruneSource() - Method in class com.c12e.cortex.profiles.cli.DataSourceCommand

pushCall(String, String) - Method in class com.c12e.cortex.profiles.intercept.GraphPlan

Push on method entry

putOption(String, String) - Method in class com.c12e.cortex.profiles.module.SparkOptionsHandler

Overwrite key with value

Q

queryFeatures(String, String) - Method in class com.c12e.cortex.profiles.featurecatalog.DefaultCortexFeatureCatalog

queryFeatures(String, String) - Method in interface com.c12e.cortex.profiles.featurecatalog.FeatureCatalog

Get the list of features associated to the DataSource with the given name

R

read() - Method in class com.c12e.cortex.profiles.CortexSession

read() - Method in interface com.c12e.cortex.profiles.CortexSparkReaderWriter

read(DefaultCortexConnectionReader.CortexReadParameters) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

Read from a Cortex Connection using the builder instance

read(DefaultCortexConnectionStreamReader.CortexReadStreamParameters) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader

Read from a Cortex Connection using the builder instance Create a static DataFrame based on the uri param Create a streaming DataFrame based on the stream_read_dir parm

read(DefaultCortexDataSourceReader.CortexReadParameters) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader

Read from a Cortex DataSource using the builder instance

read(DefaultCortexProfileReader.CortexReadParameters) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader

Read from a Cortex ProfileSchema using the builder instance

readConnection(String, String) - Method in interface com.c12e.cortex.profiles.streamReader.CortexSparkStreamReader

Read a dataset from Cortex DataSource using Spark Streams

readConnection(String, String) - Method in class com.c12e.cortex.profiles.streamReader.DefaultCortexSparkStreamReader

Read streaming connection

readDeltaTable(DefaultCortexConnectionReader.CortexReadParameters) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

Read from a Cortex Connection using the builder instance

READER_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

readerOptions - Variable in class com.c12e.cortex.profiles.module.job.IngestDataSourceJob

Expand on CortexConnectionReader reader options

readFromDataSource(DefaultCortexDataSourceReader.CortexReadParameters, Connection) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader

readFromProfileSchema(DefaultCortexProfileReader.CortexReadParameters, Connection) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader

readStream() - Method in class com.c12e.cortex.profiles.CortexSession

readStream() - Method in interface com.c12e.cortex.profiles.CortexSparkReaderWriter

readStreamFromConnection(DefaultCortexConnectionStreamReader.CortexReadStreamParameters) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader

REMOTE_STORAGE_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

RemoteStorageEnvLocator - Class in com.c12e.cortex.profiles.storage

Provide remote storage configuration for Cortex.

RemoteStorageEnvLocator(Map<String, String>, CortexRemoteStorageClient) - Constructor for class com.c12e.cortex.profiles.storage.RemoteStorageEnvLocator

resourceName(String) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader.CortexReadParameters

resourceName(String) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader.CortexReadStreamParameters

resourceName(String) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter.CortexWriteParameters

resourceName(String) - Method in interface com.c12e.cortex.profiles.module.CortexReader

Sets the resource to write to

resourceName(String) - Method in interface com.c12e.cortex.profiles.module.CortexWriter

Sets the resource to write to

resourceName(String) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader.CortexReadParameters

resourceName(String) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

resourceName(String) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

resourceName(String) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader.CortexReadParameters

resourceName(String) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

run() - Method in class com.c12e.cortex.profiles.module.job.BuildProfileJob

run() - Method in class com.c12e.cortex.profiles.module.job.IngestDataSourceJob

S

S3_ENDPOINT - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

S3_ENDPOINT_JSON_PATH - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

S3_ENDPOINT_PROP - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

S3_PATH_STYLE_ACCESS - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

S3_PATH_STYLE_ACCESS_JSON_PATH - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

S3_PATH_STYLE_ACCESS_PROP - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

S3_SSL_ENABLED - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

S3_SSL_ENABLED_JSON_PATH - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

S3_SSL_ENABLED_PROP - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

sample(Dataset<Row>) - Method in class com.c12e.cortex.profiles.featurecatalog.DefaultFeatureReportCalculator

Returns a sample taken from the dataset of size DefaultFeatureReportCalculator.MIN_SAMPLE_SIZE.

SAMPLE_MOE - Static variable in class com.c12e.cortex.profiles.featurecatalog.DefaultFeatureReportCalculator

SAMPLE_P - Static variable in class com.c12e.cortex.profiles.featurecatalog.DefaultFeatureReportCalculator

SAMPLE_SIZE - Static variable in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

SAMPLE_Z_SCORE - Static variable in class com.c12e.cortex.profiles.featurecatalog.DefaultFeatureReportCalculator

SAMPLING_FRACTIONS - Static variable in class com.c12e.cortex.profiles.featurecatalog.DefaultFeatureReportCalculator

save() - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter.CortexWriteParameters

save() - Method in interface com.c12e.cortex.profiles.module.CortexWriter

Completes building and begins write process

save() - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

save() - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

save() - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

saveDataSink(DataSink) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

saveDataStreamStatus(DataStreamStatus) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

saveFavoriteQuery(FavoriteQuery) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

saveFeatureSet(String, String, List<Feature>) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

saveFeatureSet(String, String, List<Feature>) - Method in class com.c12e.cortex.profiles.client.GeneratedPhoenixClient

Saves the List of Feature's associated with given the project and DataSource.

saveProfileLink(ProfileLink) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

saveProject(Project) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

schema - Variable in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader.CortexReadParameters

schema - Variable in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader.CortexReadStreamParameters

schema(StructType) - Method in interface com.c12e.cortex.profiles.module.connection.CortexConnectionReader

Override dataset schema when able

schema(StructType) - Method in interface com.c12e.cortex.profiles.module.connection.CortexConnectionStreamReader

Override dataset schema when able

schema(StructType) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader.CortexReadParameters

schema(StructType) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader.CortexReadStreamParameters

scopes - Static variable in class com.c12e.cortex.profiles.intercept.GraphingRequestInterceptor

SECRET_CLIENT_URL_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

Secrets Client Token URL Path

SECRETS_CLIENT_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

secretsMap - Variable in class com.c12e.cortex.profiles.client.LocalSecretClient.LocalSecrets

sessionOptions - Variable in class com.c12e.cortex.profiles.CortexSession.CortexSessionModule

setDataset(Dataset<Row>) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter.CortexWriteParameters

setDataset(Dataset<Row>) - Method in interface com.c12e.cortex.profiles.module.CortexWriter

Sets the dataset to write

setDataset(Dataset<Row>) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

setDataset(Dataset<Row>) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

setDataset(Dataset<Row>) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

setDataSourcePair(CortexDataSourcePair) - Method in interface com.c12e.cortex.profiles.module.datasource.CortexDataSourceStreamWriter

Sets the stream reader return type

setDataSourcePair(CortexDataSourcePair) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

setDescription(String) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

setFieldName(String) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

setMaxValue(Double) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

setMeanValue(Double) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

setMinValue(Double) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

setNotes(String) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

setObservations(String) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

setPctDom(Float) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

setPctNull(Float) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

setProfileGroup(String) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

setProject(String) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

setRecordCount(Long) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

setSecretsForProject(String, Map<String, String>) - Method in class com.c12e.cortex.profiles.client.LocalSecretClient.LocalSecrets

setSourceName(String) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

setStdDev(Double) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

setUniqueCount(Long) - Method in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.BaseFeatureBuilder

sourceDeltaPath(String, String) - Method in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

sourcePrimaryKey - Variable in class com.c12e.cortex.profiles.module.CortexDeltaMergeBuilder

Incoming DataFrame primary key

spark() - Method in class com.c12e.cortex.profiles.CortexSession

SPARK_CONN_READER_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

SPARK_CONN_READER_VALIDATOR_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

SPARK_CONN_WRITER_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

SPARK_CONN_WRITER_VALIDATOR_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

SPARK_DS_WRITER_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

SPARK_DS_WRITER_VALIDATOR_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

sparkOptionsHandler - Variable in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader.CortexReadParameters

sparkOptionsHandler - Variable in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader.CortexReadStreamParameters

sparkOptionsHandler - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader.CortexReadParameters

sparkOptionsHandler - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters

sparkOptionsHandler - Variable in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

sparkOptionsHandler - Variable in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader.CortexReadParameters

sparkOptionsHandler - Variable in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

SparkOptionsHandler - Class in com.c12e.cortex.profiles.module

Simple handler of spark options for Cortex reader and writer builders

SparkOptionsHandler() - Constructor for class com.c12e.cortex.profiles.module.SparkOptionsHandler

sparkSession - Variable in class com.c12e.cortex.profiles.CortexSession.CortexSessionModule

sparkVersion - Variable in class com.c12e.cortex.profiles.version.EnvironmentCortexVersions

STORAGE_CLIENT_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

STORAGE_TYPE - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

STORAGE_TYPE_JSON_PATH - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

STORAGE_TYPE_PROP - Static variable in interface com.c12e.cortex.profiles.storage.PhoenixRemoteStorage

StringFeatureBuilder - Class in com.c12e.cortex.profiles.featurecatalog.featurebuilder

Implementation of a BaseFeatureBuilder for handling String data types.

StringFeatureBuilder() - Constructor for class com.c12e.cortex.profiles.featurecatalog.featurebuilder.StringFeatureBuilder

suggestedOptions(String) - Method in interface com.c12e.cortex.profiles.intercept.CortexInterceptor

Suggests default options for the interceptor.

suggestedOptions(String) - Method in class com.c12e.cortex.profiles.intercept.GraphingRequestInterceptor

suggestedOptions(String) - Method in class com.c12e.cortex.profiles.intercept.TracingTimingMethodInterceptor

SupportedCortexVersions - Class in com.c12e.cortex.profiles.version

Supported Cortex and Spark versions by this source

SupportedCortexVersions() - Constructor for class com.c12e.cortex.profiles.version.SupportedCortexVersions

T

targetPrimaryKey - Variable in class com.c12e.cortex.profiles.module.CortexDeltaMergeBuilder

Existing DeltaTable primary key

TIMESTAMP_FIELD - Static variable in class com.c12e.cortex.profiles.featurecatalog.DefaultFeatureReportCalculator

toDot(String) - Method in class com.c12e.cortex.profiles.intercept.GraphPlan

Create a dot notated file at any time from a CortexSession

toId(String, String) - Method in class com.c12e.cortex.profiles.intercept.GraphPlan

TOP_N - Static variable in class com.c12e.cortex.profiles.featurecatalog.featurebuilder.StringFeatureBuilder

TracingMethodInterceptor - Class in com.c12e.cortex.profiles.intercept

Intercepts proxied public methods and prints a trace of invocations

TracingMethodInterceptor() - Constructor for class com.c12e.cortex.profiles.intercept.TracingMethodInterceptor

TracingTimingMethodInterceptor - Class in com.c12e.cortex.profiles.intercept

Intercepts proxied methods and prints a trace of invocations with call duration.

TracingTimingMethodInterceptor() - Constructor for class com.c12e.cortex.profiles.intercept.TracingTimingMethodInterceptor

U

UnknownFeatureBuilder - Class in com.c12e.cortex.profiles.featurecatalog.featurebuilder

Implementation of a BaseFeatureBuilder for Features with unknown/unhandled data types.

UnknownFeatureBuilder(Logger) - Constructor for class com.c12e.cortex.profiles.featurecatalog.featurebuilder.UnknownFeatureBuilder

updateConnection(Connection) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

updateDataSource(DataSource) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

updateFeatureCatalog(String, String, Dataset<Row>, Boolean) - Method in class com.c12e.cortex.profiles.featurecatalog.DefaultCortexFeatureCatalog

updateFeatureCatalog(String, String, Dataset<Row>, Boolean) - Method in interface com.c12e.cortex.profiles.featurecatalog.FeatureCatalog

Updates the set of Feature's associated with the DataSource

updateProfiles() - Method in class com.c12e.cortex.profiles.cli.ProfileCommand

updateProfileSchema(ProfileSchema) - Method in class com.c12e.cortex.profiles.catalog.CortexRemoteCatalog

V

validate(Object) - Method in interface com.c12e.cortex.profiles.validator.CortexValidator

Throws exception on validation failure

validate(Object) - Method in class com.c12e.cortex.profiles.validator.DataSourceWriteValidator

validate(Object) - Method in class com.c12e.cortex.profiles.validator.DefaultCortexValidator

validateConnection(DefaultCortexConnectionReader.CortexReadParameters) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader

validateConnection(DefaultCortexConnectionStreamReader.CortexReadStreamParameters) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader

validateConnection(DefaultCortexConnectionWriter.CortexWriteParameters) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter

validateDataSet(DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters, DataSource) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter

validateDataSet(DefaultCortexDataSourceWriter.CortexWriteParameters, DataSource) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter

validateDataSet(DefaultCortexProfileWriter.CortexWriteParameters, ProfileSchema) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter

validateDataSource(DefaultCortexDataSourceReader.CortexReadParameters) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader

validateProfileSchema(DefaultCortexProfileReader.CortexReadParameters) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader

ValidationUtils - Class in com.c12e.cortex.profiles.cli

Utility class for validating CLI options and parameters.

ValidationUtils() - Constructor for class com.c12e.cortex.profiles.cli.ValidationUtils

validWriteMode(String, CommandLine) - Static method in class com.c12e.cortex.profiles.cli.ValidationUtils

Verifies the string writeMode is a valid option, otherwise raises a CommandLine.ParameterException.

value() - Method in annotation type org.codehaus.jackson.annotate.JsonRawValue

Optional argument that defines whether this annotation is active or not.

VERSION_STORE_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

W

withConnection(Connection) - Method in interface com.c12e.cortex.profiles.module.connection.CortexConnectionReader

Override connection write

withConnection(Connection) - Method in interface com.c12e.cortex.profiles.module.connection.CortexConnectionStreamReader

Override connection write

withConnection(Connection) - Method in interface com.c12e.cortex.profiles.module.connection.CortexConnectionWriter

Override connection write

withConnection(Connection) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionReader.CortexReadParameters

withConnection(Connection) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionStreamReader.CortexReadStreamParameters

withConnection(Connection) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter.CortexWriteParameters

withDataSource(DataSource) - Method in interface com.c12e.cortex.profiles.module.datasource.CortexDataSourceReader

The DataSource to read from

withDataSource(DataSource) - Method in interface com.c12e.cortex.profiles.module.datasource.CortexDataSourceWriter

The DataSource to write to

withDataSource(DataSource) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader.CortexReadParameters

withDataSource(DataSource) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter.CortexWriteParameters

withDeltaMergeBuilder - Variable in class com.c12e.cortex.profiles.module.CortexDeltaMergeBuilder

Delta merge builder match clauses

withProfileSchema(ProfileSchema) - Method in interface com.c12e.cortex.profiles.module.profile.CortexProfileReader

\ The ProfileSchema to reader

withProfileSchema(ProfileSchema) - Method in interface com.c12e.cortex.profiles.module.profile.CortexProfileWriter

The ProfileSchema to write

withProfileSchema(ProfileSchema) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader.CortexReadParameters

withProfileSchema(ProfileSchema) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter.CortexWriteParameters

write() - Method in class com.c12e.cortex.profiles.CortexSession

write() - Method in interface com.c12e.cortex.profiles.CortexSparkReaderWriter

write(DefaultCortexConnectionWriter.CortexWriteParameters) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter

Write to a Cortex Connection using the builder instance

write(DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter

Write to a DataSource connection

write(DefaultCortexDataSourceWriter.CortexWriteParameters) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter

Write to a Cortex DataSource using the builder instance

write(DefaultCortexProfileWriter.CortexWriteParameters) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter

Write to a Cortex ProfileSchema using the builder instance

writeDataSource(CortexDataSourcePair, String, String) - Method in interface com.c12e.cortex.profiles.streamWriter.CortexSparkStreamWriter

writeDataSource(CortexDataSourcePair, String, String) - Method in class com.c12e.cortex.profiles.streamWriter.DefaultCortexSparkStreamWriter

Retrieve a builder for writing a streaming dataset to a DataSource

writeFile(String) - Method in class com.c12e.cortex.profiles.intercept.TracingTimingMethodInterceptor

WRITER_KEY - Static variable in class com.c12e.cortex.profiles.CortexSession

writerOptions - Variable in class com.c12e.cortex.profiles.module.job.BuildProfileJob

Expand on writer options

writerOptions - Variable in class com.c12e.cortex.profiles.module.job.IngestDataSourceJob

Expand on CortexDataSourceWriter writer options

writeStream() - Method in class com.c12e.cortex.profiles.CortexSession

writeStream() - Method in interface com.c12e.cortex.profiles.CortexSparkReaderWriter

writeStreamToDataSource(DefaultCortexDataSourceStreamWriter.CortexWriteStreamParameters, Connection) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceStreamWriter

writeToConnection(DefaultCortexConnectionWriter.CortexWriteParameters, Connection) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter

writeToConnection(Dataset<Row>, SaveMode, String[], Map<String, String>, String) - Method in class com.c12e.cortex.profiles.module.connection.DefaultCortexConnectionWriter

writeToDataSource(DefaultCortexDataSourceWriter.CortexWriteParameters, Connection) - Method in class com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceWriter

writeToProfileSchema(DefaultCortexProfileWriter.CortexWriteParameters, Connection) - Method in class com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter

A B C D E F G H I J L M N O P Q R S T U V W
All Classes All Packages