Package com.c12e.cortex.profiles.module.connection

Interface CortexConnectionStreamReader

All Superinterfaces:

CortexReader<CortexDataSourcePair,CortexConnectionStreamReader>

All Known Implementing Classes:

DefaultCortexConnectionStreamReader.CortexReadStreamParameters

public interface CortexConnectionStreamReader
extends CortexReader<CortexDataSourcePair,CortexConnectionStreamReader>

CortexReader extension

Method Summary

Modifier and Type	Method	Description
CortexConnectionStreamReader	schema(org.apache.spark.sql.types.StructType schema)	Override dataset schema when able
CortexConnectionStreamReader	withConnection(com.c12e.cortex.phoenix.Connection connection)	Override connection write

Methods inherited from interface com.c12e.cortex.profiles.module.CortexReader

load, option, options, project, resourceName

Method Detail

schema

CortexConnectionStreamReader schema(org.apache.spark.sql.types.StructType schema)

Override dataset schema when able

Parameters:

schema -

Returns:

this instance

withConnection

CortexConnectionStreamReader withConnection(com.c12e.cortex.phoenix.Connection connection)

Override connection write

Parameters:

connection -

Returns:

this instance