M
- Message datapublic class MessagesIterable<M extends org.apache.hadoop.io.Writable> extends RepresentativeByteStructIterable<M>
dataInputFactory
Constructor and Description |
---|
MessagesIterable(Factory<? extends ExtendedDataInput> dataInputFactory,
MessageValueFactory<M> messageValueFactory)
Constructor
|
Modifier and Type | Method and Description |
---|---|
protected M |
createWritable()
Must be able to create the writable object
|
iterator
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public MessagesIterable(Factory<? extends ExtendedDataInput> dataInputFactory, MessageValueFactory<M> messageValueFactory)
dataInputFactory
- Factory for data inputsmessageValueFactory
- factory for creating message valuesprotected M createWritable()
ByteStructIterable
createWritable
in class ByteStructIterable<M extends org.apache.hadoop.io.Writable>
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.