public void process()

in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/PrintSupplier.java [44:65]

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

        public void process(T data) {
            Properties header = context.getHeader();
            Object startTime = header.get(Constant.WINDOW_START_TIME);
            Object endTime = header.get(Constant.WINDOW_END_TIME);
            if (startTime == null || endTime == null) {
                String template = "(key=%s, value=%s)";

                Data<Object, T> result = new Data<>(this.context.getKey(), data, this.context.getDataTime(), header);
                String format = String.format(template, result.getKey(), data.toString());

                System.out.println(format);
            } else {
                String template = "[%s - %s](key=%s, value=%s)";
                String start = Utils.format((Long)startTime);
                String end = Utils.format((Long)endTime);

                String format = String.format(template, start, end, this.context.getKey(), data);
                System.out.println(format);
            }


        }