Packages

class StatefulEvaluationContext extends EvaluationContext

Evaluation context implementation

Linear Supertypes
EvaluationContext, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StatefulEvaluationContext
  2. EvaluationContext
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new StatefulEvaluationContext(fields: Array[Field], globalValues: Map[String, _ <: AnyRef], cache: Map[String, EnrichmentCache], metrics: ConverterMetrics, success: Counter, failure: Counter, errors: Queue[EvaluationError] = ...)

    fields

    fields to evaluate, in topological dependency order

    globalValues

    global variable name/values

    cache

    enrichment caches

    metrics

    metrics

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def accessor(name: String): FieldAccessor

    Gets a references to a field's value

    Gets a references to a field's value

    name

    field name

    Definition Classes
    StatefulEvaluationContext → EvaluationContext
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. val cache: Map[String, EnrichmentCache]

    Enrichment caches

    Enrichment caches

    Definition Classes
    StatefulEvaluationContext → EvaluationContext
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @HotSpotIntrinsicCandidate()
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  10. val errors: Queue[EvaluationError]

    Access to any errors that have occurred - note that errors will generally only be kept if the converter error mode is set to ReturnErrors

    Access to any errors that have occurred - note that errors will generally only be kept if the converter error mode is set to ReturnErrors

    Definition Classes
    StatefulEvaluationContext → EvaluationContext
  11. def evaluate(args: Array[AnyRef]): Either[EvaluationError, Array[AnyRef]]

    Evaluate all values using the given arguments.

    Evaluate all values using the given arguments. The returned array may be mutated on subsequent calls to evaluate, so shouldn't be kept long-term

    args

    single row of input

    Definition Classes
    StatefulEvaluationContext → EvaluationContext
  12. val failure: Counter

    Counter for tracking failures

    Counter for tracking failures

    Definition Classes
    StatefulEvaluationContext → EvaluationContext
  13. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  14. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  15. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  16. val line: Long

    The current line being processed.

    The current line being processed.

    This may be an actual line (e.g. a csv row), or a logical line (e.g. an avro record)

    Definition Classes
    EvaluationContext
  17. val metrics: ConverterMetrics

    Metrics registry, accessible for tracking any custom values

    Metrics registry, accessible for tracking any custom values

    Definition Classes
    StatefulEvaluationContext → EvaluationContext
  18. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  20. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  21. val success: Counter

    Counter for tracking successes

    Counter for tracking successes

    Definition Classes
    StatefulEvaluationContext → EvaluationContext
  22. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  23. def toString(): String
    Definition Classes
    AnyRef → Any
  24. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  25. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  26. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] ) @Deprecated
    Deprecated

Inherited from EvaluationContext

Inherited from AnyRef

Inherited from Any

Ungrouped