Class ListMessageIterable<MSG_T extends org.apache.hadoop.io.Writable>
- java.lang.Object
-
- com.alibaba.graphscope.parallel.mm.ListMessageIterable<MSG_T>
-
- All Implemented Interfaces:
MessageIterable<MSG_T>
,Iterable<MSG_T>
public class ListMessageIterable<MSG_T extends org.apache.hadoop.io.Writable> extends Object implements MessageIterable<MSG_T>
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface com.alibaba.graphscope.parallel.mm.MessageIterable
MessageIterable.EmptyMessageIterable<MSG_T_ extends org.apache.hadoop.io.Writable>
-
-
Field Summary
Fields Modifier and Type Field Description static int
DEFAULT_MESSAGE_ITERABLE_SIZE
-
Fields inherited from interface com.alibaba.graphscope.parallel.mm.MessageIterable
emptyMessageIterable
-
-
Constructor Summary
Constructors Constructor Description ListMessageIterable()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
append(MSG_T msg)
void
clear()
Iterator<MSG_T>
iterator()
Returns an iterator over elements of typeT
.int
size()
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface java.lang.Iterable
forEach, spliterator
-
-
-
-
Method Detail
-
append
public void append(MSG_T msg)
- Specified by:
append
in interfaceMessageIterable<MSG_T extends org.apache.hadoop.io.Writable>
-
clear
public void clear()
- Specified by:
clear
in interfaceMessageIterable<MSG_T extends org.apache.hadoop.io.Writable>
-
size
public int size()
- Specified by:
size
in interfaceMessageIterable<MSG_T extends org.apache.hadoop.io.Writable>
-
-