StreamGitHubEventsCommand (Pinot Tools 0.9.2 API)

java.lang.Object
- org.apache.pinot.tools.AbstractBaseCommand
- - org.apache.pinot.tools.admin.command.AbstractBaseAdminCommand
  - - org.apache.pinot.tools.admin.command.StreamGitHubEventsCommand

All Implemented Interfaces:

Callable<Integer>, Command
```
public class StreamGitHubEventsCommand
extends AbstractBaseAdminCommand
implements Command
```
Command to stream GitHub events into a kafka topic

Field Summary
- Fields inherited from class org.apache.pinot.tools.AbstractBaseCommand
  DEFAULT_CLUSTER_NAME, DEFAULT_ZK_ADDRESS

Constructor Summary

Constructors
Constructor Description

StreamGitHubEventsCommand()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`cleanup()`
`String`	`description()`
`boolean`	`execute()`
`boolean`	`getHelp()`
`String`	`getName()`
`void`	`setEventType(String eventType)`
`void`	`setKafkaBrokerList(String kafkaBrokerList)`
`void`	`setPersonalAccessToken(String personalAccessToken)`
`void`	`setSchemaFile(String schemaFile)`
`void`	`setTopic(String topic)`
`String`	`toString()`

Methods inherited from class org.apache.pinot.tools.admin.command.AbstractBaseAdminCommand
getPID, savePID, sendDeleteRequest, sendPostRequest, sendRequest, sendRequest

Methods inherited from class org.apache.pinot.tools.AbstractBaseCommand
printExamples, printUsage

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.pinot.tools.Command
call, printUsage

Constructor Detail
- StreamGitHubEventsCommand
```
public StreamGitHubEventsCommand()
```

Method Detail

setPersonalAccessToken

public void setPersonalAccessToken(String personalAccessToken)

setKafkaBrokerList

public void setKafkaBrokerList(String kafkaBrokerList)

setTopic

public void setTopic(String topic)

setEventType

public void setEventType(String eventType)

setSchemaFile

public void setSchemaFile(String schemaFile)

getHelp
```
public boolean getHelp()
```
Specified by:

getHelp in interface Command

getName
```
public String getName()
```
Overrides:

getName in class AbstractBaseCommand

toString
```
public String toString()
```
Overrides:

toString in class Object

cleanup
```
public void cleanup()
```
Overrides:

cleanup in class AbstractBaseCommand

description
```
public String description()
```
Specified by:

description in interface Command

execute
```
public boolean execute()
                throws Exception
```
Specified by:

execute in interface Command

Throws:

Exception