class
FileMessageSet
extends MessageSet with Logging
Instance Constructors
-
new
FileMessageSet
(file: File, channel: FileChannel, start: Int, end: Int)
-
new
FileMessageSet
(file: File, mutable: Boolean)
-
new
FileMessageSet
(file: File)
-
new
FileMessageSet
(file: File, channel: FileChannel)
Value Members
-
def
!=
(arg0: AnyRef): Boolean
-
def
!=
(arg0: Any): Boolean
-
def
##
(): Int
-
def
++
[B >: MessageAndOffset, That]
(that: TraversableOnce[B])(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That
-
def
++
[B >: MessageAndOffset, That]
(that: GenTraversableOnce[B])(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That
-
def
++:
[B >: MessageAndOffset, That]
(that: Traversable[B])(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That
-
def
++:
[B >: MessageAndOffset, That]
(that: TraversableOnce[B])(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That
-
def
/:
[B]
(z: B)(op: (B, MessageAndOffset) ⇒ B): B
-
def
/:\
[A1 >: MessageAndOffset]
(z: A1)(op: (A1, A1) ⇒ A1): A1
-
def
:\
[B]
(z: B)(op: (MessageAndOffset, B) ⇒ B): B
-
def
==
(arg0: AnyRef): Boolean
-
def
==
(arg0: Any): Boolean
-
def
addString
(b: StringBuilder): StringBuilder
-
def
addString
(b: StringBuilder, sep: String): StringBuilder
-
def
addString
(b: StringBuilder, start: String, sep: String, end: String): StringBuilder
-
def
aggregate
[B]
(z: B)(seqop: (B, MessageAndOffset) ⇒ B, combop: (B, B) ⇒ B): B
-
-
def
asInstanceOf
[T0]
: T0
-
def
canEqual
(that: Any): Boolean
-
def
clone
(): AnyRef
-
def
close
(): Unit
-
def
collect
[B, That]
(pf: PartialFunction[MessageAndOffset, B])(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That
-
def
collectFirst
[B]
(pf: PartialFunction[MessageAndOffset, B]): Option[B]
-
def
companion
: GenericCompanion[Iterable]
-
def
copyToArray
[B >: MessageAndOffset]
(xs: Array[B], start: Int, len: Int): Unit
-
def
copyToArray
[B >: MessageAndOffset]
(xs: Array[B]): Unit
-
def
copyToArray
[B >: MessageAndOffset]
(xs: Array[B], start: Int): Unit
-
def
copyToBuffer
[B >: MessageAndOffset]
(dest: Buffer[B]): Unit
-
-
def
debug
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
debug
(e: ⇒ Throwable): Any
-
def
debug
(msg: ⇒ String): Unit
-
def
delete
(): Boolean
-
-
def
dropRight
(n: Int): Iterable[MessageAndOffset]
-
-
def
eq
(arg0: AnyRef): Boolean
-
def
equals
(arg0: Any): Boolean
-
def
error
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
error
(e: ⇒ Throwable): Any
-
def
error
(msg: ⇒ String): Unit
-
def
exists
(p: (MessageAndOffset) ⇒ Boolean): Boolean
-
def
fatal
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
fatal
(e: ⇒ Throwable): Any
-
def
fatal
(msg: ⇒ String): Unit
-
var
file
: File
-
-
-
def
finalize
(): Unit
-
-
def
flatMap
[B, That]
(f: (MessageAndOffset) ⇒ GenTraversableOnce[B])(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That
-
def
flatten
[B]
(implicit asTraversable: (MessageAndOffset) ⇒ TraversableOnce[B]): Traversable[B]
-
def
flush
(): Unit
-
def
fold
[A1 >: MessageAndOffset]
(z: A1)(op: (A1, A1) ⇒ A1): A1
-
def
foldLeft
[B]
(z: B)(op: (B, MessageAndOffset) ⇒ B): B
-
def
foldRight
[B]
(z: B)(op: (MessageAndOffset, B) ⇒ B): B
-
def
forall
(p: (MessageAndOffset) ⇒ Boolean): Boolean
-
def
foreach
[U]
(f: (MessageAndOffset) ⇒ U): Unit
-
def
genericBuilder
[B]
: Builder[B, Iterable[B]]
-
def
getClass
(): java.lang.Class[_]
-
-
def
grouped
(size: Int): Iterator[Iterable[MessageAndOffset]]
-
def
hasDefiniteSize
: Boolean
-
def
hashCode
(): Int
-
-
-
def
info
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
info
(e: ⇒ Throwable): Any
-
def
info
(msg: ⇒ String): Unit
-
-
-
def
isEmpty
: Boolean
-
def
isInstanceOf
[T0]
: Boolean
-
def
isTraversableAgain
: Boolean
-
def
iterator
(maxMessageSize: Int): Iterator[MessageAndOffset]
-
-
-
-
var
logIdent
: String
-
lazy val
logger
: Logger
-
val
loggerName
: String
-
def
map
[B, That]
(f: (MessageAndOffset) ⇒ B)(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That
-
-
-
-
-
def
mkString
: String
-
def
mkString
(sep: String): String
-
def
mkString
(start: String, sep: String, end: String): String
-
def
ne
(arg0: AnyRef): Boolean
-
-
def
nonEmpty
: Boolean
-
def
notify
(): Unit
-
def
notifyAll
(): Unit
-
-
-
-
def
product
[B >: MessageAndOffset]
(implicit num: Numeric[B]): B
-
def
read
(position: Int, size: Int): FileMessageSet
-
def
readInto
(buffer: ByteBuffer, relativePosition: Int): ByteBuffer
-
def
reduce
[A1 >: MessageAndOffset]
(op: (A1, A1) ⇒ A1): A1
-
-
-
def
reduceOption
[A1 >: MessageAndOffset]
(op: (A1, A1) ⇒ A1): Option[A1]
-
-
-
def
renameTo
(f: File): Boolean
-
-
-
def
sameElements
[B >: MessageAndOffset]
(that: Iterable[B]): Boolean
-
def
sameElements
[B >: MessageAndOffset]
(that: GenIterable[B]): Boolean
-
def
scan
[B >: MessageAndOffset, That]
(z: B)(op: (B, B) ⇒ B)(implicit cbf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That
-
def
scanLeft
[B, That]
(z: B)(op: (B, MessageAndOffset) ⇒ B)(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That
-
def
scanRight
[B, That]
(z: B)(op: (MessageAndOffset, B) ⇒ B)(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That
-
def
searchFor
(targetOffset: Long, startingPosition: Int): OffsetPosition
-
-
def
size
: Int
-
def
sizeInBytes
(): Int
-
def
slice
(from: Int, until: Int): Iterable[MessageAndOffset]
-
-
-
-
-
def
stringPrefix
: String
-
def
sum
[B >: MessageAndOffset]
(implicit num: Numeric[B]): B
-
def
swallow
(action: ⇒ Unit): Unit
-
def
swallowDebug
(action: ⇒ Unit): Unit
-
def
swallowError
(action: ⇒ Unit): Unit
-
def
swallowInfo
(action: ⇒ Unit): Unit
-
def
swallowTrace
(action: ⇒ Unit): Unit
-
def
swallowWarn
(action: ⇒ Unit): Unit
-
def
synchronized
[T0]
(arg0: ⇒ T0): T0
-
-
-
-
def
takeRight
(n: Int): Iterable[MessageAndOffset]
-
-
-
def
toArray
[B >: MessageAndOffset]
(implicit arg0: ClassManifest[B]): Array[B]
-
-
-
def
toIndexedSeq
[B >: MessageAndOffset]
: IndexedSeq[B]
-
-
-
-
def
toMap
[T, U]
(implicit ev: <:<[MessageAndOffset, (T, U)]): Map[T, U]
-
-
-
-
def
toString
(): String
-
def
toTraversable
: Traversable[MessageAndOffset]
-
def
trace
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
trace
(e: ⇒ Throwable): Any
-
def
trace
(msg: ⇒ String): Unit
-
def
transpose
[B]
(implicit asTraversable: (MessageAndOffset) ⇒ TraversableOnce[B]): Traversable[Traversable[B]]
-
def
truncateTo
(targetSize: Int): Int
-
def
unzip
[A1, A2]
(implicit asPair: (MessageAndOffset) ⇒ (A1, A2)): (Iterable[A1], Iterable[A2])
-
def
unzip3
[A1, A2, A3]
(implicit asTriple: (MessageAndOffset) ⇒ (A1, A2, A3)): (Iterable[A1], Iterable[A2], Iterable[A3])
-
-
-
def
wait
(): Unit
-
def
wait
(arg0: Long, arg1: Int): Unit
-
def
wait
(arg0: Long): Unit
-
def
warn
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
warn
(e: ⇒ Throwable): Any
-
def
warn
(msg: ⇒ String): Unit
-
-
def
writeTo
(destChannel: GatheringByteChannel, writePosition: Long, size: Int): Int
-
def
zip
[A1 >: MessageAndOffset, B, That]
(that: Iterable[B])(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], (A1, B), That]): That
-
def
zip
[A1 >: MessageAndOffset, B, That]
(that: GenIterable[B])(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], (A1, B), That]): That
-
def
zipAll
[B, A1 >: MessageAndOffset, That]
(that: Iterable[B], thisElem: A1, thatElem: B)(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], (A1, B), That]): That
-
def
zipAll
[B, A1 >: MessageAndOffset, That]
(that: GenIterable[B], thisElem: A1, thatElem: B)(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], (A1, B), That]): That
-
def
zipWithIndex
[A1 >: MessageAndOffset, That]
(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], (A1, Int), That]): That
Inherited from Equals
Inherited from AnyRef
Inherited from Any
An on-disk message set. An optional start and end position can be applied to the message set which will allow slicing a subset of the file.