| Package | Description |
|---|---|
| org.cripac.isee.vpe.alg.pedestrian.attr | |
| org.cripac.isee.vpe.alg.pedestrian.reid | |
| org.cripac.isee.vpe.alg.pedestrian.tracking | |
| org.cripac.isee.vpe.common |
This package contains common concept classes.
|
| org.cripac.isee.vpe.data |
This package contains classes for data managing.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PedestrianAttrRecogApp.RecogStream.addToGlobalStream(Map<DataType,org.apache.spark.streaming.api.java.JavaPairDStream<UUID,TaskData>> globalStreamMap)
Add streaming actions to the global
TaskData stream.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PedestrianReIDUsingAttrApp.ReIDStream.addToGlobalStream(Map<DataType,org.apache.spark.streaming.api.java.JavaPairDStream<UUID,TaskData>> globalStreamMap)
Add streaming actions to the global
TaskData stream.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PedestrianTrackingApp.HDFSVideoTrackingStream.addToGlobalStream(Map<DataType,org.apache.spark.streaming.api.java.JavaPairDStream<UUID,TaskData>> globalStreamMap)
Add streaming actions to the global
TaskData stream.
|
| Modifier and Type | Method and Description |
|---|---|
protected org.apache.spark.streaming.api.java.JavaPairDStream<UUID,TaskData> |
Stream.filter(Map<DataType,org.apache.spark.streaming.api.java.JavaPairDStream<UUID,TaskData>> streamMap,
Stream.Port port)
|
| Modifier and Type | Method and Description |
|---|---|
abstract void |
Stream.addToGlobalStream(Map<DataType,org.apache.spark.streaming.api.java.JavaPairDStream<UUID,TaskData>> globalStreamMap)
Add streaming actions to the global
TaskData stream.
|
protected org.apache.spark.streaming.api.java.JavaPairDStream<UUID,TaskData> |
Stream.filter(Map<DataType,org.apache.spark.streaming.api.java.JavaPairDStream<UUID,TaskData>> streamMap,
Stream.Port port)
|
| Modifier and Type | Method and Description |
|---|---|
void |
DataManagingApp.VideoCuttingStream.addToGlobalStream(Map<DataType,org.apache.spark.streaming.api.java.JavaPairDStream<UUID,TaskData>> globalStreamMap)
Add streaming actions to the global
TaskData stream.
|
void |
DataManagingApp.TrackletSavingStream.addToGlobalStream(Map<DataType,org.apache.spark.streaming.api.java.JavaPairDStream<UUID,TaskData>> globalStreamMap)
Add streaming actions to the global
TaskData stream.
|
void |
DataManagingApp.AttrSavingStream.addToGlobalStream(Map<DataType,org.apache.spark.streaming.api.java.JavaPairDStream<UUID,TaskData>> globalStreamMap)
Add streaming actions to the global
TaskData stream.
|
void |
DataManagingApp.IDRankSavingStream.addToGlobalStream(Map<DataType,org.apache.spark.streaming.api.java.JavaPairDStream<UUID,TaskData>> globalStreamMap)
Add streaming actions to the global
TaskData stream.
|