AWS Code Sample

The AWS Documentation website is getting a new look!
Try it now and let us know what you think. Switch to the new look >>

You can return to the original look by selecting English in the language selector above. demonstrates how to how to import a segment into Pinpoint.

/* * Copyright 2010-2019, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. * A copy of the License is located at * * * * or in the "license" file accompanying this file. This file is distributed * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ package com.example.pinpoint; import; import; import*; public class ImportSegment { public static void main(String[] args) { final String USAGE = "\n" + "ImportSegment - import a segment \n\n" + "Usage: ImportSegment <appId> <bucket> <key> <roleArn> \n\n" + "Where:\n" + " appId - the ID the application to create a segment for.\n\n" + " bucket - name of the s3 bucket that contains the segment definitons.\n\n" + " key - key of the s3 object " + " roleArn - ARN of the role that allows pinpoint to access S3"; if (args.length < 1) { System.out.println(USAGE); System.exit(1); } String appId = args[0]; String bucket = args[1]; String key = args[2]; String roleArn = args[3]; PinpointClient pinpoint = PinpointClient.builder().region(Region.US_EAST_1).build(); ImportJobResponse response = createImportSegment(pinpoint, appId, bucket, key, roleArn); System.out.println("Import job for " + bucket + " submitted."); System.out.println("See application " + response.applicationId() + " for import job status."); } public static ImportJobResponse createImportSegment(PinpointClient client, String appId, String bucket, String key, String roleArn) { // Create the job. ImportJobRequest importRequest = ImportJobRequest.builder() .defineSegment(true) .registerEndpoints(true) .roleArn(roleArn) .format(Format.JSON) .s3Url("s3://" + bucket + "/" + key) .build(); CreateImportJobRequest jobRequest = CreateImportJobRequest.builder() .importJobRequest(importRequest) .applicationId(appId) .build(); CreateImportJobResponse jobResponse = client.createImportJob(jobRequest); return jobResponse.importJobResponse(); } }

Sample Details

Service: pinpoint

Last tested: 2019-06-01

Author: jschwarzwalder AWS

Type: full-example

On this page: