public static void main()

in quickstart-flink/quickstart-connector/src/main/java/org/apache/streampark/flink/quickstart/connector/DorisJavaApp.java [32:43]

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

    public static void main(String[] args) {
        StreamEnvConfig envConfig = new StreamEnvConfig(args, null);
        StreamingContext context = new StreamingContext(envConfig);
        DataStream<String> source = new KafkaJavaSource<String>(context)
                .getDataStream()
                .map((MapFunction<KafkaRecord<String>, String>) KafkaRecord::value)
                .returns(String.class);

        new DorisSink<String>(context).sink(source);

        context.start();
    }