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

Class DefaultCortexProfileReader.CortexReadParameters

java.lang.Object

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

All Implemented Interfaces:

CortexReader<io.delta.tables.DeltaTable,CortexProfileReader>, CortexProfileReader

Enclosing class:

DefaultCortexProfileReader

public class DefaultCortexProfileReader.CortexReadParameters
extends java.lang.Object
implements CortexProfileReader

Field Summary

Fields

Modifier and Type	Field	Description
protected com.c12e.cortex.phoenix.ProfileSchema	profileSchema
protected java.lang.String	profileSchemaName
protected java.lang.String	project
protected SparkOptionsHandler	sparkOptionsHandler

Constructor Summary

Constructors

Constructor	Description
CortexReadParameters()

Method Summary

Modifier and Type	Method	Description
io.delta.tables.DeltaTable	load()	Completes building and begins read process
CortexProfileReader	option(java.lang.String key, java.lang.String value)	Overwrites value at key
CortexProfileReader	options(java.util.Map<java.lang.String,java.lang.String> readOptions)	Merges new options with current options
CortexProfileReader	project(java.lang.String project)	Sets the project
CortexProfileReader	resourceName(java.lang.String resourceName)	Sets the resource to write to
CortexProfileReader	withProfileSchema(com.c12e.cortex.phoenix.ProfileSchema profileSchema)	\ The ProfileSchema to reader

Methods inherited from class java.lang.Object

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

Field Detail

project

protected java.lang.String project

profileSchemaName

protected java.lang.String profileSchemaName

profileSchema

protected com.c12e.cortex.phoenix.ProfileSchema profileSchema

sparkOptionsHandler

protected SparkOptionsHandler sparkOptionsHandler

Constructor Detail

CortexReadParameters

public CortexReadParameters()

Method Detail

resourceName

public CortexProfileReader resourceName(java.lang.String resourceName)

Description copied from interface: CortexReader

Sets the resource to write to

Specified by:

resourceName in interface CortexReader<io.delta.tables.DeltaTable,CortexProfileReader>

Returns:

this instance

options

public CortexProfileReader options(java.util.Map<java.lang.String,java.lang.String> readOptions)

Description copied from interface: CortexReader

Merges new options with current options

Specified by:

options in interface CortexReader<io.delta.tables.DeltaTable,CortexProfileReader>

Returns:

this instance

option

public CortexProfileReader option(java.lang.String key,
                                  java.lang.String value)

Description copied from interface: CortexReader

Overwrites value at key

Specified by:

option in interface CortexReader<io.delta.tables.DeltaTable,CortexProfileReader>

Returns:

this instance

project

public CortexProfileReader project(java.lang.String project)

Description copied from interface: CortexReader

Sets the project

Specified by:

project in interface CortexReader<io.delta.tables.DeltaTable,CortexProfileReader>

Returns:

this instance

load

public io.delta.tables.DeltaTable load()

Description copied from interface: CortexReader

Completes building and begins read process

Specified by:

load in interface CortexReader<io.delta.tables.DeltaTable,CortexProfileReader>

withProfileSchema

public CortexProfileReader withProfileSchema(com.c12e.cortex.phoenix.ProfileSchema profileSchema)

Description copied from interface: CortexProfileReader

\ The ProfileSchema to reader

Specified by:

withProfileSchema in interface CortexProfileReader

Returns:

this instance