final class RecordSet extends IpfixSet with Iterable[Record]
A RecordSet represents an IpfixSet that contains one or more Data Records.
To create a RecordSet from an input ByteBuffer, call IpfixSet.fromBuffer().
To create a RecordSet for export, use RecordSet.empty() to create an empty RecordSet and then call addRecord() to add Records to it.
- See also
The companion object for more details.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- RecordSet
- Iterable
- IterableFactoryDefaults
- IterableOps
- IterableOnceOps
- IterableOnce
- IpfixSet
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ++[B >: Record](suffix: IterableOnce[B]): Iterable[B]
- Definition Classes
- IterableOps
- Annotations
- @inline()
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def addRecord(rec: Record): RecordSet
Adds a Record to the RecordSet.
Adds a Record to the RecordSet.
- Exceptions thrown
MessageTooLongExceptionwhen adding the record would cause the size of the exported Record Set to exceed the maximum IPFIX message size.java.lang.RuntimeExceptionwhen either the ID of the Record's Template does not match the ID specified in the Record Set or the Record's Template's Session must match the Session of the Record Set.
- final def addString(b: StringBuilder): StringBuilder
- Definition Classes
- IterableOnceOps
- Annotations
- @inline()
- final def addString(b: StringBuilder, sep: String): StringBuilder
- Definition Classes
- IterableOnceOps
- Annotations
- @inline()
- def addString(b: StringBuilder, start: String, sep: String, end: String): StringBuilder
- Definition Classes
- IterableOnceOps
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def className: String
- Attributes
- protected[this]
- Definition Classes
- Iterable
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def coll: RecordSet.this.type
- Attributes
- protected
- Definition Classes
- Iterable → IterableOps
- def collect[B](pf: PartialFunction[Record, B]): Iterable[B]
- Definition Classes
- IterableOps → IterableOnceOps
- def collectFirst[B](pf: PartialFunction[Record, B]): Option[B]
- Definition Classes
- IterableOnceOps
- def concat[B >: Record](suffix: IterableOnce[B]): Iterable[B]
- Definition Classes
- IterableOps
- def copyToArray[B >: Record](xs: Array[B], start: Int, len: Int): Int
- Definition Classes
- IterableOnceOps
- def copyToArray[B >: Record](xs: Array[B], start: Int): Int
- Definition Classes
- IterableOnceOps
- Annotations
- @deprecatedOverriding()
- def copyToArray[B >: Record](xs: Array[B]): Int
- Definition Classes
- IterableOnceOps
- Annotations
- @deprecatedOverriding()
- def corresponds[B](that: IterableOnce[B])(p: (Record, B) => Boolean): Boolean
- Definition Classes
- IterableOnceOps
- def count(p: (Record) => Boolean): Int
- Definition Classes
- IterableOnceOps
- def drop(n: Int): Iterable[Record]
- Definition Classes
- IterableOps → IterableOnceOps
- def dropRight(n: Int): Iterable[Record]
- Definition Classes
- IterableOps
- def dropWhile(p: (Record) => Boolean): Iterable[Record]
- Definition Classes
- IterableOps → IterableOnceOps
- def empty: Iterable[Record]
- Definition Classes
- IterableFactoryDefaults → IterableOps
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def exists(p: (Record) => Boolean): Boolean
- Definition Classes
- IterableOnceOps
- def filter(pred: (Record) => Boolean): Iterable[Record]
- Definition Classes
- IterableOps → IterableOnceOps
- def filterNot(pred: (Record) => Boolean): Iterable[Record]
- Definition Classes
- IterableOps → IterableOnceOps
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- def find(p: (Record) => Boolean): Option[Record]
- Definition Classes
- IterableOnceOps
- def flatMap[B](f: (Record) => IterableOnce[B]): Iterable[B]
- Definition Classes
- IterableOps → IterableOnceOps
- def flatten[B](implicit asIterable: (Record) => IterableOnce[B]): Iterable[B]
- Definition Classes
- IterableOps → IterableOnceOps
- def fold[A1 >: Record](z: A1)(op: (A1, A1) => A1): A1
- Definition Classes
- IterableOnceOps
- def foldLeft[B](z: B)(op: (B, Record) => B): B
- Definition Classes
- IterableOnceOps
- def foldRight[B](z: B)(op: (Record, B) => B): B
- Definition Classes
- IterableOnceOps
- def forall(p: (Record) => Boolean): Boolean
- Definition Classes
- IterableOnceOps
- def foreach[U](f: (Record) => U): Unit
- Definition Classes
- IterableOnceOps
- def fromSpecific(coll: IterableOnce[Record]): Iterable[Record]
- Attributes
- protected
- Definition Classes
- IterableFactoryDefaults → IterableOps
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def groupBy[K](f: (Record) => K): Map[K, Iterable[Record]]
- Definition Classes
- IterableOps
- def groupMap[K, B](key: (Record) => K)(f: (Record) => B): Map[K, Iterable[B]]
- Definition Classes
- IterableOps
- def groupMapReduce[K, B](key: (Record) => K)(f: (Record) => B)(reduce: (B, B) => B): Map[K, B]
- Definition Classes
- IterableOps
- def grouped(size: Int): Iterator[Iterable[Record]]
- Definition Classes
- IterableOps
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def head: Record
- Definition Classes
- IterableOps
- def headOption: Option[Record]
- Definition Classes
- IterableOps
- final val id: Int
- Definition Classes
- IpfixSet
- def init: Iterable[Record]
- Definition Classes
- IterableOps
- def inits: Iterator[Iterable[Record]]
- Definition Classes
- IterableOps
- def isEmpty: Boolean
- Definition Classes
- IterableOnceOps
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isTraversableAgain: Boolean
- Definition Classes
- IterableOps → IterableOnceOps
- def iterableFactory: IterableFactory[Iterable]
- Definition Classes
- Iterable → IterableOps
- def iterator: Iterator[Record]
Returns an Iterator over the Records in the Set.
Returns an Iterator over the Records in the Set.
- Definition Classes
- RecordSet → IterableOnce
- def knownSize: Int
- Definition Classes
- IterableOnce
- def last: Record
- Definition Classes
- IterableOps
- def lastOption: Option[Record]
- Definition Classes
- IterableOps
- def lazyZip[B](that: Iterable[B]): LazyZip2[Record, B, RecordSet.this.type]
- Definition Classes
- Iterable
- def map[B](f: (Record) => B): Iterable[B]
- Definition Classes
- IterableOps → IterableOnceOps
- def max[B >: Record](implicit ord: Ordering[B]): Record
- Definition Classes
- IterableOnceOps
- def maxBy[B](f: (Record) => B)(implicit cmp: Ordering[B]): Record
- Definition Classes
- IterableOnceOps
- def maxByOption[B](f: (Record) => B)(implicit cmp: Ordering[B]): Option[Record]
- Definition Classes
- IterableOnceOps
- def maxOption[B >: Record](implicit ord: Ordering[B]): Option[Record]
- Definition Classes
- IterableOnceOps
- def min[B >: Record](implicit ord: Ordering[B]): Record
- Definition Classes
- IterableOnceOps
- def minBy[B](f: (Record) => B)(implicit cmp: Ordering[B]): Record
- Definition Classes
- IterableOnceOps
- def minByOption[B](f: (Record) => B)(implicit cmp: Ordering[B]): Option[Record]
- Definition Classes
- IterableOnceOps
- def minOption[B >: Record](implicit ord: Ordering[B]): Option[Record]
- Definition Classes
- IterableOnceOps
- final def mkString: String
- Definition Classes
- IterableOnceOps
- Annotations
- @inline()
- final def mkString(sep: String): String
- Definition Classes
- IterableOnceOps
- Annotations
- @inline()
- final def mkString(start: String, sep: String, end: String): String
- Definition Classes
- IterableOnceOps
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def newSpecificBuilder: Builder[Record, Iterable[Record]]
- Attributes
- protected
- Definition Classes
- IterableFactoryDefaults → IterableOps
- def nonEmpty: Boolean
- Definition Classes
- IterableOnceOps
- Annotations
- @deprecatedOverriding()
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def partition(p: (Record) => Boolean): (Iterable[Record], Iterable[Record])
- Definition Classes
- IterableOps
- def partitionMap[A1, A2](f: (Record) => Either[A1, A2]): (Iterable[A1], Iterable[A2])
- Definition Classes
- IterableOps
- def product[B >: Record](implicit num: Numeric[B]): B
- Definition Classes
- IterableOnceOps
- def recordIterator: Iterator[Record]
Returns an Iterator over the Records in this IpfixSet, returning an empty Iterator if this is a TemplateSet.
Returns an Iterator over the Records in this IpfixSet, returning an empty Iterator if this is a TemplateSet.
- Definition Classes
- IpfixSet
- def reduce[B >: Record](op: (B, B) => B): B
- Definition Classes
- IterableOnceOps
- def reduceLeft[B >: Record](op: (B, Record) => B): B
- Definition Classes
- IterableOnceOps
- def reduceLeftOption[B >: Record](op: (B, Record) => B): Option[B]
- Definition Classes
- IterableOnceOps
- def reduceOption[B >: Record](op: (B, B) => B): Option[B]
- Definition Classes
- IterableOnceOps
- def reduceRight[B >: Record](op: (Record, B) => B): B
- Definition Classes
- IterableOnceOps
- def reduceRightOption[B >: Record](op: (Record, B) => B): Option[B]
- Definition Classes
- IterableOnceOps
- def reversed: Iterable[Record]
- Attributes
- protected
- Definition Classes
- IterableOnceOps
- def scan[B >: Record](z: B)(op: (B, B) => B): Iterable[B]
- Definition Classes
- IterableOps
- def scanLeft[B](z: B)(op: (B, Record) => B): Iterable[B]
- Definition Classes
- IterableOps → IterableOnceOps
- def scanRight[B](z: B)(op: (Record, B) => B): Iterable[B]
- Definition Classes
- IterableOps
- final val session: Session
- Definition Classes
- IpfixSet
- def size: Int
Returns the number of Records in the Set.
- def sizeCompare(that: Iterable[_]): Int
- Definition Classes
- IterableOps
- def sizeCompare(otherSize: Int): Int
- Definition Classes
- IterableOps
- final def sizeIs: SizeCompareOps
- Definition Classes
- IterableOps
- Annotations
- @inline()
- def slice(from: Int, until: Int): Iterable[Record]
- Definition Classes
- IterableOps → IterableOnceOps
- def sliding(size: Int, step: Int): Iterator[Iterable[Record]]
- Definition Classes
- IterableOps
- def sliding(size: Int): Iterator[Iterable[Record]]
- Definition Classes
- IterableOps
- def span(p: (Record) => Boolean): (Iterable[Record], Iterable[Record])
- Definition Classes
- IterableOps → IterableOnceOps
- def splitAt(n: Int): (Iterable[Record], Iterable[Record])
- Definition Classes
- IterableOps → IterableOnceOps
- def stepper[S <: Stepper[_]](implicit shape: StepperShape[Record, S]): S
- Definition Classes
- IterableOnce
- def stringPrefix: String
- Attributes
- protected[this]
- Definition Classes
- Iterable
- Annotations
- @deprecatedOverriding()
- def sum[B >: Record](implicit num: Numeric[B]): B
- Definition Classes
- IterableOnceOps
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def tail: Iterable[Record]
- Definition Classes
- IterableOps
- def tails: Iterator[Iterable[Record]]
- Definition Classes
- IterableOps
- def take(n: Int): Iterable[Record]
- Definition Classes
- IterableOps → IterableOnceOps
- def takeRight(n: Int): Iterable[Record]
- Definition Classes
- IterableOps
- def takeWhile(p: (Record) => Boolean): Iterable[Record]
- Definition Classes
- IterableOps → IterableOnceOps
- def tapEach[U](f: (Record) => U): Iterable[Record]
- Definition Classes
- IterableOps → IterableOnceOps
- final val template: Template
- def templateIterator: Iterator[Template]
Returns an Iterator over the Templates in this IpfixSet, returning an empty Iterator if this is a RecordSet.
Returns an Iterator over the Templates in this IpfixSet, returning an empty Iterator if this is a RecordSet.
- Definition Classes
- IpfixSet
- def to[C1](factory: Factory[Record, C1]): C1
- Definition Classes
- IterableOnceOps
- def toArray[B >: Record](implicit arg0: ClassTag[B]): Array[B]
- Definition Classes
- IterableOnceOps
- def toBuffer(outbuf: ByteBuffer): ByteBuffer
Appends this RecordSet to a buffer for writing to an IPFIX stream.
Appends this RecordSet to a buffer for writing to an IPFIX stream.
Assumes all Templates used by the Records in this RecordSet have been written to the Session.
- Definition Classes
- RecordSet → IpfixSet
- Exceptions thrown
java.nio.BufferOverflowExceptionif there is not enough room in the buffer for all Records in the RecordSet. Because the method may make multiple writes to the buffer, the buffer's position is unknown if an error is thrown.
- final def toBuffer[B >: Record]: Buffer[B]
- Definition Classes
- IterableOnceOps
- Annotations
- @inline()
- def toIndexedSeq: IndexedSeq[Record]
- Definition Classes
- IterableOnceOps
- def toList: List[Record]
- Definition Classes
- IterableOnceOps
- def toMap[K, V](implicit ev: <:<[Record, (K, V)]): Map[K, V]
- Definition Classes
- IterableOnceOps
- def toSeq: Seq[Record]
- Definition Classes
- IterableOnceOps
- def toSet[B >: Record]: Set[B]
- Definition Classes
- IterableOnceOps
- def toString(): String
- Definition Classes
- Iterable → AnyRef → Any
- def toVector: Vector[Record]
- Definition Classes
- IterableOnceOps
- def transpose[B](implicit asIterable: (Record) => Iterable[B]): Iterable[Iterable[B]]
- Definition Classes
- IterableOps
- def unzip[A1, A2](implicit asPair: (Record) => (A1, A2)): (Iterable[A1], Iterable[A2])
- Definition Classes
- IterableOps
- def unzip3[A1, A2, A3](implicit asTriple: (Record) => (A1, A2, A3)): (Iterable[A1], Iterable[A2], Iterable[A3])
- Definition Classes
- IterableOps
- def view: View[Record]
- Definition Classes
- IterableOps
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- def withFilter(p: (Record) => Boolean): WithFilter[Record, Iterable]
- Definition Classes
- IterableOps
- def zip[B](that: IterableOnce[B]): Iterable[(Record, B)]
- Definition Classes
- IterableOps
- def zipAll[A1 >: Record, B](that: Iterable[B], thisElem: A1, thatElem: B): Iterable[(A1, B)]
- Definition Classes
- IterableOps
- def zipWithIndex: Iterable[(Record, Int)]
- Definition Classes
- IterableOps → IterableOnceOps
Deprecated Value Members
- def ++:[B >: Record](that: IterableOnce[B]): Iterable[B]
- Definition Classes
- IterableOps
- Annotations
- @deprecated
- Deprecated
(Since version 2.13.0) Use ++ instead of ++: for collections of type Iterable
- final def /:[B](z: B)(op: (B, Record) => B): B
- Definition Classes
- IterableOnceOps
- Annotations
- @deprecated @inline()
- Deprecated
(Since version 2.13.0) Use foldLeft instead of /:
- final def :\[B](z: B)(op: (Record, B) => B): B
- Definition Classes
- IterableOnceOps
- Annotations
- @deprecated @inline()
- Deprecated
(Since version 2.13.0) Use foldRight instead of :\
- def aggregate[B](z: => B)(seqop: (B, Record) => B, combop: (B, B) => B): B
- Definition Classes
- IterableOnceOps
- Annotations
- @deprecated
- Deprecated
(Since version 2.13.0)
aggregateis not relevant for sequential collections. UsefoldLeft(z)(seqop)instead.
- def companion: IterableFactory[Iterable]
- Definition Classes
- IterableOps
- Annotations
- @deprecated @deprecatedOverriding() @inline()
- Deprecated
(Since version 2.13.0) Use iterableFactory instead
- final def copyToBuffer[B >: Record](dest: Buffer[B]): Unit
- Definition Classes
- IterableOnceOps
- Annotations
- @deprecated @inline()
- Deprecated
(Since version 2.13.0) Use
dest ++= collinstead
- def hasDefiniteSize: Boolean
- Definition Classes
- IterableOnceOps
- Annotations
- @deprecated
- Deprecated
(Since version 2.13.0) Check .knownSize instead of .hasDefiniteSize for more actionable information (see scaladoc for details)
- final def repr: Iterable[Record]
- Definition Classes
- IterableOps
- Annotations
- @deprecated
- Deprecated
(Since version 2.13.0) Use coll instead of repr in a collection implementation, use the collection value itself from the outside
- def seq: RecordSet.this.type
- Definition Classes
- Iterable
- Annotations
- @deprecated
- Deprecated
(Since version 2.13.0) Iterable.seq always returns the iterable itself
- final def toIterable: RecordSet.this.type
- Definition Classes
- Iterable → IterableOps
- Annotations
- @deprecated
- Deprecated
(Since version 2.13.7) toIterable is internal and will be made protected; its name is similar to
toListortoSeq, but it doesn't copy non-immutable collections
- final def toIterator: Iterator[Record]
- Definition Classes
- IterableOnceOps
- Annotations
- @deprecated @inline()
- Deprecated
(Since version 2.13.0) Use .iterator instead of .toIterator
- final def toStream: Stream[Record]
- Definition Classes
- IterableOnceOps
- Annotations
- @deprecated @inline()
- Deprecated
(Since version 2.13.0) Use .to(LazyList) instead of .toStream
- final def toTraversable: Traversable[Record]
- Definition Classes
- IterableOps
- Annotations
- @deprecated
- Deprecated
(Since version 2.13.0) toTraversable is internal and will be made protected; its name is similar to
toListortoSeq, but it doesn't copy non-immutable collections
- def view(from: Int, until: Int): View[Record]
- Definition Classes
- IterableOps
- Annotations
- @deprecated
- Deprecated
(Since version 2.13.0) Use .view.slice(from, until) instead of .view(from, until)
This is documentation for Mothra, a collection of Scala and Spark library functions for working with Internet-related data. Some modules contain APIs of general use to Scala programmers. Some modules make those tools more useful on Spark data-processing systems.
Please see the documentation for the individual packages for more details on their use.
Scala Packages
These packages are useful in Scala code without involving Spark:
org.cert.netsa.data
This package, which is collected as the
netsa-datalibrary, provides types for working with various kinds of information:org.cert.netsa.data.net- types for working with network dataorg.cert.netsa.data.time- types for working with time dataorg.cert.netsa.data.unsigned- types for working with unsigned integral valuesorg.cert.netsa.io.ipfix
The
netsa-io-ipfixlibrary provides tools for reading and writing IETF IPFIX data from various connections and files.org.cert.netsa.io.silk
To read and write CERT NetSA SiLK file formats and configuration files, use the
netsa-io-silklibrary.org.cert.netsa.util
The "junk drawer" of
netsa-utilso far provides only two features: First, a method for equipping Scala scala.collection.Iterators with exception handling. And second, a way to query the versions of NetSA libraries present in a JVM at runtime.Spark Packages
These packages require the use of Apache Spark:
org.cert.netsa.mothra.datasources
Spark datasources for CERT file types. This package contains utility features which add methods to Apache Spark DataFrameReader objects, allowing IPFIX and SiLK flows to be opened using simple
spark.read...calls.The
mothra-datasourceslibrary contains both IPFIX and SiLK functionality, whilemothra-datasources-ipfixandmothra-datasources-silkcontain only what's needed for the named datasource.org.cert.netsa.mothra.analysis
A grab-bag of analysis helper functions and example analyses.
org.cert.netsa.mothra.functions
This single Scala object provides Spark SQL functions for working with network data. It is the entirety of the
mothra-functionslibrary.