Merge pull request #7774 from zhang2014/remove_useless_code

chore(streams): remove useless code

Author: mergify[bot]

src/query/streams/Cargo.toml

@@ -25,7 +25,6 @@ common-io = { path = "../../common/io" }
 async-stream = "0.3.3"
 async-trait = "0.1.56"
 chrono-tz = "0.6.1"
-csv-async = "1.2.4"
 futures = "0.3.21"
 parking_lot = "0.12.1"
 pin-project-lite = "0.2.9"

src/query/streams/src/lib.rs

@@ -12,16 +12,12 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-mod sources;
 mod stream;
 mod stream_datablock;
 mod stream_error;
 mod stream_progress;
-mod stream_take;
 
-pub use sources::*;
 pub use stream::*;
 pub use stream_datablock::DataBlockStream;
 pub use stream_error::ErrorStream;
 pub use stream_progress::ProgressStream;
-pub use stream_take::TakeStream;