Add Streaming source impl

[penghuo]

Signed-off-by: Peng Huo [email protected]

Description

• Add generice StreamingSource interface.
• Add FileSystemStreamingSource implementation base on hadoop fs.
• Exclude uncessary depedency from hadoop-commons, the opensearch-sql.zip size is around 50M. (currently, 33M)
• More info Add Stream Source #969.

Future Work

• [FEATURE] Implement FileSystemStreamSource state recovery. #1007

Check List

• New functionality includes testing.
  • All tests pass, including unit test, integration test and doctest
• New functionality has been documented.
  • New functionality has javadoc added
  • New functionality has user manual doc added
• Commits are signed per the DCO using --signoff

By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.
For more information on following Developer Certificate of Origin and signing off your commits, please check here.

[codecov-commenter]

Codecov Report

Merging #994 (e2e3cd8) into feature/maximus-m1 (eea2689) will decrease coverage by 35.51%.
The diff coverage is n/a.

@@                    Coverage Diff                    @@
##             feature/maximus-m1     #994       +/-   ##
=========================================================
- Coverage                 98.27%   62.76%   -35.52%     
=========================================================
  Files                       339       10      -329     
  Lines                      8545      658     -7887     
  Branches                    561      119      -442     
=========================================================
- Hits                       8398      413     -7985     
- Misses                      142      192       +50     
- Partials                      5       53       +48     

Flag	Coverage Δ
query-workbench	62.76% <ø> (?)
sql-engine	?

Flags with carried forward coverage won't be shown. Click here to find out more.

Impacted Files	Coverage Δ
...c/main/java/org/opensearch/sql/sql/SQLService.java
...nsearch/sql/expression/aggregation/Aggregator.java
...h/sql/expression/conditional/cases/WhenClause.java
...age/serialization/DefaultExpressionSerializer.java
...nsearch/sql/planner/physical/RareTopNOperator.java
.../filter/lucene/relevance/MatchBoolPrefixQuery.java
...sql/opensearch/request/OpenSearchQueryRequest.java
...h/planner/logical/rule/PushProjectAndRelation.java
...ilter/lucene/relevance/MatchPhrasePrefixQuery.java
...ch/storage/script/filter/lucene/WildcardQuery.java
... and 339 more

Help us with your feedback. Take ten seconds to tell us how you rate us. Have a feature suggestion? Share it here.

[dai-chen]

Thanks for the changes!