org.apache.pinot.tools.streams

Class MeetupRsvpStream

java.lang.Object

org.apache.pinot.tools.streams.MeetupRsvpStream

public class MeetupRsvpStream
extends Object

Constructor Summary

Constructors

Constructor and Description
MeetupRsvpStream()
MeetupRsvpStream(boolean partitionByKey)

Method Summary

Modifier and Type	Method and Description
void	run()
void	stopPublishing()

Methods inherited from class java.lang.Object

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

Constructor Detail

MeetupRsvpStream

public MeetupRsvpStream()
                 throws Exception

Throws:

Exception

MeetupRsvpStream

public MeetupRsvpStream(boolean partitionByKey)
                 throws Exception

Throws:

Exception

Method Detail

stopPublishing

public void stopPublishing()

run

public void run()