fresh-borzoni commented on code in PR #127:
URL: https://github.com/apache/fluss-rust/pull/127#discussion_r2676683186
##########
crates/fluss/tests/integration/table.rs:
##########
@@ -469,4 +469,439 @@ mod table_test {
records.sort_by_key(|r| r.offset());
records
}
+
+ #[tokio::test]
+ async fn test_poll_batches_basic() {
+ let cluster = get_fluss_cluster();
+ let connection = cluster.get_fluss_connection().await;
+ let admin = connection.get_admin().await.expect("Failed to get admin");
+
+ let table_path = TablePath::new("fluss".to_string(),
"test_poll_batches_basic".to_string());
+
+ // Create table
+ let schema = Schema::builder()
+ .column("id", DataTypes::int())
+ .column("name", DataTypes::string())
+ .build()
+ .expect("Failed to build schema");
+
+ let descriptor = TableDescriptor::builder()
+ .schema(schema)
+ .build()
+ .expect("Failed to build table descriptor");
+
+ create_table(&admin, &table_path, &descriptor).await;
+
+ // Wait for table to be ready
+ tokio::time::sleep(Duration::from_secs(1)).await;
+
+ let table = connection
+ .get_table(&table_path)
+ .await
+ .expect("Failed to get table");
+
Review Comment:
Sure, should be easy
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
