private void writeBatch()

in analytics/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java [81:102]

• 20 lines of code
• 4 McCabe index (conditional complexity)

    private void writeBatch(List<Record> recordsToSend) {
        WriteRecordsRequest writeRecordsRequest = new WriteRecordsRequest()
                .withDatabaseName(this.db)
                .withTableName(this.table)
                .withRecords(recordsToSend);

        try {
            WriteRecordsResult writeRecordsResult = this.writeClient.writeRecords(writeRecordsRequest);
            logger.debug("writeRecords Status: " + writeRecordsResult.getSdkHttpMetadata().getHttpStatusCode());
            emptyListTimestamp = System.currentTimeMillis();

        } catch (RejectedRecordsException e) {
            List<RejectedRecord> rejectedRecords = e.getRejectedRecords();
            logger.warn("Rejected Records -> " + rejectedRecords.size());
            for (int i = rejectedRecords.size() - 1; i >= 0; i--) {
                logger.warn("Discarding Malformed Record -> {}", rejectedRecords.get(i).toString());
                logger.warn("Rejected Record Reason -> {}", rejectedRecords.get(i).getReason());
            }
        } catch (Exception e) {
            logger.error("Error: " + e);
        }
    }