Skip to content

Commit 5465573

Browse files
fix(csharp/src/Drivers/Databricks): Fix Lz4 compression logic for DatabricksReader (#2690)
This PR 9ba6bdb introduce a regression for DatabricksReader. Fix it, also remove the unneeded constructor to prevent any misuse in the future.
1 parent f69b88a commit 5465573

File tree

2 files changed

+1
-6
lines changed

2 files changed

+1
-6
lines changed

csharp/src/Drivers/Databricks/DatabricksConnection.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ internal override IArrowArrayStream NewReader<T>(T statement, Schema schema, TGe
6666
}
6767
else
6868
{
69-
return new DatabricksReader(databricksStatement, schema);
69+
return new DatabricksReader(databricksStatement, schema, isLz4Compressed);
7070
}
7171
}
7272

csharp/src/Drivers/Databricks/DatabricksReader.cs

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -34,11 +34,6 @@ internal sealed class DatabricksReader : IArrowArrayStream
3434
IArrowReader? reader;
3535
bool isLz4Compressed;
3636

37-
public DatabricksReader(DatabricksStatement statement, Schema schema)
38-
: this(statement, schema, false)
39-
{
40-
}
41-
4237
public DatabricksReader(DatabricksStatement statement, Schema schema, bool isLz4Compressed)
4338
{
4439
this.statement = statement;

0 commit comments

Comments
 (0)