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 Sink extends Serializable

primarily comprises of multiple writers of kafka sink and a milvus sink, example writer shown below

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

     log.info("init  writer")

     var producer: KProducerByteArray = _
     override def open(partitionId: Long, version: Long) = {
       producer = new KProducerByteArray(brokers)
       true
     }
     override def process(value: Option[Behavior]) = {
       //enrich Behavior object as needed
       if(value.isDefined){
         val b = value.get
         producer.send(behaviorTopic, b.getSensor.id, b.toByteArray)

       }
     }
     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(sink.behaviorWriter) //write behavior to kafka
Linear Supertypes
Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Sink
  2. Serializable
  3. Serializable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Sink(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[(Behavior, Behavior)]] { ... /* 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[Behavior]] { ... /* 2 definitions in type refinement */ }

    behavior writer for cartesian / euclidean space

  7. val behaviorIWriter: ForeachWriter[Option[(Behavior, Behavior)]] { ... /* 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[Behavior])] { ... /* 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[Behavior]] { ... /* 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 frameListWriter: ForeachWriter[List[FrameMessage]] { ... /* 2 definitions in type refinement */ }

    frame list writer used for enhanced frame

  14. val frameWriter: ForeachWriter[FrameMessage] { ... /* 2 definitions in type refinement */ }

    frame writer used for enhanced frame

  15. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  16. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  17. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  18. lazy val log: Logger

    init logger

    init logger

    Annotations
    @transient()
  19. val milvusWriter: ForeachWriter[(String, List[Behavior])]
  20. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  21. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  22. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  23. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  24. def toString(): String
    Definition Classes
    AnyRef → Any
  25. def upsert(behaviors: List[Behavior]): Unit

  26. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  27. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  28. 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 Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped