Uses of Class
com.alibaba.graphscope.utils.ThreadSafeBitSet

Packages that use ThreadSafeBitSet

Package	Description
com.alibaba.graphscope.utils

Uses of ThreadSafeBitSet in com.alibaba.graphscope.utils

Fields in com.alibaba.graphscope.utils declared as ThreadSafeBitSet

Modifier and Type	Field	Description
protected ThreadSafeBitSet	AbstractMessageStore.nextSet

Methods in com.alibaba.graphscope.utils that return ThreadSafeBitSet

Modifier and Type	Method	Description
ThreadSafeBitSet	ThreadSafeBitSet.andNot(ThreadSafeBitSet other)	Return a new bit set which contains all bits which are contained in this bit set, and which are NOT contained in the other bit set.
static ThreadSafeBitSet	ThreadSafeBitSet.orAll(ThreadSafeBitSet... bitSets)	Return a new bit set which contains all bits which are contained in *any* of the specified bit sets.

Methods in com.alibaba.graphscope.utils with parameters of type ThreadSafeBitSet

Modifier and Type	Method	Description
ThreadSafeBitSet	ThreadSafeBitSet.andNot(ThreadSafeBitSet other)	Return a new bit set which contains all bits which are contained in this bit set, and which are NOT contained in the other bit set.
static <T> MessageStore<T>	MessageStore.create(int len, int fnum, int numCores, Class<? extends T> clz, scala.Function2<T,T,T> function2, ThreadSafeBitSet nextSet, GraphXConf<?,?,?> conf, int ivnum)
long	DoubleMessageStore.digest(IFragment<Long,Long,?,?> fragment, MessageInBuffer messageInBuffer, ThreadSafeBitSet curSet, int threadId)
void	DoubleMessageStore.digest(IFragment<Long,Long,?,?> fragment, FFIByteVector vector, ThreadSafeBitSet curSet, int threadId)
long	IntMessageStore.digest(IFragment<Long,Long,?,?> fragment, MessageInBuffer messageInBuffer, ThreadSafeBitSet curSet, int threadId)
void	IntMessageStore.digest(IFragment<Long,Long,?,?> fragment, FFIByteVector vector, ThreadSafeBitSet curSet, int threadId)
long	LongMessageStore.digest(IFragment<Long,Long,?,?> fragment, MessageInBuffer messageInBuffer, ThreadSafeBitSet curSet, int threadId)
void	LongMessageStore.digest(IFragment<Long,Long,?,?> fragment, FFIByteVector vector, ThreadSafeBitSet curSet, int threadId)
long	MessageStore.digest(IFragment<Long,Long,?,?> fragment, MessageInBuffer messageInBuffer, ThreadSafeBitSet curSet, int threadId)	to digest message send along edges, which should be resolved via GetMessages.
void	MessageStore.digest(IFragment<Long,Long,?,?> fragment, FFIByteVector vector, ThreadSafeBitSet curSet, int threadId)
long	ObjectMessageStore.digest(IFragment<Long,Long,?,?> fragment, MessageInBuffer messageInBuffer, ThreadSafeBitSet curSet, int threadId)
void	ObjectMessageStore.digest(IFragment<Long,Long,?,?> fragment, FFIByteVector vector, ThreadSafeBitSet curSet, int threadId)
void	AbstractMessageStore.flushMessages(ThreadSafeBitSet nextSet, ParallelMessageManager messageManager, IFragment<Long,Long,?,?> fragment, int[] fid2WorkerId, ExecutorService executorService)
void	MessageStore.flushMessages(ThreadSafeBitSet nextSet, ParallelMessageManager messageManager, IFragment<Long,Long,?,?> fragment, int[] fid2WorkerId, ExecutorService executorService)
void	ObjectMessageStore.flushMessages(ThreadSafeBitSet nextSet, ParallelMessageManager messageManager, IFragment<Long,Long,?,?> fragment, int[] fid2WorkerId, ExecutorService executorService)
static ThreadSafeBitSet	ThreadSafeBitSet.orAll(ThreadSafeBitSet... bitSets)	Return a new bit set which contains all bits which are contained in *any* of the specified bit sets.

Constructors in com.alibaba.graphscope.utils with parameters of type ThreadSafeBitSet

Constructor	Description
AbstractMessageStore(int fnum, int numCores, ThreadSafeBitSet nextSet, GraphXConf<?,?,?> conf, int ivnum)
DoubleMessageStore(int len, int fnum, int numCores, int ivnum, scala.Function2<Double,Double,Double> function2, ThreadSafeBitSet nextSet, GraphXConf<?,?,?> conf)
IntMessageStore(int len, int fnum, int numCores, int ivnum, scala.Function2<Integer,Integer,Integer> function2, ThreadSafeBitSet nextSet, GraphXConf<?,?,?> conf)
LongMessageStore(int len, int fnum, int numCores, int ivnum, scala.Function2<Long,Long,Long> mergeMessage, ThreadSafeBitSet nextSet, GraphXConf<?,?,?> conf)
ObjectMessageStore(int len, int fnum, int numCores, int ivnum, Class<? extends T> clz, scala.Function2<T,T,T> function2, ThreadSafeBitSet nextSet, GraphXConf<?,?,?> conf)