parser-java/kvs-archived-media-rekognition-label-detection-sample/src/main/java/com/amazonaws/kinesisvideo/workers/GetMediaForFragmentListBatchWorker.java [28:66]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public GetMediaForFragmentListBatchWorker(final String streamName, final List<String> fragmentNumbers,
                                              final AWSCredentialsProvider awsCredentialsProvider, final String endPoint,
                                              final Regions region, final MkvElementVisitor elementVisitor) {
        super(region, awsCredentialsProvider, streamName);
        this.fragmentNumbers = fragmentNumbers;

        this.elementVisitor = elementVisitor;
        amazonKinesisVideoArchivedMedia = AmazonKinesisVideoArchivedMediaClient
                .builder()
                .withCredentials(awsCredentialsProvider)
                .withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(endPoint, region.getName()))
                .build();
    }

    public static GetMediaForFragmentListBatchWorker create(final String streamName, final List<String> fragmentNumbers,
                                                            final AWSCredentialsProvider awsCredentialsProvider,
                                                            final Regions region,
                                                            final AmazonKinesisVideo amazonKinesisVideo,
                                                            final MkvElementVisitor elementVisitor) {
        final GetDataEndpointRequest request = new GetDataEndpointRequest()
                .withAPIName(APIName.GET_MEDIA_FOR_FRAGMENT_LIST).withStreamName(streamName);
        final String endpoint = amazonKinesisVideo.getDataEndpoint(request).getDataEndpoint();
        return new GetMediaForFragmentListBatchWorker(
                streamName, fragmentNumbers, awsCredentialsProvider, endpoint, region, elementVisitor);
    }

    @Override
    public void run() {
        try {
            log.info("Start GetMediaForFragmentListBatch worker on stream {}", streamName);
            final GetMediaForFragmentListResult result = amazonKinesisVideoArchivedMedia.getMediaForFragmentList(
                    new GetMediaForFragmentListRequest()
                            .withFragments(fragmentNumbers)
                            .withStreamName(streamName));

            log.info("GetMediaForFragmentListBatch called on stream {} response {} requestId {}",
                    streamName,
                    result.getSdkHttpMetadata().getHttpStatusCode(),
                    result.getSdkResponseMetadata().getRequestId());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



parser-java/kvs-archived-media-retrieval-sample/src/main/java/com/amazonaws/kinesisvideo/workers/GetMediaForFragmentListBatchWorker.java [29:67]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public GetMediaForFragmentListBatchWorker(final String streamName, final List<String> fragmentNumbers,
                                              final AWSCredentialsProvider awsCredentialsProvider, final String endPoint,
                                              final Regions region, final MkvElementVisitor elementVisitor) {
        super(region, awsCredentialsProvider, streamName);
        this.fragmentNumbers = fragmentNumbers;

        this.elementVisitor = elementVisitor;
        amazonKinesisVideoArchivedMedia = AmazonKinesisVideoArchivedMediaClient
                .builder()
                .withCredentials(awsCredentialsProvider)
                .withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(endPoint, region.getName()))
                .build();
    }

    public static GetMediaForFragmentListBatchWorker create(final String streamName, final List<String> fragmentNumbers,
                                                            final AWSCredentialsProvider awsCredentialsProvider,
                                                            final Regions region,
                                                            final AmazonKinesisVideo amazonKinesisVideo,
                                                            final MkvElementVisitor elementVisitor) {
        final GetDataEndpointRequest request = new GetDataEndpointRequest()
                .withAPIName(APIName.GET_MEDIA_FOR_FRAGMENT_LIST).withStreamName(streamName);
        final String endpoint = amazonKinesisVideo.getDataEndpoint(request).getDataEndpoint();
        return new GetMediaForFragmentListBatchWorker(
                streamName, fragmentNumbers, awsCredentialsProvider, endpoint, region, elementVisitor);
    }

    @Override
    public void run() {
        try {
            log.info("Start GetMediaForFragmentListBatch worker on stream {}", streamName);
            final GetMediaForFragmentListResult result = amazonKinesisVideoArchivedMedia.getMediaForFragmentList(
                    new GetMediaForFragmentListRequest()
                            .withFragments(fragmentNumbers)
                            .withStreamName(streamName));

            log.info("GetMediaForFragmentListBatch called on stream {} response {} requestId {}",
                    streamName,
                    result.getSdkHttpMetadata().getHttpStatusCode(),
                    result.getSdkResponseMetadata().getRequestId());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -