Package org.apache.pinot.tools.streams

Class MeetupRsvpJsonStream

java.lang.Object

org.apache.pinot.tools.streams.MeetupRsvpStream

org.apache.pinot.tools.streams.MeetupRsvpJsonStream

public class MeetupRsvpJsonStream
extends MeetupRsvpStream

Field Summary

Fields inherited from class org.apache.pinot.tools.streams.MeetupRsvpStream

_client, _keepPublishing, _partitionByKey, _producer, LOGGER

Constructor Summary

Constructors

Constructor	Description
MeetupRsvpJsonStream()
MeetupRsvpJsonStream(boolean partitionByKey)

Method Summary

Modifier and Type	Method	Description
protected javax.websocket.MessageHandler.Whole<String>	getMessageHandler()

Methods inherited from class org.apache.pinot.tools.streams.MeetupRsvpStream

run, stopPublishing

Methods inherited from class java.lang.Object

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

Constructor Detail

MeetupRsvpJsonStream

public MeetupRsvpJsonStream()
                     throws Exception

Throws:

Exception

MeetupRsvpJsonStream

public MeetupRsvpJsonStream(boolean partitionByKey)
                     throws Exception

Throws:

Exception

Method Detail

getMessageHandler

protected javax.websocket.MessageHandler.Whole<String> getMessageHandler()

Overrides:

getMessageHandler in class MeetupRsvpStream