feat: Add query builder interface

[hzxa21]

Usage is shown in README.md and demo.py

• Leverage pypika to support query builder like interfaces
• Add UTs
• Clean up some codes

# Batch query
demo.groupby(demo.symbol)
        .select(demo.symbol, Sum(demo.volume))
        .orderby(Sum(demo.volume), order=Order.desc)
        .show(2)

# Streaming query
streaming = (
    rw.query()
    .from_(Tumble(demo, demo.timestamp, Interval(seconds=10)))
    .groupby("window_start", "window_end", demo.symbol)
    .select(
        "window_start",
        "window_end",
        demo.symbol,
        Round(Avg(demo.close)).as_("avg_price"),
    )
    .streaming("tick_analytics")
)
streaming.on_change(
    handler=DemoHandler.on_tick_analytics_changes,
    persist_progress=True,
    output_format=OutputFormat.DATAFRAME,
    max_batch_size=1,
)

[cloudcarver]

LGTM!