diff --git a/Snowflake.Data/Core/ArrowResultSet.cs b/Snowflake.Data/Core/ArrowResultSet.cs index 3bca7a63c..d2eae555e 100755 --- a/Snowflake.Data/Core/ArrowResultSet.cs +++ b/Snowflake.Data/Core/ArrowResultSet.cs @@ -84,7 +84,7 @@ internal override async Task NextAsync() { s_logger.Debug($"Get next chunk from chunk downloader, chunk: {_currentChunk.ChunkIndex + 1}/{_totalChunkCount}" + $" rows: {_currentChunk.RowCount}, size compressed: {_currentChunk.CompressedSize}," + - $" size decompressed: {_currentChunk.UncompressedSize}, " + ((ArrowResultChunk)_currentChunk).GetMetadata()); + $" size uncompressed: {_currentChunk.UncompressedSize}, " + ((ArrowResultChunk)_currentChunk).GetMetadata()); _currentChunk = await _chunkDownloader.GetNextChunkAsync().ConfigureAwait(false); return _currentChunk?.Next() ?? false; } @@ -103,7 +103,7 @@ internal override bool Next() { s_logger.Debug($"Get next chunk from chunk downloader, chunk: {_currentChunk.ChunkIndex + 1}/{_totalChunkCount}" + $" rows: {_currentChunk.RowCount}, size compressed: {_currentChunk.CompressedSize}," + - $" size decompressed: {_currentChunk.UncompressedSize}, " + ((ArrowResultChunk)_currentChunk).GetMetadata()); + $" size uncompressed: {_currentChunk.UncompressedSize}, " + ((ArrowResultChunk)_currentChunk).GetMetadata()); _currentChunk = Task.Run(async() => await (_chunkDownloader.GetNextChunkAsync()).ConfigureAwait(false)).Result; return _currentChunk?.Next() ?? false; diff --git a/Snowflake.Data/Core/SFResultSet.cs b/Snowflake.Data/Core/SFResultSet.cs index f8fe95f02..55b069806 100755 --- a/Snowflake.Data/Core/SFResultSet.cs +++ b/Snowflake.Data/Core/SFResultSet.cs @@ -118,7 +118,7 @@ internal override async Task NextAsync() // So put this piece of code in a seperate task s_logger.Debug($"Get next chunk from chunk downloader, chunk: {_currentChunk.ChunkIndex + 1}/{_totalChunkCount}" + $" rows: {_currentChunk.RowCount}, size compressed: {_currentChunk.CompressedSize}," + - $" size decompressed: {_currentChunk.UncompressedSize}"); + $" size uncompressed: {_currentChunk.UncompressedSize}"); BaseResultChunk nextChunk = await _chunkDownloader.GetNextChunkAsync().ConfigureAwait(false); if (nextChunk != null) { @@ -141,7 +141,7 @@ internal override bool Next() { s_logger.Debug($"Get next chunk from chunk downloader, chunk: {_currentChunk.ChunkIndex + 1}/{_totalChunkCount}" + $" rows: {_currentChunk.RowCount}, size compressed: {_currentChunk.CompressedSize}," + - $" size decompressed: {_currentChunk.UncompressedSize}"); + $" size uncompressed: {_currentChunk.UncompressedSize}"); BaseResultChunk nextChunk = Task.Run(async() => await (_chunkDownloader.GetNextChunkAsync()).ConfigureAwait(false)).Result; if (nextChunk != null) { @@ -294,8 +294,7 @@ internal override object GetValue(int ordinal) { UTF8Buffer val = GetObjectInternal(ordinal); var types = sfResultSetMetaData.GetTypesByIndex(ordinal); - var x = SFDataConverter.ConvertToCSharpVal(val, types.Item1, types.Item2); - return x; + return SFDataConverter.ConvertToCSharpVal(val, types.Item1, types.Item2); } private T GetValue(int ordinal)