private static DataStream createSourceFromStaticConfig()

in src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingSinkJob.java [31:40]

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

    private static DataStream<String> createSourceFromStaticConfig(StreamExecutionEnvironment env) {

        Properties inputProperties = new Properties();
        inputProperties.setProperty(ConsumerConfigConstants.AWS_REGION, region);
        inputProperties.setProperty(ConsumerConfigConstants.STREAM_INITIAL_POSITION,
                "LATEST");
        return env.addSource(new FlinkKinesisConsumer<>(inputStreamName,
                new SimpleStringSchema(),
                inputProperties));
    }