File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1818[workspace .package ]
1919authors = [" Apache Fluss <dev@fluss.apache.org>" ]
2020categories = [" api-bindings" , " database" ]
21- description = " The rust implementation of fluss"
2221edition = " 2024"
2322homepage = " https://clients.fluss.apache.org/"
2423license = " Apache-2.0"
Original file line number Diff line number Diff line change @@ -57,11 +57,12 @@ async fn main() -> Result<()> {
5757
5858 // ---- Log table: append and scan ----
5959 let log_path = TablePath :: new (" fluss" , " events" );
60- let mut log_schema_builder = Schema :: builder ()
60+ let log_schema = Schema :: builder ()
6161 . column (" ts" , DataTypes :: bigint ())
62- . column (" message" , DataTypes :: string ());
62+ . column (" message" , DataTypes :: string ())
63+ . build ()? ;
6364 let log_descriptor = TableDescriptor :: builder ()
64- . schema (log_schema_builder . build () ? )
65+ . schema (log_schema )
6566 . build ()? ;
6667 admin . create_table (& log_path , & log_descriptor , false ). await ? ;
6768
You can’t perform that action at this time.
0 commit comments