We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6e1dd5c commit 2a9b189Copy full SHA for 2a9b189
src/parseable/streams.rs
@@ -157,15 +157,15 @@ impl Stream {
157
hostname.push_str(id);
158
}
159
let filename = format!(
160
- "{}{stream_hash}.{}.minute={}.{}.{hostname}.{ARROW_FILE_EXTENSION}",
+ "{}{stream_hash}.{}.minute={}.{}{hostname}.{ARROW_FILE_EXTENSION}",
161
Utc::now().format("%Y%m%dT%H%M"),
162
parsed_timestamp.format("date=%Y-%m-%d.hour=%H"),
163
Minute::from(parsed_timestamp).to_slot(OBJECT_STORE_DATA_GRANULARITY),
164
custom_partition_values
165
.iter()
166
.sorted_by_key(|v| v.0)
167
- .map(|(key, value)| format!("{key}={value}"))
168
- .join(".")
+ .map(|(key, value)| format!("{key}={value}."))
+ .join("")
169
);
170
self.data_path.join(filename)
171
0 commit comments