Class Db2As400RecordHandler

  • All Implemented Interfaces:
    com.amazonaws.services.lambda.runtime.RequestStreamHandler

    public class Db2As400RecordHandler
    extends JdbcRecordHandler
    • Constructor Detail

      • Db2As400RecordHandler

        public Db2As400RecordHandler​(Map<String,​String> configOptions)
      • Db2As400RecordHandler

        public Db2As400RecordHandler​(DatabaseConnectionConfig databaseConnectionConfig,
                                     Map<String,​String> configOptions)
        Constructs object of type JdbcRecordHandler.
        Parameters:
        databaseConnectionConfig -
    • Method Detail

      • buildSplitSql

        public PreparedStatement buildSplitSql​(Connection jdbcConnection,
                                               String catalogName,
                                               TableName tableName,
                                               org.apache.arrow.vector.types.pojo.Schema schema,
                                               Constraints constraints,
                                               Split split)
                                        throws SQLException
        Builds split SQL string and returns prepared statement.
        Specified by:
        buildSplitSql in class JdbcRecordHandler
        Parameters:
        jdbcConnection - jdbc connection. See Connection
        catalogName - Athena provided catalog name.
        tableName - database table name.
        schema - table schema.
        constraints - constraints to push down to the database.
        split - table split.
        Returns:
        Throws:
        SQLException