Skip to content

Commit 5b0ca47

Browse files
clippy fix
1 parent 5148a57 commit 5b0ca47

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

src/event/format/known_schema.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ impl SchemaDefinition {
8282
///
8383
/// # Returns
8484
/// * `Some` - If all expected fields are already present in the object OR if extraction was successful
85-
/// Contains fields present in catch group
85+
/// Contains fields present in catch group
8686
/// * `None` - If extraction failed or no pattern was available and fields were missing
8787
pub fn check_or_extract(
8888
&self,

src/storage/localfs.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -466,7 +466,7 @@ impl ObjectStorage for LocalFS {
466466
fn get_bucket_name(&self) -> String {
467467
self.root
468468
.iter()
469-
.last()
469+
.next_back()
470470
.expect("can be unwrapped without checking as the path is absolute")
471471
.to_str()
472472
.expect("valid unicode")

src/utils/arrow/mod.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -138,9 +138,9 @@ pub fn add_parseable_fields(
138138
field_names.insert(key.to_string());
139139

140140
let value = p_custom_fields.get(key).unwrap();
141-
columns.push(Arc::new(StringArray::from_iter_values(
142-
std::iter::repeat(value).take(row_count),
143-
)) as ArrayRef);
141+
columns.push(Arc::new(StringArray::from_iter_values(std::iter::repeat_n(
142+
value, row_count,
143+
))) as ArrayRef);
144144
}
145145
}
146146

0 commit comments

Comments
 (0)