WebLogAnalysis.FilterByRank (Flink : Examples : Batch 1.20.0-cp1 API)

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

All Implemented Interfaces:

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

Enclosing class:

WebLogAnalysis
```
public static class WebLogAnalysis.FilterByRank
extends Object
implements org.apache.flink.api.common.functions.FilterFunction<org.apache.flink.api.java.tuple.Tuple3<Integer,String,Integer>>
```
MapFunction that filters for records where the rank exceeds a certain threshold.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

FilterByRank()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`filter(org.apache.flink.api.java.tuple.Tuple3<Integer,String,Integer> value)`	Filters for records of the rank relation where the rank is greater than the given threshold.

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

- Constructor Detail
  - FilterByRank
```
public FilterByRank()
```
- Method Detail
  - filter
```
public boolean filter(org.apache.flink.api.java.tuple.Tuple3<Integer,String,Integer> value)
               throws Exception
```
    Filters for records of the rank relation where the rank is greater than the given threshold.
    Output Format: 0: RANK 1: URL 2: AVG_DURATION
    
    Specified by:
    
    filter in interface org.apache.flink.api.common.functions.FilterFunction<org.apache.flink.api.java.tuple.Tuple3<Integer,String,Integer>>
    
    Throws:
    
    Exception