Interface SupportsSaveToJDBC

All Superinterfaces:
AutoCloseable, Closeable, Operator, OperatorPipelineV3, Serializable, org.apache.spark.sql.api.java.UDF2<org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>,Boolean,Void>, Writer

@DeveloperApi @FeatureBeforeCall public interface SupportsSaveToJDBC extends Writer
The mix-in interface for Writer. Dataset writers can implement this interface to support saving the content of the DataFrame to an external database table via JDBC. This feature is invoked before applying Writer's call function.
  • Method Summary

    Modifier and Type
    Method
    Description
    save(String url, String table, Properties connectionProperties)
    Sets the target database connection with which the DataFrame will be saved.

    Methods inherited from interface java.io.Closeable

    close

    Methods inherited from interface com.atgenomix.seqslab.piper.plugin.api.Operator

    getName, getOperatorContext

    Methods inherited from interface org.apache.spark.sql.api.java.UDF2

    call

    Methods inherited from interface com.atgenomix.seqslab.piper.plugin.api.writer.Writer

    getDataSource, init
  • Method Details

    • save

      Writer save(String url, String table, Properties connectionProperties)
      Sets the target database connection with which the DataFrame will be saved.
      Parameters:
      url - JDBC database url of the form jdbc:subprotocol:subname
      table - Name of the table in the external database.
      connectionProperties - Connection arguments, a list of arbitrary string key/value
      Returns:
      The writer object itself