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

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

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.FilterDocByKeyWords
extends Object
implements org.apache.flink.api.common.functions.FilterFunction<org.apache.flink.api.java.tuple.Tuple2<String,String>>
```
MapFunction that filters for documents that contain a certain set of keywords.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

FilterDocByKeyWords()

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 documents that contain all of the given keywords and projects the records on the URL field.

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

- Constructor Detail
  - FilterDocByKeyWords
```
public FilterDocByKeyWords()
```
- Method Detail
  - filter
```
public boolean filter(org.apache.flink.api.java.tuple.Tuple2<String,String> value)
               throws Exception
```
    Filters for documents that contain all of the given keywords and projects the records on the URL field.
    Output Format: 0: URL 1: DOCUMENT_TEXT
    
    Specified by:
    
    filter in interface org.apache.flink.api.common.functions.FilterFunction<org.apache.flink.api.java.tuple.Tuple2<String,String>>
    
    Throws:
    
    Exception