Package org.apache.pinot.tools.streams.githubevents

Class PullRequestMergedEventsStream

java.lang.Object

org.apache.pinot.tools.streams.githubevents.PullRequestMergedEventsStream

public class PullRequestMergedEventsStream
extends Object

Creates a Kafka producer, for given kafka broker list Continuously fetches github events data. Creates a PullRequestMergedEvent for each valid PR event. Publishes the PullRequestMergedEvent to the given kafka topic

Constructor Summary

Constructors

Constructor	Description
PullRequestMergedEventsStream(String schemaFilePath, String topicName, String kafkaBrokerList, String personalAccessToken)

Method Summary

Modifier and Type	Method	Description
void	execute()	Starts the stream.
static void	main(String[] args)
void	shutdown()	Shuts down the stream.
void	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PullRequestMergedEventsStream

public PullRequestMergedEventsStream(String schemaFilePath,
                                     String topicName,
                                     String kafkaBrokerList,
                                     String personalAccessToken)
                              throws Exception

Throws:

Exception

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

execute

public void execute()

Starts the stream. Adds shutdown hook.

shutdown

public void shutdown()
              throws IOException,
                     InterruptedException

Shuts down the stream.

Throws:

IOException

InterruptedException

start

public void start()