public static void main()

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

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

    public static void main(final String[] args) throws Exception {
        Logger logger = LoggerFactory.getLogger(SSEConsumer.class);
        // set up the streaming execution environment
        final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        DataStream<String> input = createSourceFromApplicationProperties(env, logger);
        logger.info("SseEventSource Input stream created: " + input.toString());
        input.addSink(createSinkFromApplicationConfig()).name("Kinesis Sink").uid("Kinesis Sink");
        logger.info("SseEventSource Sink Added");
        env.execute("Server Sent Events");
    }