Interface CortexConnectionReader

    • 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 if ContentType is delta
        Returns:
        the delta table
      • withConnection

        CortexConnectionReader withConnection​(com.c12e.cortex.phoenix.Connection connection)
        Override connection write
        Parameters:
        connection -
        Returns:
        this instance