Reactive extensions experts using c#


Need to get following reactive queries developed -

Scenario - Three types of objects - GrandParent,Parent,Child

Test Scenario - Create 4 objects of each type


Parent- P11,P12,P13,P14,P21,P22,P23,P24,P31,P32,P41,P42

Child - C111,C112,C121,C122,C123,C121,C122,C123,C124,C131,C132,C141,C142 and so on

Relationship - GP1 is related to P11, P12,P13, P14 . Relationship from P to G is called "Parent"

P11 is related to C111,C112 Relationship from C to P is called "ParentOf" and relationship P to C is called "ChildOf"

( first number represent object of GrandParent, 2nd Parent, 3 is for child) .This is just sample (object name can be anything)

we have event -



string objectType;

string name;

string pc ;

string dc;

string reason;

int cond;


here cond=1 means active event

cond =2 mean event now inactive

Reactive Query Requirement (You are getting continuous stream of events, which can be corresponding to any type with any name or other properties)

Requirement 1-

a) If I recv events where pc= "CD" and cond=1 where objectType = "CHILD" for all the childs of a given parent during duration X sec, create a new event for corresponding parent with PC="PC" and cond =1, reason="CD", if during the duration X, if for anychild you recv pc=CD and cond=2 the scenario is no longer valid

b)If you recv a event with pc= "CD" and cond =2 for a child and during that time PC="PC" and cond =1, reason="CD" exist for its parent , wait for N sec, if during the time you recv a event with cond = 1 for the same child, do nothing, otherwise raise event PC="PC" and cond =2, reason="CD".

Consider following function, you can hardcode them

a)GetNodeCount(string NodeType,string NodeName,string RelationShipKind)

b)GetNodeRelation(string NodeType,string NodeName, string RelationShipKind) -

Example of function B call - if for child C1, i want to want to find a relation of kind ParentOf

the function call will look like GetNodeRelation("CHILD","C111", "ParentOf") it will give P11

Example of function A call - if I want to find number of child of the parent C1111 , i can use it like - GetNodeCount("PARENT",GetNodeRelation("CHILD","C111", "ParentOf") ,"CHILDOF")

c) RaiseEvent(AEvent evt) - The moment you raise it, on the next statement if you try function as mentioned in d, you will get 1.

d) GetExistingEventCount(string wherecondition) - this is to get count of events matching a given condition ; where condition is of like requlaer sql condition, like if i want to check if there exists a event with objecttype="CHILD" and name = "ABC" my where condtion will look like "objecttype='CHILD' and name = 'ABC'

Requirement 2

Its same as requirement 1, only difference is there is no constrain of time X there in point 1

Requirement 3

There is a Continuous influx of csv - csv is for the form (first line is header)

KeyCol1,KeyCol2,KeyCol3, Date, Time, D1,D2,D3,D4

Requirement - (Say GapTime is 15 minutes)

a) For each KeyColumn combination, output the different of last 2 values ( say you recvd 1st file at time 10:15 which has data for key1,Key2,Key3,Key4

then at 10:30 you got the 2nd file, at this time you will output key1,Key2,Key3,Key4,from 10:30 file(D1) - 10:15 (D1), 10:30 file (D2) - 10:15(d2)

and so on

and now you can relase 10:15 data for key1,key2,key3,key4 and keep 10:30 data for key1,Key2,Key3,Key4

if you never recvd 10:45 data, but directly recvd 11:00 data, then you dont output anything, just release 10:30 data and keep 11:00 data

Skills: .NET

See more: reactive extensions experts, test scenario, net experts, matching string, string matching, reactive, hardcode, data experts, childs, c1, check parent, count objects, point matching, sql query duration, net create csv file, sql scenario, reactive extensions csv, sql int date, output using, reactive extensions, sql query find date, net name matching, continuous line, 2nd file, event stream

About the Employer:
( 0 reviews ) ANUSHAKTI NAGAR, India

Project ID: #4498093