WebLogAnalysis.FilterVisitsByDate (Flink : Examples : Batch 1.19.3-cp4 API)

java.lang.Object
- org.apache.flink.examples.java.relational.WebLogAnalysis.FilterVisitsByDate

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.FilterFunction<org.apache.flink.api.java.tuple.Tuple2<String,String>>, org.apache.flink.api.common.functions.Function

Enclosing class:

WebLogAnalysis
```
public static class WebLogAnalysis.FilterVisitsByDate
extends Object
implements org.apache.flink.api.common.functions.FilterFunction<org.apache.flink.api.java.tuple.Tuple2<String,String>>
```
MapFunction that filters for records of the visits relation where the year (from the date string) is equal to a certain value.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

FilterVisitsByDate()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`filter(org.apache.flink.api.java.tuple.Tuple2<String,String> value)`	Filters for records of the visits relation where the year of visit is equal to a specified value.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - FilterVisitsByDate
```
public FilterVisitsByDate()
```
- Method Detail
  - filter
```
public boolean filter(org.apache.flink.api.java.tuple.Tuple2<String,String> value)
               throws Exception
```
    Filters for records of the visits relation where the year of visit is equal to a specified value. The URL of all visit records passing the filter is emitted.
    Output Format: 0: URL 1: DATE
    
    Specified by:
    
    filter in interface org.apache.flink.api.common.functions.FilterFunction<org.apache.flink.api.java.tuple.Tuple2<String,String>>
    
    Throws:
    
    Exception