public class CritObjectAnalyze extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<Event>,org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,Alert>>> implements DocumentingTransform
Analyze events to determine if they are related to any objects configured as being critical objects. Where identified, generate critical level alerts.
Constructor and Description |
---|
CritObjectAnalyze(AuthProfile.AuthProfileOptions options)
Initialize new critical object analysis
|
Modifier and Type | Method and Description |
---|---|
org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,Alert>> |
expand(org.apache.beam.sdk.values.PCollection<Event> input) |
String |
getTransformDoc()
Get documentation string from transform based on it's current configuration
|
public CritObjectAnalyze(AuthProfile.AuthProfileOptions options)
options
- Pipeline optionspublic String getTransformDoc()
getTransformDoc
in interface DocumentingTransform
Copyright © 2022. All rights reserved.