public RocketMQScanTableSource()

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

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

    public RocketMQScanTableSource(
            long pollTime,
            DescriptorProperties properties,
            TableSchema schema,
            String topic,
            String consumerGroup,
            String nameServerAddress,
            String accessKey,
            String secretKey,
            String tag,
            String sql,
            long stopInMs,
            long startMessageOffset,
            long startTime,
            long partitionDiscoveryIntervalMs,
            String consumerOffsetMode,
            long consumerOffsetTimestamp,
            boolean useNewApi) {
        this.pollTime = pollTime;
        this.properties = properties;
        this.schema = schema;
        this.topic = topic;
        this.consumerGroup = consumerGroup;
        this.nameServerAddress = nameServerAddress;
        this.accessKey = accessKey;
        this.secretKey = secretKey;
        this.tag = tag;
        this.sql = sql;
        this.stopInMs = stopInMs;
        this.startMessageOffset = startMessageOffset;
        this.startTime = startTime;
        this.partitionDiscoveryIntervalMs = partitionDiscoveryIntervalMs;
        this.useNewApi = useNewApi;
        this.metadataKeys = Collections.emptyList();
        this.consumerOffsetMode = consumerOffsetMode;
        this.consumerOffsetTimestamp = consumerOffsetTimestamp;
    }