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.ctrl |
This package contains classes for controlling of the platform.
|
org.cripac.isee.vpe.data |
This package contains classes for data managing.
|
Modifier and Type | Field and Description |
---|---|
private static Stream.Port |
PedestrianAttrRecogAppTest.TEST_PED_ATTR_RECV_PORT
|
static Stream.Port |
PedestrianAttrRecogApp.RecogStream.TRACKLET_PORT
Topic to input tracklets from Kafka.
|
Modifier and Type | Method and Description |
---|---|
List<Stream.Port> |
PedestrianAttrRecogApp.RecogStream.getPorts()
Get input ports of the stream.
|
Modifier and Type | Field and Description |
---|---|
static Stream.Port |
PedestrianReIDUsingAttrApp.ReIDStream.ATTR_PORT
Port to input pedestrian attributes from Kafka.
|
static Stream.Port |
PedestrianReIDUsingAttrApp.ReIDStream.TRACKLET_ATTR_PORT
Port to input pedestrian track with attributes from Kafka.
|
static Stream.Port |
PedestrianReIDUsingAttrApp.ReIDStream.TRACKLET_PORT
Port to input pedestrian tracklets from Kafka.
|
Modifier and Type | Method and Description |
---|---|
List<Stream.Port> |
PedestrianReIDUsingAttrApp.ReIDStream.getPorts()
Get input ports of the stream.
|
Modifier and Type | Field and Description |
---|---|
static Stream.Port |
PedestrianTrackingApp.HDFSVideoTrackingStream.VIDEO_URL_PORT
Port to input video URLs from Kafka.
|
Modifier and Type | Method and Description |
---|---|
List<Stream.Port> |
PedestrianTrackingApp.HDFSVideoTrackingStream.getPorts()
|
Modifier and Type | Method and Description |
---|---|
abstract List<Stream.Port> |
Stream.getPorts()
Get input ports of the 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 | Field and Description |
---|---|
Stream.Port |
TaskData.ExecutionPlan.Node.Port.prototype
|
Modifier and Type | Field and Description |
---|---|
Map<Stream.Port,TaskData.ExecutionPlan.Node.Port>
|
TaskData.destPorts
Current nodes to execute.
|
Modifier and Type | Method and Description |
---|---|
TaskData.ExecutionPlan.Node.Port
|
TaskData.ExecutionPlan.Node.createInputPort(Stream.Port prototype)
|
TaskData.ExecutionPlan.Node
|
TaskData.getDestNode(Stream.Port port)
Get the destination node which contains the given port.
|
Modifier and Type | Method and Description |
---|---|
TaskData.ExecutionPlan.Node
|
TaskData.getDestNode(List<Stream.Port> possiblePorts)
Get the destination node which contains the given ports.
|
Constructor and Description |
---|
Port(Stream.Port prototype)
|
Modifier and Type | Field and Description |
---|---|
static Stream.Port |
DataManagingApp.AttrSavingStream.PED_ATTR_SAVING_PORT
|
static Stream.Port |
DataManagingApp.IDRankSavingStream.PED_IDRANK_SAVING_PORT
|
static Stream.Port |
DataManagingApp.TrackletSavingStream.PED_TRACKLET_SAVING_PORT
|
static Stream.Port |
DataManagingApp.VideoCuttingStream.VIDEO_URL_PORT
|
Modifier and Type | Method and Description |
---|---|
List<Stream.Port> |
DataManagingApp.VideoCuttingStream.getPorts()
|
List<Stream.Port> |
DataManagingApp.TrackletSavingStream.getPorts()
|
List<Stream.Port> |
DataManagingApp.AttrSavingStream.getPorts()
|
List<Stream.Port> |
DataManagingApp.IDRankSavingStream.getPorts()
|