See: Description
| Class | Description |
|---|---|
| AppManager | |
| InputStreamReaderRunnable |
The InputStreamReaderRunnable class is designed for running a thread
continuously reading from an input stream then display to the console.
|
| MessageHandlingApp |
The MessageHandlingApp class is a Spark Streaming application responsible for
receiving commands from sources like web-UI, then producing appropriate
command messages and sending to command-defined starting application.
|
| MessageHandlingApp.CommandType |
This class stores possible commands and the String expressions of them.
|
| MessageHandlingApp.Parameter |
The class Parameter contains a numeration of parameter types
the MessageHandlingApp may use, as well as their keys.
|
| MessageHandlingAppTest |
The MessageHandlingAppTest class is for simulating commands sent to the message
handling application through Kafka.
|
| MonitorThread | |
| MonitorThread.Report | |
| MonitorThread.Report.DevInfo | |
| SystemEntry |
The SystemEntry class provides an entrance to run any spark
streaming applications, and listen to their reports.
|
| SystemPropertyCenter |
The SystemPropertyCenter class is responsible of managing the properties of
the systems.
|
| TaskController |
The TaskController retrieves the latest 100 termination signals from Kafka and store in a
pool.
|
| TaskData |
The TaskData class contains a global execution plan and the execution result
of the predecessor node.
|
| TaskData.ExecutionPlan |
The ExecutionPlan class represents a directed acyclic graph of the
execution flows of modules.
|
| TaskData.ExecutionPlan.Node |
Each node represents a flow of DStreams in an application.
|
| Exception | Description |
|---|---|
| MessageHandlingApp.UnsupportedCommandException |