org.cripac.isee.vpe.alg.pedestrian.tracking

Class PedestrianTrackingApp

java.lang.Object

org.cripac.isee.vpe.common.SparkStreamingApp

org.cripac.isee.vpe.alg.pedestrian.tracking.PedestrianTrackingApp

All Implemented Interfaces:

Serializable

public class PedestrianTrackingApp
extends SparkStreamingApp

The PedestrianTrackingApp class takes in video URLs from Kafka, then process the videos with pedestrian tracking algorithms, and finally push the tracking results back to Kafka.

Author:

Ken Yu, CRIPAC, 2016

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PedestrianTrackingApp.AppPropertyCenter
static class	PedestrianTrackingApp.HDFSVideoTrackingStream

Field Summary

Fields

Modifier and Type	Field and Description
static String	APP_NAME The name of this application.
private static long	serialVersionUID

Fields inherited from class org.cripac.isee.vpe.common.SparkStreamingApp

loggerSingleton

Constructor Summary

Constructors

Constructor and Description
PedestrianTrackingApp(PedestrianTrackingApp.AppPropertyCenter propCenter) Constructor of the application, configuring properties read from a property center.

Method Summary

Modifier and Type	Method and Description
void	addToContext() Add streaming actions directly to the global streaming context.
static void	main(String[] args)

Methods inherited from class org.cripac.isee.vpe.common.SparkStreamingApp

awaitTermination, buildDirectStream, buildDirectStream, finalize, initialize, registerStreams, start, stop

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

APP_NAME

public static final String APP_NAME

The name of this application.

See Also:

Constant Field Values

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

Constructor Detail

PedestrianTrackingApp

public PedestrianTrackingApp(PedestrianTrackingApp.AppPropertyCenter propCenter)
                      throws Exception

Constructor of the application, configuring properties read from a property center.

Parameters:

propCenter - A class saving all the properties this application may need.

Throws:

Exception - Any exception that might occur during execution.

Method Detail

main

public static void main(String[] args)
                 throws Exception

Parameters:

args - No options supported currently.

Throws:

Exception - Any exception that might occur during execution.

addToContext

public void addToContext()
                  throws Exception

Description copied from class: SparkStreamingApp

Add streaming actions directly to the global streaming context. This is for applications that may take as input messages with types other than TaskData. Actions that take TaskData as input should be implemented in the Stream.addToGlobalStream(Map), in order to save time of deserialization. Note that existence of Kafka topics used in this method is not automatically checked.

Specified by:

addToContext in class SparkStreamingApp

Throws:

Exception