The part to the right of new is us calling the Constructor for the Scanner class and passing it a single argument, in this case System.in. Let's make a new class called Book that has the following ...

We are leveraging flink-connector-clickhouse to read and write data to clickhouse from custom written DataStream Api KeyedCoProcessFunction. Implementation uses AbstractClickHouseOutputFormat builder ...