/
githubmirror
/
the-algorithm
Обзор
Документация
Войти
/
githubmirror
/
the-algorithm
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
src/java/com/twitter/search/ingester/model/IngesterThriftVersionedEvents.java
50 строк
1 KB
twitter-team
Twitter Recommendation Algorithm
01 апр 2023, 01:36
01 апр 2023, 01:36
ef4c5eb
Код
Авторство
О чём код?
package com.twitter.search.ingester.model; import java.util.Map; import com.google.common.primitives.Longs; import com.twitter.search.common.debug.DebugEventAccumulator; import com.twitter.search.common.indexing.thriftjava.ThriftVersionedEvents; import com.twitter.search.common.partitioning.base.Partitionable; import com.twitter.search.common.schema.thriftjava.ThriftIndexingEvent; /** * Wrap of ThriftVersionedEvents, make it partitionable for the queue writer. */ public class IngesterThriftVersionedEvents extends ThriftVersionedEvents implements Comparable<ThriftVersionedEvents>, Partitionable, DebugEventAccumulator { // Make userId field easier to be accessed to calculate partition number private final long userId; public IngesterThriftVersionedEvents(long userId) { this.userId = userId; } public IngesterThriftVersionedEvents(long userId, Map<Byte, ThriftIndexingEvent> versionedEvents) { super(versionedEvents); this.userId = userId; } public IngesterThriftVersionedEvents(long userId, ThriftVersionedEvents original) { super(original); this.userId = userId; } @Override public int compareTo(ThriftVersionedEvents o) { return Longs.compare(getId(), o.getId()); } @Override public long getTweetId() { return this.getId(); } @Override public long getUserId() { return this.userId; } }