public DynamicTableSource copy()

in src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQScanTableSource.java [164:186]

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

    public DynamicTableSource copy() {
        RocketMQScanTableSource tableSource =
                new RocketMQScanTableSource(
                        pollTime,
                        properties,
                        schema,
                        topic,
                        consumerGroup,
                        nameServerAddress,
                        accessKey,
                        secretKey,
                        tag,
                        sql,
                        stopInMs,
                        startMessageOffset,
                        startTime,
                        partitionDiscoveryIntervalMs,
                        consumerOffsetMode,
                        consumerOffsetTimestamp,
                        useNewApi);
        tableSource.metadataKeys = metadataKeys;
        return tableSource;
    }