org.cripac.isee.vpe.data

Class DataManagingApp.TrackletPackingThread

java.lang.Object

org.cripac.isee.vpe.data.DataManagingApp.TrackletPackingThread

All Implemented Interfaces:

Runnable

Enclosing class:

DataManagingApp

static class DataManagingApp.TrackletPackingThread
extends Object
implements Runnable

This is a thread independent from Spark Streaming, which listen to tracklet packing jobs from Kafka, and perform HAR packing. There is no need to worry about job loss due to system faults, since offsets are committed after jobs are finished, so interrupted jobs can be retrieved from Kafka and executed again on another start of this thread. This thread is to be started together with the DataManagingApp.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) Properties	consumerProperties
(package private) GraphDatabaseConnector	dbConnector
(package private) static String	JOB_TOPIC
(package private) Logger	logger
private static int	MAX_POLL_INTERVAL_MS
private int	maxPollRecords
(package private) String	metadataDir
private AtomicReference<Boolean>	running

Constructor Summary

Constructors

Constructor and Description
TrackletPackingThread(DataManagingApp.AppPropertyCenter propCenter, AtomicReference<Boolean> running)

Method Summary

Modifier and Type	Method and Description
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

JOB_TOPIC

static final String JOB_TOPIC

See Also:

Constant Field Values

consumerProperties

final Properties consumerProperties

metadataDir

final String metadataDir

logger

final Logger logger

running

private final AtomicReference<Boolean> running

dbConnector

final GraphDatabaseConnector dbConnector

MAX_POLL_INTERVAL_MS

private static final int MAX_POLL_INTERVAL_MS

See Also:

Constant Field Values

maxPollRecords

private int maxPollRecords

Constructor Detail

TrackletPackingThread

TrackletPackingThread(DataManagingApp.AppPropertyCenter propCenter,
                      AtomicReference<Boolean> running)

Method Detail

run

public void run()

Specified by:

run in interface Runnable