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 |
---|---|
static class |
PeriodicStreamingJob.PeriodicSourceGenerator
Data-generating source function.
|
Constructor and Description |
---|
PeriodicStreamingJob() |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.