public class EventFilter extends Object implements Serializable
Constructor and Description |
---|
EventFilter()
Create new
EventFilter |
Modifier and Type | Method and Description |
---|---|
void |
addRule(EventFilterRule rule)
Add new rule to filter
|
Boolean |
getMatchAny()
Get match any setting
|
ArrayList<EventFilterRule> |
getRules()
Get configured rules
|
static org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<Event>,org.apache.beam.sdk.values.PCollection<Event>> |
getTransform(EventFilter filter)
Get composite transform to apply filter to event stream
|
Boolean |
getWantUTC()
Get UTC handling parameter
|
EventFilter |
matchAny() |
Boolean |
matches(Event e)
Test if event matches filter
|
EventFilter |
passConfigurationTicks()
Configure filter to pass configuration ticks
|
void |
setMatchAny(Boolean matchAny)
Set match any flag to specified value
|
void |
setRules(ArrayList<EventFilterRule> rules)
Set filter rules
|
EventFilter |
setWantUTC(Boolean flag)
Choose to ignore non-UTC timezone events
|
public EventFilter()
EventFilter
public EventFilter passConfigurationTicks()
Adds a rule to the filter that will pass configuration ticks.
public static org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<Event>,org.apache.beam.sdk.values.PCollection<Event>> getTransform(EventFilter filter)
filter
- Event filterpublic Boolean matches(Event e)
e
- Event to match against filterpublic void addRule(EventFilterRule rule)
rule
- New rule to addpublic void setRules(ArrayList<EventFilterRule> rules)
rules
- Array of rulespublic ArrayList<EventFilterRule> getRules()
public EventFilter setWantUTC(Boolean flag)
flag
- If true, drop events with parsed timezones that are not UTCpublic Boolean getWantUTC()
public EventFilter matchAny()
public void setMatchAny(Boolean matchAny)
matchAny
- True to match everythingpublic Boolean getMatchAny()
Copyright © 2022. All rights reserved.