org.apache.flink.streaming.kafka.test.base

Class KafkaEvent

java.lang.Object

org.apache.flink.streaming.kafka.test.base.KafkaEvent

public class KafkaEvent
extends Object

The event type used in the KafkaExample.

This is a Java POJO, which Flink recognizes and will allow "by-name" field referencing when keying a DataStream of such a type. For a demonstration of this, see the code in KafkaExample.

Constructor Summary

Constructors

Constructor and Description
KafkaEvent()
KafkaEvent(String word, int frequency, long timestamp)

Method Summary

Modifier and Type	Method and Description
static KafkaEvent	fromString(String eventStr)
int	getFrequency()
long	getTimestamp()
String	getWord()
void	setFrequency(int frequency)
void	setTimestamp(long timestamp)
void	setWord(String word)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaEvent

public KafkaEvent()

KafkaEvent

public KafkaEvent(String word,
                  int frequency,
                  long timestamp)

Method Detail

getWord

public String getWord()

setWord

public void setWord(String word)

getFrequency

public int getFrequency()

setFrequency

public void setFrequency(int frequency)

getTimestamp

public long getTimestamp()

setTimestamp

public void setTimestamp(long timestamp)

fromString

public static KafkaEvent fromString(String eventStr)

toString

public String toString()

Overrides:

toString in class Object