case object BagDataType extends ShortEnum[BagDataType] with Product with Serializable
- Grouped
- Alphabetic
- By Inheritance
- BagDataType
- Serializable
- Product
- Equals
- ShortEnum
- ValueEnum
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def apply(v: Short): BagDataType
Converts a short value to a bag data (field) type.
Converts a short value to a bag data (field) type.
- returns
The data type represented by this value.
- Exceptions thrown
SilkDataFormatException
if the short represents no known data type.
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final macro def findValues: IndexedSeq[BagDataType]
- Attributes
- protected
- Definition Classes
- ShortEnum
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def productElementName(n: Int): String
- Definition Classes
- Product
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- lazy val values: IndexedSeq[BagDataType]
Collection of all known valid SiLK bag data types.
Collection of all known valid SiLK bag data types.
- Definition Classes
- BagDataType → ValueEnum
- final lazy val valuesToEntriesMap: Map[Short, BagDataType]
- Definition Classes
- ValueEnum
- 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 withValue(i: Short): BagDataType
- Definition Classes
- ValueEnum
- Annotations
- @SuppressWarnings()
- def withValueEither(i: Short): Either[NoSuchMember[Short, ValueEnumEntry[Short]], BagDataType]
- Definition Classes
- ValueEnum
- def withValueOpt(i: Short): Option[BagDataType]
- Definition Classes
- ValueEnum
- case object SKBAG_FIELD_ANY_COUNTRY extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_ANY_IP_PMAP extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_ANY_IPv4 extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_ANY_IPv6 extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_ANY_PORT extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_ANY_PORT_PMAP extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_ANY_SNMP extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_ANY_TIME extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_APPLICATION extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_BYTES extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_CUSTOM extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_DIP_COUNTRY extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_DIP_PMAP extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_DIPv4 extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_DIPv6 extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_DPORT extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_DPORT_PMAP extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_ELAPSED extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_ENDTIME extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_FLAGS extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_FTYPE_CLASS extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_FTYPE_TYPE extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_ICMP_TYPE_CODE extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_INIT_FLAGS extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_INPUT extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_NHIPv4 extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_NHIPv6 extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_OUTPUT extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_PACKETS extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_PROTO extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_RECORDS extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_REST_FLAGS extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_SID extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_SIP_COUNTRY extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_SIP_PMAP extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_SIPv4 extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_SIPv6 extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_SPORT extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_SPORT_PMAP extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_STARTTIME extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_SUM_BYTES extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_SUM_ELAPSED extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_SUM_PACKETS extends BagDataType with Product with Serializable
- case object SKBAG_FIELD_TCP_STATE extends BagDataType with Product with Serializable
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-data
library, 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-ipfix
library 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-silk
library.org.cert.netsa.util
The "junk drawer" of
netsa-util
so 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-datasources
library contains both IPFIX and SiLK functionality, whilemothra-datasources-ipfix
andmothra-datasources-silk
contain 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-functions
library.