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

Class KafkaExampleUtil

java.lang.Object

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

Direct Known Subclasses:

KafkaExample

public class KafkaExampleUtil
extends Object

The util class for kafka example.

Constructor Summary

Constructors

Constructor and Description
KafkaExampleUtil()

Method Summary

Modifier and Type	Method and Description
static StreamExecutionEnvironment	prepareExecutionEnv(ParameterTool parameterTool)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaExampleUtil

public KafkaExampleUtil()

Method Detail

prepareExecutionEnv

public static StreamExecutionEnvironment prepareExecutionEnv(ParameterTool parameterTool)
                                                      throws Exception

Throws:

Exception