Package com.c12e.cortex.profiles.module.datasource

Class DefaultCortexDataSourceReader.CortexReadParameters

java.lang.Object

com.c12e.cortex.profiles.module.datasource.DefaultCortexDataSourceReader.CortexReadParameters

All Implemented Interfaces:

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

Enclosing class:

DefaultCortexDataSourceReader

public class DefaultCortexDataSourceReader.CortexReadParameters
extends java.lang.Object
implements CortexDataSourceReader

Field Summary

Fields

Modifier and Type	Field	Description
protected com.c12e.cortex.phoenix.DataSource	dataSource
protected java.lang.String	dataSourceName
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
CortexDataSourceReader	option(java.lang.String key, java.lang.String value)	Overwrites value at key
CortexDataSourceReader	options(java.util.Map<java.lang.String,java.lang.String> readOptions)	Merges new options with current options
CortexDataSourceReader	project(java.lang.String project)	Sets the project
CortexDataSourceReader	resourceName(java.lang.String resourceName)	Sets the resource to write to
CortexDataSourceReader	withDataSource(com.c12e.cortex.phoenix.DataSource dataSource)	The DataSource to read from

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

dataSourceName

protected java.lang.String dataSourceName

dataSource

protected com.c12e.cortex.phoenix.DataSource dataSource

sparkOptionsHandler

protected SparkOptionsHandler sparkOptionsHandler

Constructor Detail

CortexReadParameters

public CortexReadParameters()

Method Detail

resourceName

public CortexDataSourceReader 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,CortexDataSourceReader>

Returns:

this instance

options

public CortexDataSourceReader 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,CortexDataSourceReader>

Returns:

this instance

option

public CortexDataSourceReader 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,CortexDataSourceReader>

Returns:

this instance

project

public CortexDataSourceReader project(java.lang.String project)

Description copied from interface: CortexReader

Sets the project

Specified by:

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

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,CortexDataSourceReader>

withDataSource

public CortexDataSourceReader withDataSource(com.c12e.cortex.phoenix.DataSource dataSource)

Description copied from interface: CortexDataSourceReader

The DataSource to read from

Specified by:

withDataSource in interface CortexDataSourceReader

Returns:

this instance