public long getTimestamp()

in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SourceSupplier.java [67:77]

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

        public long getTimestamp(MessageExt originData, TimeType timeType) {
            if (timeType == null) {
                return System.currentTimeMillis();
            } else if (timeType == TimeType.EVENT_TIME) {
                return originData.getBornTimestamp();
            } else if (timeType == TimeType.PROCESS_TIME) {
                return System.currentTimeMillis();
            } else {
                throw new IllegalStateException("unknown time type: " + timeType.getClass().getName());
            }
        }