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 util
    Definition Classes
    core
  • package kafka
    Definition Classes
    util
  • package kml

    primarily comprise of KMLWriter classes, these utility classed are used to validate calibration, malformed trajectories etc.

    primarily comprise of KMLWriter classes, these utility classed are used to validate calibration, malformed trajectories etc.

    Definition Classes
    util
  • package osm
    Definition Classes
    util
  • package playback

    primarily comprise of playback classes, these utility classed are used to simulate perception layer, send Frames or Messages from input file.

    primarily comprise of playback classes, these utility classed are used to simulate perception layer, send Frames or Messages from input file.

    Definition Classes
    util
  • CRP
  • Config
  • DistanceUtil
  • Encryptor
  • Implicits
  • MapMatchingUtil
  • SchemaUtil
  • Util

class Config extends Serializable

utility class which provides all the default configuration

Kafka Topics example when rawTopic = mdx-raw, the prefix mdx- is used for rest of the topic name generation

	alertsTopic = mdx-alerts
	framesTopic = mdx-frames
	behaviorTopic = mdx-behavior
	behaviorPlusTopic = mdx-behavior-plus
	tripwireTopic = mdx-tripwire

User can always override the above in the configuration

Also provides default configuration for various anomalies, this could be sensor specific or application wide

  • Abnormal Movement
  • Speeding anomaly
  • unexpected stopping

other Cofiguration include

  • Default Triton Inference Server host and port
  • checkpoint directory
  • threshold used for clustering
Linear Supertypes
Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Config
  2. Serializable
  3. Serializable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Config(config: Map[String, String] = Map.empty)

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 abnormalDistanceThreshold(implicit sensorId: String): Double

    default is 60 meters

  5. def abnormalMinTrajectoryLen(implicit sensorId: String): Int

    default is 40 points

  6. def abnormalRelativeDirectionChangeEnable(implicit sensorId: String): Boolean

    default is true

  7. def abnormalRelativeMaxThreshold(implicit sensorId: String): Double

    default is 20 meters

  8. def abnormalRelativeThreshold(implicit sensorId: String): Double

    default is 2.5

  9. def abnormalTimeIntervalThreshold(implicit sensorId: String): Double

    default is 6 seconds

  10. def abnormalUseLinearDistance(implicit sensorId: String): Boolean

    default is true

  11. lazy val abnormal_filtered_list: List[String]

    list of sensors to ignore while doing anomaly detection

  12. lazy val alertsTopic: String
  13. def anomalyDetectionCheck(implicit sensorId: String): Boolean
  14. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  15. lazy val behaviorPlusTopic: String
  16. lazy val behaviorStateTimeout: Long
  17. lazy val behaviorTopic: String
  18. lazy val behaviorWatermark: Int
  19. def changeInDirectionDegree(implicit sensorId: String): Double

    default is 30 degrees

  20. def changeInDirectionDistance(implicit sensorId: String): Int

    default is 20 meters

  21. def changeInDirectionStep(implicit sensorId: String): Int

    default is 5

  22. val checkpoint_dir: String

    checkpoint_dir, default value "checkpoint"

  23. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @HotSpotIntrinsicCandidate()
  24. def clusterTimeIntervalThreshold(implicit sensorId: String): Double

    default is 2 seconds, a behavior object will be assigned a cluster index if the time interval is > threshold, used for traffic pattern

  25. var config: Map[String, String]
  26. val dataType: String

    input data type, default value "protobuf", other option is "json"

  27. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  28. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  29. lazy val framesTopic: String
  30. def getBooleanValue(sensorId: String, key: String, dValue: Boolean): Boolean
  31. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  32. def getDoubleValue(sensorId: String, key: String, dValue: Double): Double
  33. def getIntValue(sensorId: String, key: String, dValue: Int): Int
  34. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  35. lazy val inferenceTriggerInterval: String

    default is "10 seconds", the enhance-behavior pipeline will be triggered based on this value

  36. def initConfig: Unit

    to be invoked only when running locally

  37. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  38. lazy val kafkaBrokers: String

    kafka broker and topics, global to all sensors

  39. def localMode: Boolean
  40. lazy val log: Logger

    init logger

    init logger

    Annotations
    @transient()
  41. lazy val maxBehaviorPointsStored: Int
  42. lazy val milvusBboxAspectRatioMax: Double

    milvus bboxAspectRatio min / max

  43. lazy val milvusBboxAspectRatioMin: Double

    milvus bboxAspectRatio min / max

  44. lazy val milvusBboxConfidence: Double

    milvus bboxConfidence

  45. lazy val milvusBboxSize: Int

    milvus bboxSize

  46. lazy val milvusClusterThreshold: Double

    milvus ClusterThreshold

  47. lazy val milvusCollection: String

    milvus collection name

  48. lazy val milvusHost: String

    milvus DB host

  49. lazy val milvusIndexParam: String

    milvus indexParam

  50. lazy val milvusIndexType: String

    milvus indexType

  51. lazy val milvusMetricType: String

    milvus metricType

  52. lazy val milvusPartitioningStrategy: String

    milvus PartitioningStrategy

  53. lazy val milvusPort: Int

    milvus DB grpc port

  54. lazy val milvusSensorIdMaxLength: Int

    milvus sensor id max length

  55. lazy val milvusTriggerInterval: String

    default is "60 seconds", the milvus-insertion pipeline will be triggered based on this value

  56. lazy val milvusVectorDim: Int

    milvus embedding vector dimension

  57. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  58. lazy val notificationTopic: String
  59. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  60. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  61. def proximityDetectionThreshold(implicit sensorId: String): Double
  62. lazy val rawTopic: String
  63. val resetMilvus: Boolean

    milvus reset flag

  64. lazy val sensorConfigMap: Map[String, Map[String, String]]
  65. def speedMphThreshold(implicit sensorId: String): Double
  66. def speedTimeIntervalThreshold(implicit sensorId: String): Double
  67. def stoppingMphThreshold(implicit sensorId: String): Double
  68. def stoppingTimeIntervalThreshold(implicit sensorId: String): Double
  69. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  70. val sys: String

    configuration init

  71. def toString(): String
    Definition Classes
    AnyRef → Any
  72. lazy val topic: String
  73. lazy val topicPrefix: String
  74. def tripwireMinPoints(implicit sensorId: String): Int

    default is 5

  75. lazy val tripwireTopic: String
  76. lazy val tritonHost: String

    triton inference server host

  77. lazy val tritonPort: Int

    triton inference server grpc port

  78. def validBehaviorLength(implicit sensorId: String): Int

    default is 10 i.e.

    default is 10 i.e. at 10 object detections are needed to form a valid behavior object

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