feat: add olap aggregation function

[nathanielc]

The aggregation function compute the stream state for each new event into a stream. All stream states are persisted into a parquet database.

TODO:

• Use schema version naming
• CLI args for flight sql path

Closes AES-289
Closes AES-290

[linear]

AES-289 OLAP Datafusion Federation

AES-290 OLAP UDAF

[samika98]

Few questions about the evaluate_all code.
I believe using topological sort would be a neater solution than the current iterative + hashmap approach.
Also concerned about termination during cycles in the current code. We might need to handle that and a return exec error

[nathanielc]

@samika98 I have updated the algo to do a single pass.

[dav1do]

I like the test. Some questions as it's a bit dense to those of us uninitiated with datafusion (their docs seem really good though so I just need to spend some time reading them).

[dav1do]

The main thing I struggled with was understanding the where things are coming from and what we're actually working with. The datafusion docs are pretty good for how this trait is used but but including a doc comment about what the expected input looks like would be helpful. Then again, the assignments into the fields makes it fairly clear, so maybe it's not useful 🤷

(these assignments)

        let event_cids = as_binary_array(&values[0])?;
        let previous_cids = as_binary_array(&values[1])?;
        let previous_states = as_string_array(&values[2])?;
        let patches = as_string_array(&values[3])?;

samika is OOO and we discussed changes already in person