This is an automated email from the ASF dual-hosted git repository.
nehapawar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new d454acd adding a constructor override (#8454)
d454acd is described below
commit d454acdd44d4bc24de1dd1bfa8668fb445518919
Author: Navina Ramesh <[email protected]>
AuthorDate: Thu Mar 31 18:42:20 2022 -0700
adding a constructor override (#8454)
Co-authored-by: Navina Ramesh <[email protected]>
---
.../githubevents/PullRequestMergedEventsStream.java | 15 +++++++++++++++
1 file changed, 15 insertions(+)
diff --git
a/pinot-tools/src/main/java/org/apache/pinot/tools/streams/githubevents/PullRequestMergedEventsStream.java
b/pinot-tools/src/main/java/org/apache/pinot/tools/streams/githubevents/PullRequestMergedEventsStream.java
index ab45f45..a1703d8 100644
---
a/pinot-tools/src/main/java/org/apache/pinot/tools/streams/githubevents/PullRequestMergedEventsStream.java
+++
b/pinot-tools/src/main/java/org/apache/pinot/tools/streams/githubevents/PullRequestMergedEventsStream.java
@@ -64,6 +64,21 @@ public class PullRequestMergedEventsStream {
private StreamDataProducer _producer;
+ public PullRequestMergedEventsStream(File schemaFile, String topicName,
String personalAccessToken,
+ StreamDataProducer producer)
+ throws Exception {
+ _service = Executors.newFixedThreadPool(2);
+ try {
+ _avroSchema =
AvroUtils.getAvroSchemaFromPinotSchema(org.apache.pinot.spi.data.Schema.fromFile(schemaFile));
+ } catch (Exception e) {
+ LOGGER.error("Got exception while reading Pinot schema from file: [" +
schemaFile.getName() + "]");
+ throw e;
+ }
+ _topicName = topicName;
+ _gitHubAPICaller = new GitHubAPICaller(personalAccessToken);
+ _producer = producer;
+ }
+
public PullRequestMergedEventsStream(String schemaFilePath, String
topicName, String personalAccessToken,
StreamDataProducer producer)
throws Exception {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
