public class CustomsAccountEnumeration extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,CustomsFeatures>>,org.apache.beam.sdk.values.PCollection<Alert>>
Assumed to operate on ten minute fixed windows.
Modifier and Type | Field and Description |
---|---|
static String |
EXPERIMENTAL_TAG |
Constructor and Description |
---|
CustomsAccountEnumeration(Customs.CustomsOptions options,
org.apache.beam.sdk.values.PCollectionView<Map<String,Boolean>> varianceView)
Create new CustomsAccountEnumeration
|
Modifier and Type | Method and Description |
---|---|
org.apache.beam.sdk.values.PCollection<Alert> |
expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,CustomsFeatures>> col) |
default String |
getTransformDoc()
Get documentation string from transform based on it's current configuration
|
String |
getTransformDocDescription()
Get documentation description from transform based on it's current configuration
|
boolean |
isExperimental()
Get whether the transform is experimental and won't be escalated
|
public static final String EXPERIMENTAL_TAG
public CustomsAccountEnumeration(Customs.CustomsOptions options, org.apache.beam.sdk.values.PCollectionView<Map<String,Boolean>> varianceView)
options
- Pipeline optionsvarianceView
- Use PCollectionView
for variance, or null to disablepublic String getTransformDocDescription()
public org.apache.beam.sdk.values.PCollection<Alert> expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,CustomsFeatures>> col)
expand
in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,CustomsFeatures>>,org.apache.beam.sdk.values.PCollection<Alert>>
public boolean isExperimental()
public String getTransformDoc()
DocumentingTransform
getTransformDoc
in interface DocumentingTransform
Copyright © 2022. All rights reserved.