Packages

  • package root
    Definition Classes
    root
  • package com
    Definition Classes
    root
  • package nvidia
    Definition Classes
    com
  • package mdx

    this is the base transform for mdx analytics SDK, the transform comprise of

    this is the base transform for mdx analytics SDK, the transform comprise of


    core : mdx streaming core classes
    xapp : comprise of sample applications

    Definition Classes
    nvidia
  • package core

    this is the core transform for mdx SDK, contains transform and classes for the core mdx functionality

    this is the core transform for mdx SDK, contains transform and classes for the core mdx functionality

    Definition Classes
    mdx
  • package stream
    Definition Classes
    core
  • ObjectState
  • Sink
  • StateMgmt
  • jObjectState
  • jSink
  • jStateMgmt

class jSink extends AnyRef

primarily comprises of multiple writer of kafka sink, example writer shown below

//example writer implementation
val behaviorWriter = new ForeachWriter[Option[Behavior]]{

    log.info("init frame writer")

    var producer: KProducer = _
    override def open(partitionId: Long, version: Long) = {
      producer = new KProducer(brokers)
      true
    }
    override def process(value: Option[Behavior]) = {
      //enrich Behavior object as needed
      if(value.isDefined){
        val b = value.get
      	val j = Util.jsonString(b)
      	producer.send(framesTopic, b.sensorId, j)
      }
    }
    override def close(errorOrNull: Throwable) = {
      producer.close
    }

  }

  //use of the above in StreamProcessor class
 val behaviorQuery = dataset // dataset of Message
	.groupByKey(msg => msg.key)  //represents unique object-id
	.mapGroupsWithState(processingTimeTimeout())(stateMgmt.updateBehavior)
	.writeStream
	.option("checkpointLocation", checkpoint_behavior) //checkpoint location
	.foreach(kafkasink.behaviorWriter) //write behavior to kafka
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. jSink
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new jSink(config: Map[String, String])

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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. val behaviorEWithTripwireWriter: ForeachWriter[Option[(jBehavior, jBehavior)]] { ... /* 2 definitions in type refinement */ }

    behavior writer used for tripwire, take two inputs, the original trajectory and tracklet to be used for tripwire event detection

  6. val behaviorEWriter: ForeachWriter[Option[jBehavior]] { ... /* 2 definitions in type refinement */ }

    behavior writer for cartesian / euclidean space

  7. val behaviorIWriter: ForeachWriter[Option[(jBehavior, jBehavior)]] { ... /* 2 definitions in type refinement */ }

    behavior writer in Image Coordinates, used for tripwire, take two inputs, the original trajectory and tracklet to be used for tripwire event detection

  8. val behaviorInferenceWriter: ForeachWriter[(String, List[String])] { ... /* 2 definitions in type refinement */ }

    behavior writer for Inference As a Service, inference is done using Triton Inference Server the current inference service is used find cluster index in which a trajectory belong

    behavior writer for Inference As a Service, inference is done using Triton Inference Server the current inference service is used find cluster index in which a trajectory belong

    In future more services like trajectory smoothing, pose estimation, gesture and gaze estimation will be added

  9. val behaviorWriter: ForeachWriter[Option[jBehavior]] { ... /* 2 definitions in type refinement */ }

    behavior writer used for geo spatial use case

    behavior writer used for geo spatial use case

    Apart from persisting object behavior across time, also check of anomalies like abnormal movement, speed violation and vehicle stopping

  10. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @HotSpotIntrinsicCandidate()
  11. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  13. val framesWriter: ForeachWriter[jFrameMessage] { ... /* 2 definitions in type refinement */ }

    frames writer used for enhanced frame

  14. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. val messageWriter: ForeachWriter[jMessage] { ... /* 2 definitions in type refinement */ }

    Message writer, Message represents single object detected

  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. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  22. def toString(): String
    Definition Classes
    AnyRef → Any
  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  25. 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 AnyRef

Inherited from Any

Ungrouped