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

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

All Implemented Interfaces:

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

Enclosing class:

WebLogAnalysis
```
public static class WebLogAnalysis.AntiJoinVisits
extends Object
implements org.apache.flink.api.common.functions.CoGroupFunction<org.apache.flink.api.java.tuple.Tuple3<Integer,String,Integer>,org.apache.flink.api.java.tuple.Tuple1<String>,org.apache.flink.api.java.tuple.Tuple3<Integer,String,Integer>>
```
CoGroupFunction that realizes an anti-join. If the first input does not provide any pairs, all pairs of the second input are emitted. Otherwise, no pair is emitted.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

AntiJoinVisits()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`coGroup(Iterable<org.apache.flink.api.java.tuple.Tuple3<Integer,String,Integer>> ranks, Iterable<org.apache.flink.api.java.tuple.Tuple1<String>> visits, org.apache.flink.util.Collector<org.apache.flink.api.java.tuple.Tuple3<Integer,String,Integer>> out)`	If the visit iterator is empty, all pairs of the rank iterator are emitted.

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

- Constructor Detail
  - AntiJoinVisits
```
public AntiJoinVisits()
```
- Method Detail
  - coGroup
```
public void coGroup(Iterable<org.apache.flink.api.java.tuple.Tuple3<Integer,String,Integer>> ranks,
                    Iterable<org.apache.flink.api.java.tuple.Tuple1<String>> visits,
                    org.apache.flink.util.Collector<org.apache.flink.api.java.tuple.Tuple3<Integer,String,Integer>> out)
```
    If the visit iterator is empty, all pairs of the rank iterator are emitted. Otherwise, no pair is emitted.
    Output Format: 0: RANK 1: URL 2: AVG_DURATION
    
    Specified by:
    
    coGroup in interface org.apache.flink.api.common.functions.CoGroupFunction<org.apache.flink.api.java.tuple.Tuple3<Integer,String,Integer>,org.apache.flink.api.java.tuple.Tuple1<String>,org.apache.flink.api.java.tuple.Tuple3<Integer,String,Integer>>