src/main/java/com/amazonaws/services/neptune/profiles/neptune_ml/NeptuneMachineLearningExportEventHandlerV1.java [228:262]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        S3ObjectInfo s3ObjectInfo = outputS3ObjectInfo.withNewKeySuffix(filename);

        try {
            UploadFileRequest uploadFileRequest = UploadFileRequest.builder()
                    .source(trainingJobConfigurationFile)
                    .putObjectRequest(configureServerSideEncryption(PutObjectRequest.builder(), sseKmsKeyId)
                            .bucket(s3ObjectInfo.bucket())
                            .key(s3ObjectInfo.key())
                            .tagging(ExportToS3NeptuneExportEventHandler.createObjectTags(profiles))
                            .build())
                    .build();

            FileUpload upload = transferManager.uploadFile(uploadFileRequest);

            upload.completionFuture().join();

        } catch (CompletionException | CancellationException e) {
            logger.warn(e.getMessage());
            Thread.currentThread().interrupt();
        }
    }

    private S3ObjectInfo calculateOutputS3Path(File outputDirectory) {
        S3ObjectInfo outputBaseS3ObjectInfo = new S3ObjectInfo(outputS3Path);
        if (createExportSubdirectory) {
            return outputBaseS3ObjectInfo.withNewKeySuffix(outputDirectory.getName());
        } else {
            return outputBaseS3ObjectInfo;
        }
    }

    private JsonGenerator createJsonGenerator(Writer writer) throws IOException {
        JsonGenerator generator = new JsonFactory().createGenerator(writer);
        generator.setPrettyPrinter(new DefaultPrettyPrinter());
        return generator;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/amazonaws/services/neptune/profiles/neptune_ml/NeptuneMachineLearningExportEventHandlerV2.java [229:263]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        S3ObjectInfo s3ObjectInfo = outputS3ObjectInfo.withNewKeySuffix(filename);

        try {
            UploadFileRequest uploadFileRequest = UploadFileRequest.builder()
                    .source(trainingJobConfigurationFile)
                    .putObjectRequest(configureServerSideEncryption(PutObjectRequest.builder(), sseKmsKeyId)
                            .bucket(s3ObjectInfo.bucket())
                            .key(s3ObjectInfo.key())
                            .tagging(ExportToS3NeptuneExportEventHandler.createObjectTags(profiles))
                            .build())
                    .build();

            FileUpload upload = transferManager.uploadFile(uploadFileRequest);

            upload.completionFuture().join();

        } catch (CompletionException | CancellationException e) {
            logger.warn(e.getMessage());
            Thread.currentThread().interrupt();
        }
    }

    private S3ObjectInfo calculateOutputS3Path(File outputDirectory) {
        S3ObjectInfo outputBaseS3ObjectInfo = new S3ObjectInfo(outputS3Path);
        if (createExportSubdirectory) {
            return outputBaseS3ObjectInfo.withNewKeySuffix(outputDirectory.getName());
        } else {
            return outputBaseS3ObjectInfo;
        }
    }

    private JsonGenerator createJsonGenerator(Writer writer) throws IOException {
        JsonGenerator generator = new JsonFactory().createGenerator(writer);
        generator.setPrettyPrinter(new DefaultPrettyPrinter());
        return generator;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -