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
o

com.nvidia.mdx.core.util

SchemaUtil

object SchemaUtil extends Serializable

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

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. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @HotSpotIntrinsicCandidate()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  8. def frameSchema(spark: SparkSession): StructType

    returns a StructType representing Frame
    Used in conjunction with "org.apache.spark.sql.functions.from_json" which Parses a column containing a JSON string into a StructType with the specified schema.

    returns a StructType representing Frame
    Used in conjunction with "org.apache.spark.sql.functions.from_json" which Parses a column containing a JSON string into a StructType with the specified schema. Returns null, in the case of an unparseable string.

    the structType corresponds to Frame json, see com.nvidia.mdx.core.schema.frame.jFrame

    An example with SGIE  where object-type is Vehicle
    {
       "version": "4.0",
       "id": "frame-id",
       "@timestamp": "2018-04-11T04:59:59.828Z",
       "sensorId": "sensor-id",
       "objects": [
       "957|1834|150|1918|215|Vehicle|#|sedan|Bugatti|M|blue|CA 444|California|0.8",
       "..........."
    
    ]
    }
  9. def frameToMessages(frame: jFrame): Array[jMessage]
  10. def frameToTypeBbox(frame: Frame): Array[(String, String, Bbox)]
  11. def frameToTypeBbox(frame: jFrame): Array[(String, String, jBbox)]
  12. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  13. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. def jsonToNvFrame(j: String): Frame
  16. def mesageSchema(spark: SparkSession): StructType

    returns a StructType representing Message
    Used in conjunction with "org.apache.spark.sql.functions.from_json" which Parses a column containing a JSON string into a StructType with the specified schema.

    returns a StructType representing Message
    Used in conjunction with "org.apache.spark.sql.functions.from_json" which Parses a column containing a JSON string into a StructType with the specified schema. Returns null, in the case of an unparseable string.

    the structType corresponds to Message json, see com.nvidia.mdx.core.schema.jMessage

    An example of Message
    {
    "messageid": "0357d37b-122c-4591-b5a6-d34ffd6e9a22",
    "mdsversion": "1.0",
    "@timestamp": "2018-01-06T08:18:29.811Z",
    "place":
    {
    "id": "1",
    "name": "endeavor",
    "type": "building/garage",
    "location":
    {
    "lat": 37.37060687475246,
    "lon": -121.9672466762127,
    "alt": 10.0
    },
    
    "parkingSpot":
    {
    "id": "Spot-649",
    "type": "LEV",
    "level": "P1",
    "coordinate":
    {
    "x": -15.80039606856171,
    "y": -42.71209355187643,
    "z": 3.0
    }
    }
    },
    
    "sensor":
    {
    "id": "Cam_24",
    "type": "Camera",
    "location":
    {
    "lat": 37.37097419504406,
    "lon": -121.96695453400918,
    "alt": 77.83
    },
    
    "description": "Camera Cam_24",
    "coordinate":
    {
    "x": -25.79694075531654,
    "y": -40.81336573354596,
    "z": 1.0
    }
    },
    
    "analyticsModule":
    {
    "id": "AM-id",
    "description": "Parking Detection",
    "source": "OpenALR",
    "version": "1.0"
    },
    
    "object":
    {
    "id": "931",
    "vehicle":
    {
    "type": "SUV/Van",
    "make": "Jeep",
    "model": "Grand Cherokee",
    "color": "blue",
    "confidence": 0.6303990104266417,
    "license": "GYM0M3",
    "licenseState": "CA"
    },
    
    "bbox":
    {
    "topleftx": -15.80039606856171,
    "toplefty": -42.71209355187643,
    "bottomrightx": -15.80039606856171,
    "bottomrighty": -42.71209355187643
    },
    
    "signature":
    [
    0.9659786686200269,
    0.26463120365924153,
    0.4939636991282117
    ],
    
    "speed": 0.0,
    "direction": 72.90656542385659,
    "orientation": 72.90656542385659,
    "location":
    {
    "lat": 37.37099128359443,
    "lon": -121.96706774169897,
    "alt": 38.14
    },
    
    "coordinate":
    {
    "x": -15.80039606856171,
    "y": -42.71209355187643,
    "z": 3.0
    }
    },
    
    "event":
    {
    "id": "event-id",
    "type": "parked"
    },
    
    "videoPath": "http://metrovideodev/play.html?videoPath=./videos/cam_80_capture-2017-11-07_17-12-30.mp4"
    }
  17. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  19. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  20. def nvFrameToMessages(frame: Frame): Array[Message]
  21. def puckSchema(spark: SparkSession): StructType

    returns a StructType representing Puck
    Used in conjunction with "org.apache.spark.sql.functions.from_json" which Parses a column containing a JSON string into a StructType with the specified schema.

    returns a StructType representing Puck
    Used in conjunction with "org.apache.spark.sql.functions.from_json" which Parses a column containing a JSON string into a StructType with the specified schema. Returns null, in the case of an unparseable string.

    the structType corresponds to Puck json, see com.nvidia.mdx.core.schema.puck.Puck

    An example of Puck json
    
    {
    "SensorId": "0080000004003b42",
    "GatewayTime": "2018-04-18T21:43:19.317Z",
    "SENtralTime": 0,
    "PacketCounter": 32,
    "ServerTime": "2018-04-18T21:43:19.317Z",
    "LoraWan":
    {
    "fCnt": 130,
    "loRaSNR": 8.8,
    "rssi": -91,
    "gwCount": 2,
    "rxInfo":
    [
    {
    "mac": "00800000a00022f0",
    "rssi": -91,
    "loRaSNR": 8.8,
    "name": "00800000a00022f0",
    "latitude": 0,
    "longitude": 0,
    "altitude": 0
    },
    
    {
    "mac": "00800000a0001f92",
    "rssi": -104,
    "loRaSNR": 6.2,
    "name": "00800000a0001f92",
    "latitude": 0,
    "longitude": 0,
    "altitude": 0
    }
    ],
    
    "txInfo":
    {
    "frequency": 903500000,
    "dataRate":
    {
    "modulation": "LORA",
    "bandwidth": 125,
    "spreadFactor": 9
    },
    
    "adr": false,
    "codeRate": "4/5"
    }
    },
    
    "MetaError": null,
    "topic": "iot/KeepAlive",
    "CarPresence": 3,
    "Battery": 3.645,
    "Temperature": 16,
    "EventCounter": 0,
    "Latitude": 38.4209,
    "Longitude": -122.755257
    }
  22. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  23. def testSchema(spark: SparkSession): StructType
  24. def toString(): String
    Definition Classes
    AnyRef → Any
  25. def trajectorySchema(spark: SparkSession): StructType

    this schema is incomplete, used for test purpose

  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