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

Class PedestrianTrackingApp.HDFSVideoTrackingStream

java.lang.Object

org.cripac.isee.vpe.common.Stream

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

All Implemented Interfaces:

Serializable

Enclosing class:

PedestrianTrackingApp

public static class PedestrianTrackingApp.HDFSVideoTrackingStream
extends Stream

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	PedestrianTrackingApp.HDFSVideoTrackingStream.ConfCache

Nested classes/interfaces inherited from class org.cripac.isee.vpe.common.Stream

Stream.Port

Field Summary

Fields

Modifier and Type	Field and Description
private Singleton<PedestrianTrackingApp.HDFSVideoTrackingStream.ConfCache>	confCacheSingleton
private String	metadataDir
static String	NAME
private int	numSamplesPerTracklet
static DataType	OUTPUT_TYPE
private static long	serialVersionUID
static Stream.Port	VIDEO_URL_PORT Port to input video URLs from Kafka.

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

loggerSingleton

Constructor Summary

Constructors

Constructor and Description
HDFSVideoTrackingStream(PedestrianTrackingApp.AppPropertyCenter propCenter)

Method Summary

Modifier and Type	Method and Description
void	addToGlobalStream(Map<DataType,org.apache.spark.streaming.api.java.JavaPairDStream<UUID,TaskData>> globalStreamMap) Add streaming actions to the global TaskData stream.
List<Stream.Port>	getPorts() Get input ports of the stream.

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

filter, output

Methods inherited from class java.lang.Object

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

Field Detail

NAME

public static final String NAME

See Also:

Constant Field Values

OUTPUT_TYPE

public static final DataType OUTPUT_TYPE

VIDEO_URL_PORT

public static final Stream.Port VIDEO_URL_PORT

Port to input video URLs from Kafka.

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

confCacheSingleton

private final Singleton<PedestrianTrackingApp.HDFSVideoTrackingStream.ConfCache> confCacheSingleton

numSamplesPerTracklet

private final int numSamplesPerTracklet

metadataDir

private final String metadataDir

Constructor Detail

HDFSVideoTrackingStream

public HDFSVideoTrackingStream(PedestrianTrackingApp.AppPropertyCenter propCenter)
                        throws Exception

Throws:

Exception

Method Detail

addToGlobalStream

public void addToGlobalStream(Map<DataType,org.apache.spark.streaming.api.java.JavaPairDStream<UUID,TaskData>> globalStreamMap)

Add streaming actions to the global TaskData stream. This global stream contains pre-deserialized TaskData messages, so as to save time.

Specified by:

addToGlobalStream in class Stream

Parameters:

globalStreamMap - A map of streams. The key of an entry is the topic name, which must be one of the DataType. The value is a filtered stream.

getPorts

public List<Stream.Port> getPorts()

Description copied from class: Stream

Get input ports of the stream.

Specified by:

getPorts in class Stream

Returns:

A list of ports.