org.cripac.isee.vpe.alg.pedestrian.reid

Class PedestrianReIDUsingAttrApp

java.lang.Object

org.cripac.isee.vpe.common.SparkStreamingApp

org.cripac.isee.vpe.alg.pedestrian.reid.PedestrianReIDUsingAttrApp

All Implemented Interfaces:

Serializable

public class PedestrianReIDUsingAttrApp
extends SparkStreamingApp

The PedestrianReIDApp class is a Spark Streaming application which performs pedestrian re-identification with attributes.

Author:

Ken Yu, CRIPAC, 2016

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PedestrianReIDUsingAttrApp.ReIDStream

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
PedestrianReIDUsingAttrApp(SystemPropertyCenter 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

PedestrianReIDUsingAttrApp

public PedestrianReIDUsingAttrApp(SystemPropertyCenter 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 - On failure in Spark.

Method Detail

main

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

Parameters:

args - No options supported currently.

Throws:

Exception - On failure in Spark.

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