All Classes Interface Summary Class Summary Annotation Types Summary
Class |
Description |
Application |
CLI application entrypoint for interacting with profiles, data sources, and feature catalog resources.
|
ArrayFeatureBuilder |
Implementation of a BaseFeatureBuilder for handling general Array types by wrapping an existing FeatureBuilder.
|
BaseCortexContext |
Default CortexContext, holds the context information for a CortexSession
|
BaseFeatureBuilder |
Base implementation of a FeatureBuilder that provides setters for Feature attributes, and
|
BuildProfileJob |
Job that builds a ProfileSchema
|
CommonOptionMixin |
Mixin meant to store common options for CLI commands, namely the "-p"/"--project" flag and a catch-all
List<String> args .
|
CortexAuthContext |
Holds the token retrieved from env var or spark session properties and decodes the user information
|
CortexCatalogReaderWriter |
Exposes the Cortex Catalog
|
CortexConnectionReader |
CortexReader extension
|
CortexConnectionReaderModule |
Module for reading a dataset from Cortex Connection
|
CortexConnectionStreamReader |
CortexReader extension
|
CortexConnectionStreamReaderModule |
Module for reading a dataset from Cortex Connection
|
CortexConnectionWriter |
CortexWriter extension
|
CortexConnectionWriterModule |
Module for writing a dataset to Cortex Connection
|
CortexContext |
Holds the context information for a CortexSession
|
CortexDataSourcePair |
|
CortexDataSourceReader |
CortexReader extension
|
CortexDataSourceReaderModule |
Module for reading a dataset from Cortex Connection
|
CortexDataSourceStreamWriter |
|
CortexDataSourceStreamWriterModule |
|
CortexDataSourceWriter |
CortexWriter extension
|
CortexDataSourceWriterModule |
Module for writing a dataset to Cortex DataSource
|
CortexDeltaMergeBuilder |
Handles a DeltaTable merge operation
|
CortexInterceptor |
Interface for Cortex specific MethodInterceptor 's that need to perform final operation after
the desired call stack has been captured.
|
CortexJobBuilder |
Exposes the Cortex Job Registry
|
CortexJobRegistry |
|
CortexModule<T> |
A built module to execute a Cortex process flow
|
CortexProfileReader |
CortexReader extension
|
CortexProfileReaderModule |
Module for reading a dataset from Cortex ProfileSchema
|
CortexProfileWriter |
CortexWriter extension
|
CortexProfileWriterModule |
Module for writing a dataset to Cortex ProfileSchema
|
CortexReader<ReturnType,T extends CortexReader> |
Common interface of reader builder parameters
|
CortexRemoteCatalog |
Catalog interface adapter to a graphql phoenix client
|
CortexRemoteStorageClient |
Client to Cortex Phoenix REST Service
|
CortexSecretsClient |
Client to Cortex Secrets Service
|
CortexSession |
CortexSession is a managed interface to Cortex which utilizes spark for custom processing of profile data.
|
CortexSession.CortexSessionModule |
Guice backed @see com.google.inject.Module handling configuration options for creating a CortexSession.
|
CortexSparkReader |
Interface to Cortex dataset readers.
|
CortexSparkReaderWriter |
Entrypoint into the cortex supported spark flows
|
CortexSparkStreamReader |
|
CortexSparkStreamWriter |
Interface to Cortex streaming dataset writer.
|
CortexSparkWriter |
Interface to Cortex dataset writers.
|
CortexValidator |
Validates a validatee
|
CortexVersionStore |
Stores the tracked Cortex and Spark dependency versions
|
CortexWriter<T extends CortexWriter> |
Common interface of writer builder parameters
|
DataSourceCommand |
|
DataSourceWriteValidator |
|
DefaultCortexConnectionReader |
Default implementation of DefaultCortexConnectionReader
|
DefaultCortexConnectionStreamReader |
|
DefaultCortexConnectionWriter |
Default implementation of CortexConnectionWriterModule
|
DefaultCortexDataSourceReader |
Default implementation of DefaultCortexDataSourceReader
|
DefaultCortexDataSourceStreamWriter |
|
DefaultCortexDataSourceWriter |
Default implementation of CortexDataSourceWriterModule
|
DefaultCortexFeatureCatalog |
|
DefaultCortexJobRegistry |
CortexJobRegistry implementation
|
DefaultCortexProfileReader |
Default implementation of CortexProfileReaderModule
|
DefaultCortexProfileWriter |
Default implementation of CortexProfileWriterModule
|
DefaultCortexSparkReader |
Default implementation with reader builder retrieval and mandatory options set.
|
DefaultCortexSparkStreamReader |
Default implementation with stream reader builder retrieval and mandatory options set.
|
DefaultCortexSparkStreamWriter |
Default implementation with stream writer builder retrieval and mandatory options set.
|
DefaultCortexSparkWriter |
Default implementation with writer builder retrieval and mandatory options set.
|
DefaultCortexValidator |
Default validator, always passes.
|
DefaultFeatureReportCalculator |
|
DriverLoadingJdbcAdapter |
JDBC Spark Adapter that supports parsing Connection Plugin Properties and attempts to modify the classpath.
|
EnvironmentCortexVersions |
Versions retrieved from the current processing environment
|
FeatureBuilder |
Interface for building a Cortex Feature corresponding to a Spark DataType and Cortex FeatureType .
|
FeatureCatalog |
Interface for service maintaining the set of Features associated with a DataSource.
|
FeatureReport |
POJO holding inferred feature information, a reference to the Dataset (sample) it was inferred from, and a separate
preview of the Dataset.
|
FeatureReportCalculator |
Interface for computing Feature information (@see FeatureReport) from a Cortex DataSource and source data.
|
FloatFeatureBuilder |
|
GeneratedPhoenixClient |
Client to remote phoenix service, exposes a GraphQL API
|
GraphingRequestInterceptor |
Intercepts proxied methods by scope and generates a dot notated request plan.
|
GraphPlan |
Storage for traced plan of a series of CortexSession requests
|
IngestDataSourceJob |
Ingest a DataSource
|
InjectLogger |
Annotation for Guice injection of logger instance, based on: https://github.com/google/guice/wiki/CustomInjections.
|
IntFeatureBuilder |
|
JacksonAnnotation |
Meta-annotation (annotations used on other annotations)
used for marking all annotations that are
part of Jackson package.
|
JdbcSparkAdapter |
Adapter utils for converting Cortex CData Connections to Spark properties.
|
JsonRawValue |
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 |
Java agent to add jar to classpath at runtime
|
LocalRemoteStorageClient |
Reads storage configuration from a DocumentContext
|
LocalSecretClient |
|
LocalSecretClient.LocalSecrets |
|
LogTypeListener |
|
NonLoadingJdbcAdapter |
JDBC Spark Adapter that supports parsing Connection Plugin Properties, but DOES NOT attempt to modify the classpath.
|
PhoenixRemoteStorage |
Interface storing and providing remote storage configuration objects for Cortex.
|
ProfileCommand |
|
RemoteStorageEnvLocator |
Provide remote storage configuration for Cortex.
|
SparkOptionsHandler |
Simple handler of spark options for Cortex reader and writer builders
|
StringFeatureBuilder |
|
SupportedCortexVersions |
Supported Cortex and Spark versions by this source
|
TracingMethodInterceptor |
Intercepts proxied public methods and prints a trace of invocations
|
TracingTimingMethodInterceptor |
Intercepts proxied methods and prints a trace of invocations with call duration.
|
UnknownFeatureBuilder |
|
ValidationUtils |
Utility class for validating CLI options and parameters.
|