public class StatefulStreamingJob extends Object
Modifier and Type | Class and Description |
---|---|
static class |
StatefulStreamingJob.MySource
Stub source that emits one record per second.
|
static class |
StatefulStreamingJob.MyStatefulFunction
A stateful
RichMapFunction that keeps the required types of state. |
Constructor and Description |
---|
StatefulStreamingJob() |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.