public class QsStateProducer extends Object
Email
pojo with random ids and increasing
timestamps and passes it to a stateful FlatMapFunction
, where it is exposed as queryable state.Constructor and Description |
---|
QsStateProducer() |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.