private static DataStream createSourceFromApplicationProperties()

in kinesis-data-analytics-sse/src/main/java/com/amazonaws/services/kinesisanalytics/SSEConsumer.java [33:36]

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

    private static DataStream<String> createSourceFromApplicationProperties(final StreamExecutionEnvironment env, final Logger logger) throws IOException {
        Map<String, Properties> applicationProperties = KinesisAnalyticsRuntime.getApplicationProperties();
        return env.addSource(new SSESource(applicationProperties.get(SSE_SOURCE_PROPERTIES), logger)).name("SSE Source").uid("SSE Source").setParallelism(1);
    }