Package es.uam.eps.ir.relison.diffusion.expiration

Class AllNotRealPropagatedTimestampExpirationMechanism<U extends java.io.Serializable,​I extends java.io.Serializable,​P>

java.lang.Object
es.uam.eps.ir.relison.diffusion.expiration.AllNotRealPropagatedTimestampExpirationMechanism<U,​I,​P>
Type Parameters:
U - Type of the users.
I - Type of the information pieces.
P - Type of the features.
All Implemented Interfaces:
ExpirationMechanism<U,​I,​P>
public class AllNotRealPropagatedTimestampExpirationMechanism<U extends java.io.Serializable,​I extends java.io.Serializable,​P>
extends java.lang.Object
implements ExpirationMechanism<U,​I,​P>
If current timestamp is greater than the timestamp of the pieces, the elements are discarded.

  • Constructor Summary

    Constructors 
    Constructor Description
    AllNotRealPropagatedTimestampExpirationMechanism()  

  • Method Summary

    Modifier and Type Method Description
    java.util.stream.Stream<java.lang.Integer> expire​(UserState<U> user, Data<U,​I,​P> data, int numIter, java.lang.Long timestamp)
    Obtains the information that has expired in the current iteration.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

  • Method Details

    • expire

      public java.util.stream.Stream<java.lang.Integer> expire​(UserState<U> user, Data<U,​I,​P> data, int numIter, java.lang.Long timestamp)
      Description copied from interface: ExpirationMechanism
      Obtains the information that has expired in the current iteration.
      Specified by:
      expire in interface ExpirationMechanism<U extends java.io.Serializable,​I extends java.io.Serializable,​P>
      Parameters:
      user - UserState to check.
      data - The full data.
      numIter - Current iteration.
      timestamp - moment of time represented by the iteration.
      Returns:
      A stream with the identifiers of all the received information pieces that have expired.