[Stream Insight] Application DEV.

n  Main Process

1.     Create Server Instance

2.     Create Application

3.     Create Input Stream Object

4.     Create Query Template Object

5.     Create & Register Input Adaptor

6.     Create & Register Output Adaptor

7.     Create Query Binder Object

8.     Bind a Query Template Input to Input Adaptor

9.     Add an Output Adaptor as Event Consumer

10.   Create Runnable Query

11.   Start Query

n  Input Adaptor

1.     Create Configuration Class

2.     Create Factory Class

3.     Create Stream Input Class

• Implement Functions
  • public override void Start()
  • public override void Resume()
  • Implement Event Creation Function
• Event Creation Function
  • Check the state of Adaptor
  • If the state is Stopping → Stopped Adaptor → return
  • Create event populate payload
  • Enqueue event with payload
  • Check the enqueue result
  • If result is Full → Ready Adaptor → return

 

n  Output Adaptor

1.     Create Configuration Class

2.     Create Factory Class

3.     Create Stream Output Class

• Implement Functions
  • public override void Start()
  • public override void Resume()
  • Implement Event consume Function
• Event consume Function
  • Check the state of Adaptor
  • If the state is Stopping → Stopped Adaptor → return
  • Dequeue the event
  • Check the dequeue result
  • If result is Empty → Ready Adaptor → return