public static void main()

in quickstart-flink/quickstart-connector/src/main/java/org/apache/streampark/flink/quickstart/connector/HttpJavaApp.java [30:36]

• 7 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);
        DataStreamSource<Entity> source = context.getJavaEnv().addSource(new MyDataSource());
        new HttpSink(context).get(source.map(x -> String.format("http://www.qq.com?id=%d", x.userId)));
        context.start();
    }