org.apache.flink.streaming.tests

Class PeriodicStreamingJob

java.lang.Object

org.apache.flink.streaming.tests.PeriodicStreamingJob

public class PeriodicStreamingJob
extends Object

This is a periodic streaming job that runs for CLI testing purposes.

The stream is bounded and will complete after the specified duration.

Parameters: -outputPath Sets the path to where the result data is written. -recordsPerSecond Sets the output record frequency. -durationInSecond Sets the running duration of the job. -offsetInSecond Sets the startup delay before processing the first message.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PeriodicStreamingJob.PeriodicSourceGenerator Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

Constructor Summary

Constructors

Constructor and Description
PeriodicStreamingJob()

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)

Methods inherited from class java.lang.Object

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

Constructor Detail

PeriodicStreamingJob

public PeriodicStreamingJob()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception