public CreateStreamProcessorResult createStreamProcessor()

in src/main/java/com/amazonaws/kinesisvideo/parser/rekognition/processor/RekognitionStreamProcessor.java [102:126]

• 24 lines of code
• 1 McCabe index (conditional complexity)

    public CreateStreamProcessorResult createStreamProcessor() {
        final KinesisVideoStream kinesisVideoStream = new KinesisVideoStream()
                .withArn(kinesisVideoStreamArn);
        final StreamProcessorInput streamProcessorInput = new StreamProcessorInput()
                .withKinesisVideoStream(kinesisVideoStream);
        final KinesisDataStream kinesisDataStream = new KinesisDataStream()
                .withArn(kinesisDataStreamArn);
        final StreamProcessorOutput streamProcessorOutput = new StreamProcessorOutput()
                .withKinesisDataStream(kinesisDataStream);
        final FaceSearchSettings faceSearchSettings = new FaceSearchSettings()
                .withCollectionId(collectionId)
                .withFaceMatchThreshold(matchThreshold);
        final StreamProcessorSettings streamProcessorSettings = new StreamProcessorSettings()
                .withFaceSearch(faceSearchSettings);

        final CreateStreamProcessorResult createStreamProcessorResult =
                rekognitionClient.createStreamProcessor(new CreateStreamProcessorRequest()
                        .withInput(streamProcessorInput)
                        .withOutput(streamProcessorOutput)
                        .withSettings(streamProcessorSettings)
                        .withRoleArn(roleArn)
                        .withName(streamProcessorName));
        log.info("StreamProcessorArn : {} ", createStreamProcessorResult.getStreamProcessorArn());
        return createStreamProcessorResult;
    }