package statefulprocessor
- Alphabetic
- Public
- Protected
Type Members
- class DriverStatefulProcessorHandleImpl extends StatefulProcessorHandleImplBase
This DriverStatefulProcessorHandleImpl is used within TransformWithExec on the driver side to collect the columnFamilySchemas before any processing is actually done.
This DriverStatefulProcessorHandleImpl is used within TransformWithExec on the driver side to collect the columnFamilySchemas before any processing is actually done. We need this class because we can only collect the schemas after the StatefulProcessor is initialized.
- class QueryInfoImpl extends QueryInfo
- class StatefulProcessorHandleImpl extends StatefulProcessorHandleImplBase with Logging
Class that provides a concrete implementation of a StatefulProcessorHandle.
Class that provides a concrete implementation of a StatefulProcessorHandle. Note that we keep track of valid transitions as various functions are invoked to track object lifecycle.
- abstract class StatefulProcessorHandleImplBase extends StatefulProcessorHandle
Value Members
- object ImplicitGroupingKeyTracker
Object used to assign/retrieve/remove grouping key passed implicitly for various state manipulation actions using the store handle.
- object StatefulProcessorHandleState extends Enumeration
Enum used to track valid states for the StatefulProcessorHandle
- object TWSMetricsUtils
Utility object to perform metrics updates