public void run()

in demo-apps/demo-kinesis-driver/src/main/java/com/amazonaws/services/kinesisanalytics/sources/RandEmployeeInfoSource.java [47:59]

• 10 lines of code
• 3 McCabe index (conditional complexity)

    public void run(SourceContext<EmployeeInfo> sourceContext) throws Exception {
        while(isRunning) {
            EmployeeInfo ei = getNextEmployee();

            sourceContext.collectWithTimestamp(ei, ei.getEventtimestamp());

            if(ei.getEventtimestamp() % WATERMARK_GEN_PERIOD == 0) {
                sourceContext.emitWatermark(new Watermark(ei.getEventtimestamp()));
            }

            Thread.sleep(SLEEP_PERIOD);
        }
    }