Package com.c12e.cortex.profiles.module.profile

Class DefaultCortexProfileReader

java.lang.Object

com.c12e.cortex.profiles.module.profile.DefaultCortexProfileReader

All Implemented Interfaces:

CortexModule<CortexProfileReader>, CortexProfileReaderModule

public class DefaultCortexProfileReader
extends java.lang.Object
implements CortexProfileReaderModule

Default implementation of CortexProfileReaderModule

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	DefaultCortexProfileReader.CortexReadParameters

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DefaultCortexProfileReader(CortexContext cortexContext, com.c12e.cortex.phoenix.Catalog catalog, CortexValidator validator, PhoenixRemoteStorage phoenixRemoteStorage, CortexConnectionReaderModule cortexConnectionReaderModule)

Method Summary

Modifier and Type	Method	Description
CortexProfileReader	getBuilder()	Create module specific builder
protected com.c12e.cortex.phoenix.ProfileSchema	getProfileSchema(DefaultCortexProfileReader.CortexReadParameters cortexReadParameters)
protected com.c12e.cortex.phoenix.Connection	getReadConnection(java.lang.String project, java.lang.String profileSchemaName)
io.delta.tables.DeltaTable	read(DefaultCortexProfileReader.CortexReadParameters cortexReadParameters)	Read from a Cortex ProfileSchema using the builder instance
protected io.delta.tables.DeltaTable	readFromProfileSchema(DefaultCortexProfileReader.CortexReadParameters readParameters, com.c12e.cortex.phoenix.Connection phoenixProfileConnection)
protected void	validateProfileSchema(DefaultCortexProfileReader.CortexReadParameters readParameters)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultCortexProfileReader

@Inject
protected DefaultCortexProfileReader(CortexContext cortexContext,
                                     com.c12e.cortex.phoenix.Catalog catalog,
                                     CortexValidator validator,
                                     PhoenixRemoteStorage phoenixRemoteStorage,
                                     CortexConnectionReaderModule cortexConnectionReaderModule)

Method Detail

getProfileSchema

protected com.c12e.cortex.phoenix.ProfileSchema getProfileSchema(DefaultCortexProfileReader.CortexReadParameters cortexReadParameters)

validateProfileSchema

protected void validateProfileSchema(DefaultCortexProfileReader.CortexReadParameters readParameters)

getReadConnection

protected com.c12e.cortex.phoenix.Connection getReadConnection(java.lang.String project,
                                                               java.lang.String profileSchemaName)

readFromProfileSchema

protected io.delta.tables.DeltaTable readFromProfileSchema(DefaultCortexProfileReader.CortexReadParameters readParameters,
                                                           com.c12e.cortex.phoenix.Connection phoenixProfileConnection)

read

public io.delta.tables.DeltaTable read(DefaultCortexProfileReader.CortexReadParameters cortexReadParameters)

Read from a Cortex ProfileSchema using the builder instance

Parameters:

cortexReadParameters - builder instance

getBuilder

public CortexProfileReader getBuilder()

Description copied from interface: CortexModule

Create module specific builder

Specified by:

getBuilder in interface CortexModule<CortexProfileReader>

Returns:

builder instance