NestedRecordBuilder

abstract def buildData: Option[Data]

Returns the data for the record or None if no record should be generated for the data.

abstract def dataRecord(data: Data, issues: Seq[Issue]): Rec

Returns a data record for the data.

abstract def errorRecord(issues: Seq[Issue]): Rec

Builds an error record.

final def !=(arg0: Any): Boolean

final def ##(): Int

def +(other: String): String

def ->[B](y: B): (NestedRecordBuilder[Input, Data, Rec, Ctx], B)

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def build: TraversableOnce[Rec]

Returns the record built from the input or an empty traversable if the input should be skipped.

def captureData: Option[Data]

Returns the result of buildData() after saving it in _maybeData for possible use in errorRecord().

def clone(): AnyRef

def collectAnyRecordStatistics(record: Rec): Unit

Called for every record that is emitted.

def collectDataRecordStatistics(record: Rec): Unit

Called when a record with non-empty data that should not be skipped is generated.

def collectEmptyRecordStatistics(features: Int): Unit

Called when record builder produced no data from the record input.

def collectErrorRecordStatistics(record: Rec): Unit

Called when an error record was produced.

def collectInputStatistics(): Unit

Overrides method and does not increment input.count.

def collectIssueStats(record: Rec): Unit

Called every time a record is emitted, independent of whether it has data or not and whether it is an error or not.

def collectSkippedRecordStatistics(maybeData: Option[Data]): Unit

Called when data was produced that should be skipped.

def collectStatistics(maybeRecord: Option[Rec]): Unit

Orchestrates statistics collection.

def collectUnhandledExceptionStatistics(record: Rec, ex: Throwable): Unit

Called when there is an internal error as part of record building.

def containsSomeFeatures(mask: Int): Boolean

Returns true if the feature mask collected during record building contains one of more of the 1 bits in the provided bitmask.

def debug(msg: String, detail: String, id: Int = Issue.Debug.UNKNOWN): Unit

def debug(msg: String, id: Int): Unit

def debug(msg: String): Unit

def ensuring(cond: (NestedRecordBuilder[Input, Data, Rec, Ctx]) ⇒ Boolean, msg: ⇒ Any): NestedRecordBuilder[Input, Data, Rec, Ctx]

def ensuring(cond: (NestedRecordBuilder[Input, Data, Rec, Ctx]) ⇒ Boolean): NestedRecordBuilder[Input, Data, Rec, Ctx]

def ensuring(cond: Boolean, msg: ⇒ Any): NestedRecordBuilder[Input, Data, Rec, Ctx]

def ensuring(cond: Boolean): NestedRecordBuilder[Input, Data, Rec, Ctx]

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def error(msg: String, detail: String, id: Int = Issue.Error.UNKNOWN): Unit

def error(msg: String, id: Int): Unit

def error(msg: String): Unit

def features: Int

Returns the feature mask collected during record building.

def finalize(): Unit

def formatted(fmtstr: String): String

final def getClass(): Class[_]

def hashCode(): Int

def info(msg: String, detail: String, id: Int = Issue.Info.UNKNOWN): Unit

def info(msg: String, id: Int): Unit

def info(msg: String): Unit

val input: Input

source data

final def isInstanceOf[T0]: Boolean

def jc: Ctx

Shorthand for jobContext.

val jobContext: Ctx

the job context

def maybeData: Option[Data]

Returns _maybeData.

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def notifyDetail(ex: Throwable): Unit

Notifies the builder to add this Throwable to the list from which issues will be generated.

def notifyFeatures(mask: Int): Unit

Notifies the builder to add the following features to the aggregate features.

final def synchronized[T0](arg0: ⇒ T0): T0

def throwError(message: String, messageId: Int, cause: Throwable): Nothing

def throwError(message: String, detail: String, messageId: Int, cause: Throwable): Nothing

def throwError(message: String, messageId: Int): Nothing

def throwError(message: String, detail: String, messageId: Int): Nothing

def throwError(message: String): Nothing

def throwError(message: String, detail: String): Nothing

def toRecord(maybeData: Option[Data]): Option[Rec]

Returns a record from the data or None, if no record should be emitted.

def toString(): String

def unhandledException(ex: Throwable): Rec

Returns an error record for an unhandled exception.

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

def warn(msg: String, detail: String, id: Int = Issue.Warning.UNKNOWN): Unit

def warn(msg: String, id: Int): Unit

def warn(msg: String): Unit

def →[B](y: B): (NestedRecordBuilder[Input, Data, Rec, Ctx], B)