File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
crates/iceberg/src/writer Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 145145//! }
146146//!
147147//! #[async_trait::async_trait]
148- //! impl<B: IcebergWriterBuilder + Sync > IcebergWriterBuilder for LatencyRecordWriterBuilder<B> {
148+ //! impl<B: IcebergWriterBuilder> IcebergWriterBuilder for LatencyRecordWriterBuilder<B> {
149149//! type R = LatencyRecordWriter<B::R>;
150150//!
151151//! async fn build(&self, partition_key: Option<PartitionKey>) -> Result<Self::R> {
@@ -398,7 +398,7 @@ type DefaultOutput = Vec<DataFile>;
398398
399399/// The builder for iceberg writer.
400400#[ async_trait:: async_trait]
401- pub trait IcebergWriterBuilder < I = DefaultInput , O = DefaultOutput > : Send + ' static {
401+ pub trait IcebergWriterBuilder < I = DefaultInput , O = DefaultOutput > : Send + Sync + ' static {
402402 /// The associated writer type.
403403 type R : IcebergWriter < I , O > ;
404404 /// Build the iceberg writer with an optional partition key.
You can’t perform that action at this time.
0 commit comments