New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Remove StreamingQueryProcessor and add streaming param for other QueryProcessors #87

Open

chjuncn opened this issue Jan 28, 2025 · 0 comments

Labels

Collaborator

chjuncn commented Jan 28, 2025

StreamingQueryProcessor currently is just a way to process input and output, this concept is different from other processors.

We could:

Remove StreamingQueryProcessor
Add a new param for QueryProcessor: streaming=True/False
Implement execute_batch() and execute_streaming() under execute() based on streaming param.

chjuncn added the enhancement label

chjuncn mentioned this issue

1. support add_columns in Dataset; 2. support run().to_df(); 3. add demo in df-newinterface.py #78

Merged

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment