Interface CortexConnectionReader
-
- All Superinterfaces:
CortexReader<org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>,CortexConnectionReader>
- All Known Implementing Classes:
DefaultCortexConnectionReader.CortexReadParameters
public interface CortexConnectionReader extends CortexReader<org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>,CortexConnectionReader>
CortexReader extension
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description io.delta.tables.DeltaTable
loadDeltaTable()
Loads the data as a delta table ifContentType
is deltaCortexConnectionReader
schema(org.apache.spark.sql.types.StructType schema)
Override dataset schema when ableCortexConnectionReader
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
CortexConnectionReader schema(org.apache.spark.sql.types.StructType schema)
Override dataset schema when able- Parameters:
schema
-- Returns:
- this instance
-
loadDeltaTable
io.delta.tables.DeltaTable loadDeltaTable()
Loads the data as a delta table ifContentType
is delta- Returns:
- the delta table
-
withConnection
CortexConnectionReader withConnection(com.c12e.cortex.phoenix.Connection connection)
Override connection write- Parameters:
connection
-- Returns:
- this instance
-
-