rohityadav1993 commented on code in PR #13837: URL: https://github.com/apache/pinot/pull/13837#discussion_r1740103462
########## pinot-connectors/pinot-flink-connector/README.md: ########## @@ -39,9 +44,34 @@ srcDs.addSink(new PinotSinkFunction<>(new PinotRowRecordConverter(TEST_TYPE_INFO execEnv.execute(); ``` +## Quick start for realtime(upsert) table backfill +```java +// Set up flink env and data source +StreamExecutionEnvironment execEnv = StreamExecutionEnvironment.getExecutionEnvironment(); +execEnv.setParallelism(2); // mandatory for upsert tables wi +DataStream<Row> srcDs = execEnv.fromCollection(data).returns(TEST_TYPE_INFO) + +// Create a ControllerRequestClient to fetch Pinot schema and table config +HttpClient httpClient = HttpClient.getInstance(); +ControllerRequestClient client = new ControllerRequestClient( +ControllerRequestURLBuilder.baseUrl(DEFAULT_CONTROLLER_URL), httpClient); + +// fetch Pinot schema +Schema schema = PinotConnectionUtils.getSchema(client, "starbucksStores"); +// fetch Pinot table config +TableConfig tableConfig = PinotConnectionUtils.getTableConfig(client, "starbucksStores", "OFFLINE"); Review Comment: realtime -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org
