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