api-docs/0.6/kafka/message/FileMessageSet.html

<?xml version='1.0' encoding='UTF-8'?> <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.1//EN" "http://www.w3.org/TR/xhtml11/DTD/xhtml11.dtd"> <html> <head> <title>Scaladoc for kafka.message.FileMessageSet</title> <meta http-equiv="content-type" content="text/html; charset=UTF-8" /> <script type="text/javascript" src="../../lib/jquery.js"></script> <link href="../../lib/template.css" rel="stylesheet" type="text/css" media="screen" /> <script type="text/javascript" src="../../lib/template.js"></script> <script type="text/javascript" src="../../lib/tools.tooltip.js"></script> </head> <body class="type"> <p id="owner"><a href="../package.html" class="extype" name="kafka">kafka</a>.<a href="package.html" class="extype" name="kafka.message">message</a></p> <div id="definition"> <img src="../../lib/class_big.png" /> <h1>FileMessageSet</h1> </div> <h4 class="signature" id="signature"> <span class="kind">class</span> <span class="symbol"> <span class="name">FileMessageSet</span><span class="result"> extends <a href="MessageSet.html" class="extype" name="kafka.message.MessageSet">MessageSet</a></span> </span> </h4> <div class="fullcomment" id="comment"><div class="comment cmt"><p>An on-disk message set. The set can be opened either mutably or immutably. Mutation attempts will fail on an immutable message set. An optional limit and offset can be applied to the message set which will control the offset into the file and the effective length into the file from which messages will be read </p></div> </div> <div id="template"> <div id="mbrsel"> <div id="ancestors"> <span class="filtertype">Inherited</span> <ol><li class="hideall">Hide All</li><li class="showall">Show all</li></ol> <ol id="linearization"><li class="in" name="kafka.message.MessageSet">MessageSet</li><li class="in" name="scala.collection.Iterable">Iterable</li><li class="in" name="scala.collection.IterableLike">IterableLike</li><li class="in" name="scala.Equals">Equals</li><li class="in" name="scala.collection.Traversable">Traversable</li><li class="in" name="scala.collection.generic.GenericTraversableTemplate">GenericTraversableTemplate</li><li class="in" name="scala.collection.TraversableLike">TraversableLike</li><li class="in" name="scala.collection.TraversableOnce">TraversableOnce</li><li class="in" name="scala.collection.generic.FilterMonadic">FilterMonadic</li><li class="in" name="scala.collection.generic.HasNewBuilder">HasNewBuilder</li><li class="in" name="scala.AnyRef">AnyRef</li><li class="in" name="scala.Any">Any</li></ol> </div> <div id="visbl"> <span class="filtertype">Visibility</span> <ol><li class="public in">Public</li><li class="all out">All</li></ol> </div> </div> <div class="members" id="constructors"> <h3>Instance constructors</h3> <ol><li visbl="pub" name="kafka.message.FileMessageSet#this"> <h4 class="signature"> <span class="kind">new</span> <span class="symbol"> <span class="name">FileMessageSet</span><span class="params">(<span name="file">file: <span class="extype" name="java.io.File">File</span></span>, <span name="mutable">mutable: <span class="extype" name="scala.Boolean">Boolean</span></span>, <span name="needRecover">needRecover: <span class="extype" name="java.util.concurrent.atomic.AtomicBoolean">AtomicBoolean</span></span>)</span> </span> </h4> <p class="shortcomment cmt">Create a file message set with no limit or offset </p> <div class="fullcomment"><div class="comment cmt"><p>Create a file message set with no limit or offset </p></div> </div> </li><li visbl="pub" name="kafka.message.FileMessageSet#this"> <h4 class="signature"> <span class="kind">new</span> <span class="symbol"> <span class="name">FileMessageSet</span><span class="params">(<span name="channel">channel: <span class="extype" name="java.nio.channels.FileChannel">FileChannel</span></span>, <span name="mutable">mutable: <span class="extype" name="scala.Boolean">Boolean</span></span>, <span name="needRecover">needRecover: <span class="extype" name="java.util.concurrent.atomic.AtomicBoolean">AtomicBoolean</span></span>)</span> </span> </h4> <p class="shortcomment cmt">Create a file message set with no limit or offset </p> <div class="fullcomment"><div class="comment cmt"><p>Create a file message set with no limit or offset </p></div> </div> </li><li visbl="pub" name="kafka.message.FileMessageSet#this"> <h4 class="signature"> <span class="kind">new</span> <span class="symbol"> <span class="name">FileMessageSet</span><span class="params">(<span name="file">file: <span class="extype" name="java.io.File">File</span></span>, <span name="mutable">mutable: <span class="extype" name="scala.Boolean">Boolean</span></span>)</span> </span> </h4> <p class="shortcomment cmt">Create a file message set with no limit or offset </p> <div class="fullcomment"><div class="comment cmt"><p>Create a file message set with no limit or offset </p></div> </div> </li><li visbl="pub" name="kafka.message.FileMessageSet#this"> <h4 class="signature"> <span class="kind">new</span> <span class="symbol"> <span class="name">FileMessageSet</span><span class="params">(<span name="channel">channel: <span class="extype" name="java.nio.channels.FileChannel">FileChannel</span></span>, <span name="mutable">mutable: <span class="extype" name="scala.Boolean">Boolean</span></span>)</span> </span> </h4> <p class="shortcomment cmt">Create a file message set with no limit or offset </p> <div class="fullcomment"><div class="comment cmt"><p>Create a file message set with no limit or offset </p></div> </div> </li></ol> </div> <div class="members" id="types"> <h3>Type Members</h3> <ol><li visbl="prt" name="scala.collection.TraversableLike#Self"> <h4 class="signature"> <span class="kind">type</span> <span class="symbol"> <span class="name">Self</span><span class="result"> = <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> attributes: protected </div><div class="block"> definition classes: TraversableLike </div></div> </li></ol> </div> <div class="members" id="values"> <h3>Value Members</h3> <ol><li visbl="pub" name="scala.AnyRef#!="> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">!=</span><span class="params">(<span name="arg0">arg0: AnyRef</span>)</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> <div class="fullcomment"><div class="block"> attributes: final </div><div class="block"> definition classes: AnyRef </div></div> </li><li visbl="pub" name="scala.Any#!="> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">!=</span><span class="params">(<span name="arg0">arg0: <span class="extype" name="scala.Any">Any</span></span>)</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> <p class="shortcomment cmt"><code>o != arg0</code> is the same as <code>!(o == (arg0))</code>.</p> <div class="fullcomment"><div class="comment cmt"><p><code>o != arg0</code> is the same as <code>!(o == (arg0))</code>. </p></div><dl class="paramcmts block"><dt class="param">arg0</dt><dd class="cmt"><p>the object to compare against this object for dis-equality.</p></dd><dt>returns</dt><dd class="cmt"><p><code>false</code> if the receiver object is equivalent to the argument; <code>true</code> otherwise.</p></dd></dl><div class="block"> attributes: final </div><div class="block"> definition classes: Any </div> </div> </li><li visbl="pub" name="scala.AnyRef###"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">##</span><span class="params">()</span><span class="result">: <span class="extype" name="scala.Int">Int</span></span> </span> </h4> <div class="fullcomment"><div class="block"> attributes: final </div><div class="block"> definition classes: AnyRef → Any </div></div> </li><li visbl="pub" name="scala.AnyRef#$asInstanceOf"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">$asInstanceOf</span><span class="tparams">[<span name="T0">T0</span>]</span><span class="params">()</span><span class="result">: T0</span> </span> </h4> <div class="fullcomment"><div class="block"> attributes: final </div><div class="block"> definition classes: AnyRef </div></div> </li><li visbl="pub" name="scala.AnyRef#$isInstanceOf"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">$isInstanceOf</span><span class="tparams">[<span name="T0">T0</span>]</span><span class="params">()</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> <div class="fullcomment"><div class="block"> attributes: final </div><div class="block"> definition classes: AnyRef </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#++"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">++</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>, <span name="That">That</span>]</span><span class="params">(<span name="that">that: <span class="extype" name="scala.collection.TraversableOnce">TraversableOnce</span>[B]</span>)</span><span class="params">(<span class="implicit">implicit </span><span name="bf">bf: <span class="extype" name="scala.collection.generic.CanBuildFrom">CanBuildFrom</span>[<span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>], B, That]</span>)</span><span class="result">: That</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#/:"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">/:</span><span class="tparams">[<span name="B">B</span>]</span><span class="params">(<span name="z">z: B</span>)</span><span class="params">(<span name="op">op: (B, <a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ B</span>)</span><span class="result">: B</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#:\"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">:\</span><span class="tparams">[<span name="B">B</span>]</span><span class="params">(<span name="z">z: B</span>)</span><span class="params">(<span name="op">op: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>, B) ⇒ B</span>)</span><span class="result">: B</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.AnyRef#=="> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">==</span><span class="params">(<span name="arg0">arg0: AnyRef</span>)</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> <p class="shortcomment cmt"><code>o == arg0</code> is the same as <code>if (o eq null) arg0 eq null else o.equals(arg0)</code>.</p> <div class="fullcomment"><div class="comment cmt"><p><code>o == arg0</code> is the same as <code>if (o eq null) arg0 eq null else o.equals(arg0)</code>. </p></div><dl class="paramcmts block"><dt class="param">arg0</dt><dd class="cmt"><p>the object to compare against this object for equality.</p></dd><dt>returns</dt><dd class="cmt"><p><code>true</code> if the receiver object is equivalent to the argument; <code>false</code> otherwise.</p></dd></dl><div class="block"> attributes: final </div><div class="block"> definition classes: AnyRef </div> </div> </li><li visbl="pub" name="scala.Any#=="> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">==</span><span class="params">(<span name="arg0">arg0: <span class="extype" name="scala.Any">Any</span></span>)</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> <p class="shortcomment cmt"><code>o == arg0</code> is the same as <code>o.equals(arg0)</code>.</p> <div class="fullcomment"><div class="comment cmt"><p><code>o == arg0</code> is the same as <code>o.equals(arg0)</code>. </p></div><dl class="paramcmts block"><dt class="param">arg0</dt><dd class="cmt"><p>the object to compare against this object for equality.</p></dd><dt>returns</dt><dd class="cmt"><p><code>true</code> if the receiver object is equivalent to the argument; <code>false</code> otherwise.</p></dd></dl><div class="block"> attributes: final </div><div class="block"> definition classes: Any </div> </div> </li><li visbl="pub" name="scala.collection.TraversableOnce#addString"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">addString</span><span class="params">(<span name="b">b: <span class="extype" name="scala.collection.mutable.StringBuilder">StringBuilder</span></span>)</span><span class="result">: <span class="extype" name="scala.collection.mutable.StringBuilder">StringBuilder</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#addString"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">addString</span><span class="params">(<span name="b">b: <span class="extype" name="scala.collection.mutable.StringBuilder">StringBuilder</span></span>, <span name="sep">sep: <span class="extype" name="java.lang.String">String</span></span>)</span><span class="result">: <span class="extype" name="scala.collection.mutable.StringBuilder">StringBuilder</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#addString"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">addString</span><span class="params">(<span name="b">b: <span class="extype" name="scala.collection.mutable.StringBuilder">StringBuilder</span></span>, <span name="start">start: <span class="extype" name="java.lang.String">String</span></span>, <span name="sep">sep: <span class="extype" name="java.lang.String">String</span></span>, <span name="end">end: <span class="extype" name="java.lang.String">String</span></span>)</span><span class="result">: <span class="extype" name="scala.collection.mutable.StringBuilder">StringBuilder</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="kafka.message.FileMessageSet#append"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">append</span><span class="params">(<span name="messages">messages: <a href="MessageSet.html" class="extype" name="kafka.message.MessageSet">MessageSet</a></span>)</span><span class="result">: <span class="extype" name="scala.Unit">Unit</span></span> </span> </h4> <p class="shortcomment cmt">Append this message to the message set </p> <div class="fullcomment"><div class="comment cmt"><p>Append this message to the message set </p></div> </div> </li><li visbl="pub" name="scala.Any#asInstanceOf"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">asInstanceOf</span><span class="tparams">[<span name="T0">T0</span>]</span><span class="result">: T0</span> </span> </h4> <p class="shortcomment cmt">This method is used to cast the receiver object to be of type <code>T0</code>.</p> <div class="fullcomment"><div class="comment cmt"><p>This method is used to cast the receiver object to be of type <code>T0</code>.</p><p>Note that the success of a cast at runtime is modulo Scala's erasure semantics. Therefore the expression<code>1.asInstanceOf[String]</code> will throw a <code>ClassCastException</code> at runtime, while the expression<code>List(1).asInstanceOf[List[String]]</code> will not. In the latter example, because the type argument is erased as part of compilation it is not possible to check whether the contents of the list are of the requested typed. </p></div><dl class="paramcmts block"><dt>returns</dt><dd class="cmt"><p>the receiver object.</p></dd></dl><div class="block"> attributes: final </div><div class="block"> definition classes: Any </div> </div> </li><li visbl="pub" name="scala.collection.IterableLike#canEqual"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">canEqual</span><span class="params">(<span name="that">that: <span class="extype" name="scala.Any">Any</span></span>)</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → Equals </div></div> </li><li visbl="pub" name="kafka.message.FileMessageSet#checkMutable"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">checkMutable</span><span class="params">()</span><span class="result">: <span class="extype" name="scala.Unit">Unit</span></span> </span> </h4> </li><li visbl="prt" name="scala.AnyRef#clone"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">clone</span><span class="params">()</span><span class="result">: AnyRef</span> </span> </h4> <p class="shortcomment cmt">This method creates and returns a copy of the receiver object.</p> <div class="fullcomment"><div class="comment cmt"><p>This method creates and returns a copy of the receiver object.</p><p>The default implementation of the <code>clone</code> method is platform dependent. </p></div><dl class="paramcmts block"><dt>returns</dt><dd class="cmt"><p>a copy of the receiver object.</p></dd></dl><div class="block"> attributes: protected </div><div class="block"> definition classes: AnyRef </div> </div> </li><li visbl="pub" name="kafka.message.FileMessageSet#close"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">close</span><span class="params">()</span><span class="result">: <span class="extype" name="scala.Unit">Unit</span></span> </span> </h4> <p class="shortcomment cmt">Close this message set </p> <div class="fullcomment"><div class="comment cmt"><p>Close this message set </p></div> </div> </li><li visbl="pub" name="scala.collection.TraversableLike#collect"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">collect</span><span class="tparams">[<span name="B">B</span>, <span name="That">That</span>]</span><span class="params">(<span name="pf">pf: <span class="extype" name="scala.PartialFunction">PartialFunction</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>, B]</span>)</span><span class="params">(<span class="implicit">implicit </span><span name="bf">bf: <span class="extype" name="scala.collection.generic.CanBuildFrom">CanBuildFrom</span>[<span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>], B, That]</span>)</span><span class="result">: That</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.Iterable#companion"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">companion</span><span class="result">: <span class="extype" name="scala.collection.generic.GenericCompanion">GenericCompanion</span>[<span class="extype" name="scala.collection.Iterable">Iterable</span>[A][A]]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: Iterable → Traversable → GenericTraversableTemplate </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#copyToArray"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">copyToArray</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="params">(<span name="xs">xs: <span class="extype" name="scala.Array">Array</span>[B]</span>, <span name="start">start: <span class="extype" name="scala.Int">Int</span></span>, <span name="len">len: <span class="extype" name="scala.Int">Int</span></span>)</span><span class="result">: <span class="extype" name="scala.Unit">Unit</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → TraversableLike → TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#copyToArray"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">copyToArray</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="params">(<span name="xs">xs: <span class="extype" name="scala.Array">Array</span>[B]</span>)</span><span class="result">: <span class="extype" name="scala.Unit">Unit</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#copyToArray"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">copyToArray</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="params">(<span name="xs">xs: <span class="extype" name="scala.Array">Array</span>[B]</span>, <span name="start">start: <span class="extype" name="scala.Int">Int</span></span>)</span><span class="result">: <span class="extype" name="scala.Unit">Unit</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#copyToBuffer"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">copyToBuffer</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="params">(<span name="dest">dest: <span class="extype" name="scala.collection.mutable.Buffer">Buffer</span>[B]</span>)</span><span class="result">: <span class="extype" name="scala.Unit">Unit</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#count"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">count</span><span class="params">(<span name="p">p: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ <span class="extype" name="scala.Boolean">Boolean</span></span>)</span><span class="result">: <span class="extype" name="scala.Int">Int</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#drop"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">drop</span><span class="params">(<span name="n">n: <span class="extype" name="scala.Int">Int</span></span>)</span><span class="result">: <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#dropRight"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">dropRight</span><span class="params">(<span name="n">n: <span class="extype" name="scala.Int">Int</span></span>)</span><span class="result">: <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#dropWhile"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">dropWhile</span><span class="params">(<span name="p">p: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ <span class="extype" name="scala.Boolean">Boolean</span></span>)</span><span class="result">: <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#elements"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name deprecated">elements</span><span class="result">: <span class="extype" name="scala.collection.Iterator">Iterator</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike </div><div class="block"><ol>deprecated: <li><p>use <code>iterator' instead</code></p></li> </ol></div></div> </li><li visbl="pub" name="scala.AnyRef#eq"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">eq</span><span class="params">(<span name="arg0">arg0: AnyRef</span>)</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> <p class="shortcomment cmt">This method is used to test whether the argument (<code>arg0</code>) is a reference to the receiver object (<code>this</code>).</p> <div class="fullcomment"><div class="comment cmt"><p>This method is used to test whether the argument (<code>arg0</code>) is a reference to the receiver object (<code>this</code>).</p><p>The <code>eq</code> method implements an [http://en.wikipedia.org/wiki/Equivalence_relation equivalence relation] on non-null instances of <code>AnyRef</code>: * It is reflexive: for any non-null instance <code>x</code> of type <code>AnyRef</code>, <code>x.eq(x)</code> returns <code>true</code>. * It is symmetric: for any non-null instances <code>x</code> and <code>y</code> of type <code>AnyRef</code>, <code>x.eq(y)</code> returns <code>true</code> if and only if <code>y.eq(x)</code> returns <code>true</code>. * It is transitive: for any non-null instances <code>x</code>, <code>y</code>, and <code>z</code> of type <code>AnyRef</code> if <code>x.eq(y)</code> returns <code>true</code> and <code>y.eq(z)</code> returns <code>true</code>, then <code>x.eq(z)</code> returns <code>true</code>.</p><p>Additionally, the <code>eq</code> method has three other properties. * It is consistent: for any non-null instances <code>x</code> and <code>y</code> of type <code>AnyRef</code>, multiple invocations of <code>x.eq(y)</code> consistently returns <code>true</code> or consistently returns <code>false</code>. * For any non-null instance <code>x</code> of type <code>AnyRef</code>, <code>x.eq(null)</code> and <code>null.eq(x)</code> returns <code>false</code>. * <code>null.eq(null)</code> returns <code>true</code>.</p><p>When overriding the <code>equals</code> or <code>hashCode</code> methods, it is important to ensure that their behavior is consistent with reference equality. Therefore, if two objects are references to each other (<code>o1 eq o2</code>), they should be equal to each other (<code>o1 == o2</code>) and they should hash to the same value (<code>o1.hashCode == o2.hashCode</code>). </p></div><dl class="paramcmts block"><dt class="param">arg0</dt><dd class="cmt"><p>the object to compare against this object for reference equality.</p></dd><dt>returns</dt><dd class="cmt"><p><code>true</code> if the argument is a reference to the receiver object; <code>false</code> otherwise.</p></dd></dl><div class="block"> attributes: final </div><div class="block"> definition classes: AnyRef </div> </div> </li><li visbl="pub" name="scala.AnyRef#equals"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">equals</span><span class="params">(<span name="arg0">arg0: <span class="extype" name="scala.Any">Any</span></span>)</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> <p class="shortcomment cmt">This method is used to compare the receiver object (<code>this</code>) with the argument object (<code>arg0</code>) for equivalence.</p> <div class="fullcomment"><div class="comment cmt"><p>This method is used to compare the receiver object (<code>this</code>) with the argument object (<code>arg0</code>) for equivalence.</p><p>The default implementations of this method is an [http://en.wikipedia.org/wiki/Equivalence_relation equivalence relation]: * It is reflexive: for any instance <code>x</code> of type <code>Any</code>, <code>x.equals(x)</code> should return <code>true</code>. * It is symmetric: for any instances <code>x</code> and <code>y</code> of type <code>Any</code>, <code>x.equals(y)</code> should return <code>true</code> if and only if <code>y.equals(x)</code> returns <code>true</code>. * It is transitive: for any instances <code>x</code>, <code>y</code>, and <code>z</code> of type <code>AnyRef</code> if <code>x.equals(y)</code> returns <code>true</code> and <code>y.equals(z)</code> returns <code>true</code>, then <code>x.equals(z)</code> should return <code>true</code>.</p><p>If you override this method, you should verify that your implementation remains an equivalence relation. Additionally, when overriding this method it is often necessary to override <code>hashCode</code> to ensure that objects that are "equal" (<code>o1.equals(o2)</code> returns <code>true</code>) hash to the same scala.Int (<code>o1.hashCode.equals(o2.hashCode)</code>). </p></div><dl class="paramcmts block"><dt class="param">arg0</dt><dd class="cmt"><p>the object to compare against this object for equality.</p></dd><dt>returns</dt><dd class="cmt"><p><code>true</code> if the receiver object is equivalent to the argument; <code>false</code> otherwise.</p></dd></dl><div class="block"> definition classes: AnyRef → Any </div> </div> </li><li visbl="pub" name="scala.collection.IterableLike#exists"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">exists</span><span class="params">(<span name="p">p: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ <span class="extype" name="scala.Boolean">Boolean</span></span>)</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → TraversableLike → TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#filter"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">filter</span><span class="params">(<span name="p">p: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ <span class="extype" name="scala.Boolean">Boolean</span></span>)</span><span class="result">: <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#filterNot"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">filterNot</span><span class="params">(<span name="p">p: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ <span class="extype" name="scala.Boolean">Boolean</span></span>)</span><span class="result">: <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="prt" name="scala.AnyRef#finalize"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">finalize</span><span class="params">()</span><span class="result">: <span class="extype" name="scala.Unit">Unit</span></span> </span> </h4> <p class="shortcomment cmt">This method is called by the garbage collector on the receiver object when garbage collection determines that there are no more references to the object.</p> <div class="fullcomment"><div class="comment cmt"><p>This method is called by the garbage collector on the receiver object when garbage collection determines that there are no more references to the object.</p><p>The details of when and if the <code>finalize</code> method are invoked, as well as the interaction between <code>finalize</code>and non-local returns and exceptions, are all platform dependent.</p></div><div class="block"> attributes: protected </div><div class="block"> definition classes: AnyRef </div> </div> </li><li visbl="pub" name="scala.collection.IterableLike#find"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">find</span><span class="params">(<span name="p">p: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ <span class="extype" name="scala.Boolean">Boolean</span></span>)</span><span class="result">: <span class="extype" name="scala.Option">Option</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → TraversableLike → TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#first"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name deprecated">first</span><span class="result">: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike </div><div class="block"><ol>deprecated: <li><p>use <code>head' instead</code></p></li> </ol></div></div> </li><li visbl="pub" name="scala.collection.IterableLike#firstOption"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name deprecated">firstOption</span><span class="result">: <span class="extype" name="scala.Option">Option</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike </div><div class="block"><ol>deprecated: <li><p>use <code>headOption' instead</code></p></li> </ol></div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#flatMap"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">flatMap</span><span class="tparams">[<span name="B">B</span>, <span name="That">That</span>]</span><span class="params">(<span name="f">f: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ <span class="extype" name="scala.collection.Traversable">Traversable</span>[B]</span>)</span><span class="params">(<span class="implicit">implicit </span><span name="bf">bf: <span class="extype" name="scala.collection.generic.CanBuildFrom">CanBuildFrom</span>[<span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>], B, That]</span>)</span><span class="result">: That</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike → FilterMonadic </div></div> </li><li visbl="pub" name="scala.collection.generic.GenericTraversableTemplate#flatten"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">flatten</span><span class="tparams">[<span name="B">B</span>]</span><span class="params">(<span class="implicit">implicit </span><span name="asTraversable">asTraversable: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ <span class="extype" name="scala.collection.Traversable">Traversable</span>[B]</span>)</span><span class="result">: <span class="extype" name="scala.collection.Iterable">Iterable</span>[B]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: GenericTraversableTemplate </div></div> </li><li visbl="pub" name="kafka.message.FileMessageSet#flush"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">flush</span><span class="params">()</span><span class="result">: <span class="extype" name="scala.Unit">Unit</span></span> </span> </h4> <p class="shortcomment cmt">Commit all written data to the physical disk </p> <div class="fullcomment"><div class="comment cmt"><p>Commit all written data to the physical disk </p></div> </div> </li><li visbl="pub" name="scala.collection.TraversableOnce#foldLeft"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">foldLeft</span><span class="tparams">[<span name="B">B</span>]</span><span class="params">(<span name="z">z: B</span>)</span><span class="params">(<span name="op">op: (B, <a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ B</span>)</span><span class="result">: B</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#foldRight"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">foldRight</span><span class="tparams">[<span name="B">B</span>]</span><span class="params">(<span name="z">z: B</span>)</span><span class="params">(<span name="op">op: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>, B) ⇒ B</span>)</span><span class="result">: B</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#forall"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">forall</span><span class="params">(<span name="p">p: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ <span class="extype" name="scala.Boolean">Boolean</span></span>)</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → TraversableLike → TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#foreach"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">foreach</span><span class="tparams">[<span name="U">U</span>]</span><span class="params">(<span name="f">f: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ U</span>)</span><span class="result">: <span class="extype" name="scala.Unit">Unit</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → TraversableLike → TraversableOnce → FilterMonadic </div></div> </li><li visbl="pub" name="scala.collection.generic.GenericTraversableTemplate#genericBuilder"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">genericBuilder</span><span class="tparams">[<span name="B">B</span>]</span><span class="result">: <span class="extype" name="scala.collection.mutable.Builder">Builder</span>[B, <span class="extype" name="scala.collection.Iterable">Iterable</span>[B]]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: GenericTraversableTemplate </div></div> </li><li visbl="pub" name="scala.AnyRef#getClass"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">getClass</span><span class="params">()</span><span class="result">: java.lang.Class[_]</span> </span> </h4> <p class="shortcomment cmt">Returns a representation that corresponds to the dynamic class of the receiver object.</p> <div class="fullcomment"><div class="comment cmt"><p>Returns a representation that corresponds to the dynamic class of the receiver object.</p><p>The nature of the representation is platform dependent. </p></div><dl class="paramcmts block"><dt>returns</dt><dd class="cmt"><p>a representation that corresponds to the dynamic class of the receiver object.</p></dd></dl><div class="block"> attributes: final </div><div class="block"> definition classes: AnyRef </div> </div> </li><li visbl="pub" name="scala.collection.TraversableLike#groupBy"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">groupBy</span><span class="tparams">[<span name="K">K</span>]</span><span class="params">(<span name="f">f: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ K</span>)</span><span class="result">: <span class="extype" name="scala.collection.immutable.Map">Map</span>[K, <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#grouped"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">grouped</span><span class="params">(<span name="size">size: <span class="extype" name="scala.Int">Int</span></span>)</span><span class="result">: <span class="extype" name="scala.collection.Iterator">Iterator</span>[<span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#hasDefiniteSize"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">hasDefiniteSize</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike → TraversableOnce </div></div> </li><li visbl="pub" name="scala.AnyRef#hashCode"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">hashCode</span><span class="params">()</span><span class="result">: <span class="extype" name="scala.Int">Int</span></span> </span> </h4> <p class="shortcomment cmt">Returns a hash code value for the object.</p> <div class="fullcomment"><div class="comment cmt"><p>Returns a hash code value for the object.</p><p>The default hashing algorithm is platform dependent.</p><p>Note that it is allowed for two objects to have identical hash codes (<code>o1.hashCode.equals(o2.hashCode)</code>) yet not be equal (<code>o1.equals(o2)</code> returns <code>false</code>). A degenerate implementation could always return <code>0</code>. However, it is required that if two objects are equal (<code>o1.equals(o2)</code> returns <code>true</code>) that they have identical hash codes (<code>o1.hashCode.equals(o2.hashCode)</code>). Therefore, when overriding this method, be sure to verify that the behavior is consistent with the <code>equals</code> method. </p></div><dl class="paramcmts block"><dt>returns</dt><dd class="cmt"><p>the hash code value for the object.</p></dd></dl><div class="block"> definition classes: AnyRef → Any </div> </div> </li><li visbl="pub" name="scala.collection.IterableLike#head"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">head</span><span class="result">: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#headOption"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">headOption</span><span class="result">: <span class="extype" name="scala.Option">Option</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="pub" name="kafka.message.FileMessageSet#highWaterMark"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">highWaterMark</span><span class="params">()</span><span class="result">: <span class="extype" name="scala.Long">Long</span></span> </span> </h4> <p class="shortcomment cmt">The high water mark </p> <div class="fullcomment"><div class="comment cmt"><p>The high water mark </p></div> </div> </li><li visbl="pub" name="scala.collection.TraversableLike#init"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">init</span><span class="result">: <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#isEmpty"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">isEmpty</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → TraversableLike → TraversableOnce </div></div> </li><li visbl="pub" name="scala.Any#isInstanceOf"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">isInstanceOf</span><span class="tparams">[<span name="T0">T0</span>]</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> <p class="shortcomment cmt">This method is used to test whether the dynamic type of the receiver object is <code>T0</code>.</p> <div class="fullcomment"><div class="comment cmt"><p>This method is used to test whether the dynamic type of the receiver object is <code>T0</code>.</p><p>Note that the test result of the test is modulo Scala's erasure semantics. Therefore the expression<code>1.isInstanceOf[String]</code> will return <code>false</code>, while the expression <code>List(1).isInstanceOf[List[String]]</code> will return <code>true</code>. In the latter example, because the type argument is erased as part of compilation it is not possible to check whether the contents of the list are of the requested typed. </p></div><dl class="paramcmts block"><dt>returns</dt><dd class="cmt"><p><code>true</code> if the receiver object is an instance of erasure of type <code>T0</code>; <code>false</code> otherwise.</p></dd></dl><div class="block"> attributes: final </div><div class="block"> definition classes: Any </div> </div> </li><li visbl="pub" name="scala.collection.TraversableLike#isTraversableAgain"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">isTraversableAgain</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> <div class="fullcomment"><div class="block"> attributes: final </div><div class="block"> definition classes: TraversableLike → TraversableOnce </div></div> </li><li visbl="pub" name="kafka.message.FileMessageSet#iterator"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">iterator</span><span class="result">: <span class="extype" name="scala.collection.Iterator">Iterator</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <p class="shortcomment cmt">Get an iterator over the messages in the set </p> <div class="fullcomment"><div class="comment cmt"><p>Get an iterator over the messages in the set </p></div><div class="block"> definition classes: <a href="" class="extype" name="kafka.message.FileMessageSet">FileMessageSet</a> → <a href="MessageSet.html" class="extype" name="kafka.message.MessageSet">MessageSet</a> → IterableLike </div> </div> </li><li visbl="pub" name="scala.collection.TraversableLike#last"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">last</span><span class="result">: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#lastOption"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">lastOption</span><span class="result">: <span class="extype" name="scala.Option">Option</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#map"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">map</span><span class="tparams">[<span name="B">B</span>, <span name="That">That</span>]</span><span class="params">(<span name="f">f: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ B</span>)</span><span class="params">(<span class="implicit">implicit </span><span name="bf">bf: <span class="extype" name="scala.collection.generic.CanBuildFrom">CanBuildFrom</span>[<span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>], B, That]</span>)</span><span class="result">: That</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike → FilterMonadic </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#max"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">max</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="params">(<span class="implicit">implicit </span><span name="cmp">cmp: <span class="extype" name="scala.math.Ordering">Ordering</span>[B]</span>)</span><span class="result">: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#min"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">min</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="params">(<span class="implicit">implicit </span><span name="cmp">cmp: <span class="extype" name="scala.math.Ordering">Ordering</span>[B]</span>)</span><span class="result">: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#mkString"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">mkString</span><span class="result">: <span class="extype" name="java.lang.String">String</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#mkString"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">mkString</span><span class="params">(<span name="sep">sep: <span class="extype" name="java.lang.String">String</span></span>)</span><span class="result">: <span class="extype" name="java.lang.String">String</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#mkString"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">mkString</span><span class="params">(<span name="start">start: <span class="extype" name="java.lang.String">String</span></span>, <span name="sep">sep: <span class="extype" name="java.lang.String">String</span></span>, <span name="end">end: <span class="extype" name="java.lang.String">String</span></span>)</span><span class="result">: <span class="extype" name="java.lang.String">String</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="kafka.message.FileMessageSet#mutable"> <h4 class="signature"> <span class="kind">val</span> <span class="symbol"> <span class="name">mutable</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> </li><li visbl="pub" name="scala.AnyRef#ne"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">ne</span><span class="params">(<span name="arg0">arg0: AnyRef</span>)</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> <p class="shortcomment cmt"><code>o.ne(arg0)</code> is the same as <code>!(o.eq(arg0))</code>.</p> <div class="fullcomment"><div class="comment cmt"><p><code>o.ne(arg0)</code> is the same as <code>!(o.eq(arg0))</code>. </p></div><dl class="paramcmts block"><dt class="param">arg0</dt><dd class="cmt"><p>the object to compare against this object for reference dis-equality.</p></dd><dt>returns</dt><dd class="cmt"><p><code>false</code> if the argument is not a reference to the receiver object; <code>true</code> otherwise.</p></dd></dl><div class="block"> attributes: final </div><div class="block"> definition classes: AnyRef </div> </div> </li><li visbl="pub" name="kafka.message.FileMessageSet#needRecover"> <h4 class="signature"> <span class="kind">val</span> <span class="symbol"> <span class="name">needRecover</span><span class="result">: <span class="extype" name="java.util.concurrent.atomic.AtomicBoolean">AtomicBoolean</span></span> </span> </h4> </li><li visbl="prt" name="scala.collection.generic.GenericTraversableTemplate#newBuilder"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">newBuilder</span><span class="result">: <span class="extype" name="scala.collection.mutable.Builder">Builder</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>, <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]]</span> </span> </h4> <div class="fullcomment"><div class="block"> attributes: protected[this] </div><div class="block"> definition classes: GenericTraversableTemplate → HasNewBuilder </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#nonEmpty"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">nonEmpty</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.AnyRef#notify"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">notify</span><span class="params">()</span><span class="result">: <span class="extype" name="scala.Unit">Unit</span></span> </span> </h4> <p class="shortcomment cmt">Wakes up a single thread that is waiting on the receiver object's monitor.</p> <div class="fullcomment"><div class="comment cmt"><p>Wakes up a single thread that is waiting on the receiver object's monitor.</p></div><div class="block"> attributes: final </div><div class="block"> definition classes: AnyRef </div> </div> </li><li visbl="pub" name="scala.AnyRef#notifyAll"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">notifyAll</span><span class="params">()</span><span class="result">: <span class="extype" name="scala.Unit">Unit</span></span> </span> </h4> <p class="shortcomment cmt">Wakes up all threads that are waiting on the receiver object's monitor.</p> <div class="fullcomment"><div class="comment cmt"><p>Wakes up all threads that are waiting on the receiver object's monitor.</p></div><div class="block"> attributes: final </div><div class="block"> definition classes: AnyRef </div> </div> </li><li visbl="pub" name="scala.collection.TraversableLike#partition"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">partition</span><span class="params">(<span name="p">p: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ <span class="extype" name="scala.Boolean">Boolean</span></span>)</span><span class="result">: (<span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>], <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>])</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#product"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">product</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="params">(<span class="implicit">implicit </span><span name="num">num: <span class="extype" name="scala.math.Numeric">Numeric</span>[B]</span>)</span><span class="result">: B</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#projection"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name deprecated">projection</span><span class="result">: <span class="extype" name="scala.collection.IterableView">IterableView</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>, <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike </div><div class="block"><ol>deprecated: <li><p>use <code>view' instead</code></p></li> </ol></div></div> </li><li visbl="pub" name="kafka.message.FileMessageSet#read"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">read</span><span class="params">(<span name="readOffset">readOffset: <span class="extype" name="scala.Long">Long</span></span>, <span name="size">size: <span class="extype" name="scala.Long">Long</span></span>)</span><span class="result">: <a href="MessageSet.html" class="extype" name="kafka.message.MessageSet">MessageSet</a></span> </span> </h4> <p class="shortcomment cmt">Return a message set which is a view into this set starting from the given offset and with the given size limit.</p> <div class="fullcomment"><div class="comment cmt"><p>Return a message set which is a view into this set starting from the given offset and with the given size limit. </p></div> </div> </li><li visbl="pub" name="kafka.message.FileMessageSet#recover"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">recover</span><span class="params">()</span><span class="result">: <span class="extype" name="scala.Long">Long</span></span> </span> </h4> <p class="shortcomment cmt">Recover log up to the last complete entry.</p> <div class="fullcomment"><div class="comment cmt"><p>Recover log up to the last complete entry. Truncate off any bytes from any incomplete messages written </p></div> </div> </li><li visbl="pub" name="scala.collection.TraversableOnce#reduceLeft"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">reduceLeft</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="params">(<span name="op">op: (B, <a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ B</span>)</span><span class="result">: B</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#reduceLeftOption"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">reduceLeftOption</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="params">(<span name="op">op: (B, <a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ B</span>)</span><span class="result">: <span class="extype" name="scala.Option">Option</span>[B]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#reduceRight"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">reduceRight</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="params">(<span name="op">op: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>, B) ⇒ B</span>)</span><span class="result">: B</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#reduceRightOption"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">reduceRightOption</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="params">(<span name="op">op: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>, B) ⇒ B</span>)</span><span class="result">: <span class="extype" name="scala.Option">Option</span>[B]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#repr"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">repr</span><span class="result">: <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="prt" name="scala.collection.TraversableOnce#reversed"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">reversed</span><span class="result">: <span class="extype" name="scala.collection.immutable.List">List</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> attributes: protected[this] </div><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#sameElements"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">sameElements</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="params">(<span name="that">that: <span class="extype" name="scala.collection.Iterable">Iterable</span>[B]</span>)</span><span class="result">: <span class="extype" name="scala.Boolean">Boolean</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#scanLeft"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">scanLeft</span><span class="tparams">[<span name="B">B</span>, <span name="That">That</span>]</span><span class="params">(<span name="z">z: B</span>)</span><span class="params">(<span name="op">op: (B, <a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ B</span>)</span><span class="params">(<span class="implicit">implicit </span><span name="bf">bf: <span class="extype" name="scala.collection.generic.CanBuildFrom">CanBuildFrom</span>[<span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>], B, That]</span>)</span><span class="result">: That</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#scanRight"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">scanRight</span><span class="tparams">[<span name="B">B</span>, <span name="That">That</span>]</span><span class="params">(<span name="z">z: B</span>)</span><span class="params">(<span name="op">op: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>, B) ⇒ B</span>)</span><span class="params">(<span class="implicit">implicit </span><span name="bf">bf: <span class="extype" name="scala.collection.generic.CanBuildFrom">CanBuildFrom</span>[<span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>], B, That]</span>)</span><span class="result">: That</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#size"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">size</span><span class="result">: <span class="extype" name="scala.Int">Int</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="kafka.message.FileMessageSet#sizeInBytes"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">sizeInBytes</span><span class="params">()</span><span class="result">: <span class="extype" name="scala.Long">Long</span></span> </span> </h4> <p class="shortcomment cmt">The number of bytes taken up by this file set </p> <div class="fullcomment"><div class="comment cmt"><p>The number of bytes taken up by this file set </p></div><div class="block"> definition classes: <a href="" class="extype" name="kafka.message.FileMessageSet">FileMessageSet</a> → <a href="MessageSet.html" class="extype" name="kafka.message.MessageSet">MessageSet</a> </div> </div> </li><li visbl="pub" name="scala.collection.IterableLike#slice"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">slice</span><span class="params">(<span name="from">from: <span class="extype" name="scala.Int">Int</span></span>, <span name="until">until: <span class="extype" name="scala.Int">Int</span></span>)</span><span class="result">: <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#sliding"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">sliding</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="params">(<span name="size">size: <span class="extype" name="scala.Int">Int</span></span>, <span name="step">step: <span class="extype" name="scala.Int">Int</span></span>)</span><span class="result">: <span class="extype" name="scala.collection.Iterator">Iterator</span>[<span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#sliding"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">sliding</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="params">(<span name="size">size: <span class="extype" name="scala.Int">Int</span></span>)</span><span class="result">: <span class="extype" name="scala.collection.Iterator">Iterator</span>[<span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#span"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">span</span><span class="params">(<span name="p">p: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ <span class="extype" name="scala.Boolean">Boolean</span></span>)</span><span class="result">: (<span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>], <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>])</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#splitAt"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">splitAt</span><span class="params">(<span name="n">n: <span class="extype" name="scala.Int">Int</span></span>)</span><span class="result">: (<span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>], <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>])</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#stringPrefix"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">stringPrefix</span><span class="result">: <span class="extype" name="java.lang.String">String</span></span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#sum"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">sum</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="params">(<span class="implicit">implicit </span><span name="num">num: <span class="extype" name="scala.math.Numeric">Numeric</span>[B]</span>)</span><span class="result">: B</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.AnyRef#synchronized"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">synchronized</span><span class="tparams">[<span name="T0">T0</span>]</span><span class="params">(<span name="arg0">arg0: T0</span>)</span><span class="result">: T0</span> </span> </h4> <div class="fullcomment"><div class="block"> attributes: final </div><div class="block"> definition classes: AnyRef </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#tail"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">tail</span><span class="result">: <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#take"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">take</span><span class="params">(<span name="n">n: <span class="extype" name="scala.Int">Int</span></span>)</span><span class="result">: <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#takeRight"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">takeRight</span><span class="params">(<span name="n">n: <span class="extype" name="scala.Int">Int</span></span>)</span><span class="result">: <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#takeWhile"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">takeWhile</span><span class="params">(<span name="p">p: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ <span class="extype" name="scala.Boolean">Boolean</span></span>)</span><span class="result">: <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → TraversableLike </div></div> </li><li visbl="prt" name="scala.collection.IterableLike#thisCollection"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">thisCollection</span><span class="result">: <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> attributes: protected[this] </div><div class="block"> definition classes: IterableLike → TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#toArray"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">toArray</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="params">(<span class="implicit">implicit </span><span name="arg0">arg0: <span class="extype" name="scala.reflect.ClassManifest">ClassManifest</span>[B]</span>)</span><span class="result">: <span class="extype" name="scala.Array">Array</span>[B]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#toBuffer"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">toBuffer</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="result">: <span class="extype" name="scala.collection.mutable.Buffer">Buffer</span>[B]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="prt" name="scala.collection.IterableLike#toCollection"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">toCollection</span><span class="params">(<span name="repr">repr: <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span>)</span><span class="result">: <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> attributes: protected[this] </div><div class="block"> definition classes: IterableLike → TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#toIndexedSeq"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">toIndexedSeq</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="result">: <span class="extype" name="scala.collection.immutable.IndexedSeq">IndexedSeq</span>[B]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#toIterable"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">toIterable</span><span class="result">: <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#toIterator"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">toIterator</span><span class="result">: <span class="extype" name="scala.collection.Iterator">Iterator</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike → TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#toList"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">toList</span><span class="result">: <span class="extype" name="scala.collection.immutable.List">List</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#toMap"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">toMap</span><span class="tparams">[<span name="T">T</span>, <span name="U">U</span>]</span><span class="params">(<span class="implicit">implicit </span><span name="ev">ev: <span class="extype" name="scala.Predef.<:<"><:<</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>, (T, U)]</span>)</span><span class="result">: <span class="extype" name="scala.collection.immutable.Map">Map</span>[T, U]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#toSeq"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">toSeq</span><span class="result">: <span class="extype" name="scala.collection.Seq">Seq</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableOnce#toSet"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">toSet</span><span class="tparams">[<span name="B">B >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>]</span><span class="result">: <span class="extype" name="scala.collection.immutable.Set">Set</span>[B]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#toStream"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">toStream</span><span class="result">: <span class="extype" name="scala.collection.immutable.Stream">Stream</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → TraversableLike → TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#toString"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">toString</span><span class="params">()</span><span class="result">: <span class="extype" name="java.lang.String">String</span></span> </span> </h4> <p class="shortcomment cmt">Returns a string representation of the object.</p> <div class="fullcomment"><div class="comment cmt"><p>Returns a string representation of the object.</p><p>The default representation is platform dependent. </p></div><dl class="paramcmts block"><dt>returns</dt><dd class="cmt"><p>a string representation of the object.</p></dd></dl><div class="block"> definition classes: TraversableLike → AnyRef → Any </div> </div> </li><li visbl="pub" name="scala.collection.TraversableLike#toTraversable"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">toTraversable</span><span class="result">: <span class="extype" name="scala.collection.Traversable">Traversable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike → TraversableOnce </div></div> </li><li visbl="pub" name="scala.collection.generic.GenericTraversableTemplate#transpose"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">transpose</span><span class="tparams">[<span name="B">B</span>]</span><span class="params">(<span class="implicit">implicit </span><span name="asTraversable">asTraversable: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ <span class="extype" name="scala.collection.Traversable">Traversable</span>[B]</span>)</span><span class="result">: <span class="extype" name="scala.collection.Iterable">Iterable</span>[<span class="extype" name="scala.collection.Iterable">Iterable</span>[B]]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: GenericTraversableTemplate </div></div> </li><li visbl="pub" name="scala.collection.generic.GenericTraversableTemplate#unzip"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">unzip</span><span class="tparams">[<span name="A1">A1</span>, <span name="A2">A2</span>]</span><span class="params">(<span class="implicit">implicit </span><span name="asPair">asPair: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ (A1, A2)</span>)</span><span class="result">: (<span class="extype" name="scala.collection.Iterable">Iterable</span>[A1], <span class="extype" name="scala.collection.Iterable">Iterable</span>[A2])</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: GenericTraversableTemplate </div></div> </li><li visbl="pub" name="kafka.message.MessageSet#validate"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">validate</span><span class="params">()</span><span class="result">: <span class="extype" name="scala.Unit">Unit</span></span> </span> </h4> <p class="shortcomment cmt">Validate the checksum of all the messages in the set.</p> <div class="fullcomment"><div class="comment cmt"><p>Validate the checksum of all the messages in the set. Throws an InvalidMessageException if the checksum doesn't match the payload for any message. </p></div><div class="block"> definition classes: <a href="MessageSet.html" class="extype" name="kafka.message.MessageSet">MessageSet</a> </div> </div> </li><li visbl="pub" name="scala.collection.IterableLike#view"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">view</span><span class="params">(<span name="from">from: <span class="extype" name="scala.Int">Int</span></span>, <span name="until">until: <span class="extype" name="scala.Int">Int</span></span>)</span><span class="result">: <span class="extype" name="scala.collection.IterableView">IterableView</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>, <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → TraversableLike </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#view"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">view</span><span class="result">: <span class="extype" name="scala.collection.IterableView">IterableView</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>, <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike → TraversableLike </div></div> </li><li visbl="pub" name="scala.AnyRef#wait"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">wait</span><span class="params">()</span><span class="result">: <span class="extype" name="scala.Unit">Unit</span></span> </span> </h4> <div class="fullcomment"><div class="block"> attributes: final </div><div class="block"> definition classes: AnyRef </div></div> </li><li visbl="pub" name="scala.AnyRef#wait"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">wait</span><span class="params">(<span name="arg0">arg0: <span class="extype" name="scala.Long">Long</span></span>, <span name="arg1">arg1: <span class="extype" name="scala.Int">Int</span></span>)</span><span class="result">: <span class="extype" name="scala.Unit">Unit</span></span> </span> </h4> <div class="fullcomment"><div class="block"> attributes: final </div><div class="block"> definition classes: AnyRef </div></div> </li><li visbl="pub" name="scala.AnyRef#wait"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">wait</span><span class="params">(<span name="arg0">arg0: <span class="extype" name="scala.Long">Long</span></span>)</span><span class="result">: <span class="extype" name="scala.Unit">Unit</span></span> </span> </h4> <div class="fullcomment"><div class="block"> attributes: final </div><div class="block"> definition classes: AnyRef </div></div> </li><li visbl="pub" name="scala.collection.TraversableLike#withFilter"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">withFilter</span><span class="params">(<span name="p">p: (<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>) ⇒ <span class="extype" name="scala.Boolean">Boolean</span></span>)</span><span class="result">: <span class="extype" name="scala.collection.generic.FilterMonadic">FilterMonadic</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>, <span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>]]</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: TraversableLike → FilterMonadic </div></div> </li><li visbl="pub" name="kafka.message.FileMessageSet#writeTo"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">writeTo</span><span class="params">(<span name="destChannel">destChannel: <span class="extype" name="java.nio.channels.WritableByteChannel">WritableByteChannel</span></span>, <span name="writeOffset">writeOffset: <span class="extype" name="scala.Long">Long</span></span>, <span name="size">size: <span class="extype" name="scala.Long">Long</span></span>)</span><span class="result">: <span class="extype" name="scala.Long">Long</span></span> </span> </h4> <p class="shortcomment cmt">Write some of this set to the given channel, return the ammount written </p> <div class="fullcomment"><div class="comment cmt"><p>Write some of this set to the given channel, return the ammount written </p></div><div class="block"> definition classes: <a href="" class="extype" name="kafka.message.FileMessageSet">FileMessageSet</a> → <a href="MessageSet.html" class="extype" name="kafka.message.MessageSet">MessageSet</a> </div> </div> </li><li visbl="pub" name="scala.collection.IterableLike#zip"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">zip</span><span class="tparams">[<span name="A1">A1 >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>, <span name="B">B</span>, <span name="That">That</span>]</span><span class="params">(<span name="that">that: <span class="extype" name="scala.collection.Iterable">Iterable</span>[B]</span>)</span><span class="params">(<span class="implicit">implicit </span><span name="bf">bf: <span class="extype" name="scala.collection.generic.CanBuildFrom">CanBuildFrom</span>[<span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>], (A1, B), That]</span>)</span><span class="result">: That</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#zipAll"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">zipAll</span><span class="tparams">[<span name="B">B</span>, <span name="A1">A1 >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>, <span name="That">That</span>]</span><span class="params">(<span name="that">that: <span class="extype" name="scala.collection.Iterable">Iterable</span>[B]</span>, <span name="thisElem">thisElem: A1</span>, <span name="thatElem">thatElem: B</span>)</span><span class="params">(<span class="implicit">implicit </span><span name="bf">bf: <span class="extype" name="scala.collection.generic.CanBuildFrom">CanBuildFrom</span>[<span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>], (A1, B), That]</span>)</span><span class="result">: That</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike </div></div> </li><li visbl="pub" name="scala.collection.IterableLike#zipWithIndex"> <h4 class="signature"> <span class="kind">def</span> <span class="symbol"> <span class="name">zipWithIndex</span><span class="tparams">[<span name="A1">A1 >: <a href="Message.html" class="extype" name="kafka.message.Message">Message</a></span>, <span name="That">That</span>]</span><span class="params">(<span class="implicit">implicit </span><span name="bf">bf: <span class="extype" name="scala.collection.generic.CanBuildFrom">CanBuildFrom</span>[<span class="extype" name="scala.collection.Iterable">Iterable</span>[<a href="Message.html" class="extype" name="kafka.message.Message">Message</a>], (A1, <span class="extype" name="scala.Int">Int</span>), That]</span>)</span><span class="result">: That</span> </span> </h4> <div class="fullcomment"><div class="block"> definition classes: IterableLike </div></div> </li></ol> </div> </div> <div id="tooltip"></div> </body> </html>

api-docs/0.6/kafka/message/FileMessageSet.html (1,566 lines of code) (raw):