Skip to content

Commit 86aab05

Browse files
committed
Fix wasm build
1 parent 3d646d7 commit 86aab05

5 files changed

Lines changed: 5 additions & 0 deletions

File tree

datafusion/core/src/datasource/file_format/arrow.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -144,6 +144,7 @@ impl FileFormat for ArrowFormat {
144144
for object in objects {
145145
let r = store.as_ref().get(&object.location).await?;
146146
let schema = match r.payload {
147+
#[cfg(not(target_arch = "wasm32"))]
147148
GetResultPayload::File(mut file, _) => {
148149
let reader = FileReader::try_new(&mut file, None)?;
149150
reader.schema()

datafusion/core/src/datasource/physical_plan/arrow_file.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -273,6 +273,7 @@ impl FileOpener for ArrowOpener {
273273
None => {
274274
let r = object_store.get(file_meta.location()).await?;
275275
match r.payload {
276+
#[cfg(not(target_arch = "wasm32"))]
276277
GetResultPayload::File(file, _) => {
277278
let arrow_reader = arrow::ipc::reader::FileReader::try_new(
278279
file, projection,

datafusion/datasource-csv/src/source.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -704,6 +704,7 @@ impl FileOpener for CsvOpener {
704704
let result = store.get_opts(file_meta.location(), options).await?;
705705

706706
match result.payload {
707+
#[cfg(not(target_arch = "wasm32"))]
707708
GetResultPayload::File(mut file, _) => {
708709
let is_whole_file_scanned = file_meta.range.is_none();
709710
let decoder = if is_whole_file_scanned {

datafusion/datasource-json/src/file_format.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -209,6 +209,7 @@ impl FileFormat for JsonFormat {
209209

210210
let r = store.as_ref().get(&object.location).await?;
211211
let schema = match r.payload {
212+
#[cfg(not(target_arch = "wasm32"))]
212213
GetResultPayload::File(file, _) => {
213214
let decoder = file_compression_type.convert_read(file)?;
214215
let mut reader = BufReader::new(decoder);

datafusion/datasource-json/src/source.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -355,6 +355,7 @@ impl FileOpener for JsonOpener {
355355
let result = store.get_opts(file_meta.location(), options).await?;
356356

357357
match result.payload {
358+
#[cfg(not(target_arch = "wasm32"))]
358359
GetResultPayload::File(mut file, _) => {
359360
let bytes = match file_meta.range {
360361
None => file_compression_type.convert_read(file)?,

0 commit comments

Comments
 (0)