public class PeriodicStreamingJob extends Object
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.
|Modifier and Type||Class and Description|
Data-generating source function.
|Constructor and Description|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.