org.cripac.isee.vpe.alg.pedestrian.attr

Class PedestrianAttrRecogApp

java.lang.Object

org.cripac.isee.vpe.common.SparkStreamingApp

org.cripac.isee.vpe.alg.pedestrian.attr.PedestrianAttrRecogApp

All Implemented Interfaces:

Serializable

public class PedestrianAttrRecogApp
extends SparkStreamingApp

The PedestrianAttrRecogApp class is a Spark Streaming application which performs pedestrian attribute recognition.

Author:

Ken Yu, CRIPAC, 2016

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PedestrianAttrRecogApp.Algorithm Available algorithms of pedestrian attribute recognition.
static class	PedestrianAttrRecogApp.AppPropertyCenter
static class	PedestrianAttrRecogApp.RecogStream

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
PedestrianAttrRecogApp(PedestrianAttrRecogApp.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

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

APP_NAME

public static final String APP_NAME

The name of this application.

See Also:

Constant Field Values

Constructor Detail

PedestrianAttrRecogApp

public PedestrianAttrRecogApp(PedestrianAttrRecogApp.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

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

main

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

Parameters:

args - No options supported currently.

Throws:

Exception - Any exception that might occur during execution.