You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@avro.apache.org by mg...@apache.org on 2022/02/04 09:13:20 UTC
[avro] branch branch-1.11 updated: AVRO-3356 simplify naming in DataFileReader (#1507)
This is an automated email from the ASF dual-hosted git repository.
mgrigorov pushed a commit to branch branch-1.11
in repository https://gitbox.apache.org/repos/asf/avro.git
The following commit(s) were added to refs/heads/branch-1.11 by this push:
new 1bc7986 AVRO-3356 simplify naming in DataFileReader (#1507)
1bc7986 is described below
commit 1bc79861c3d7202d117ecf88711f3418c57d637e
Author: Kyle Schoonover <ky...@minmaxcorp.com>
AuthorDate: Fri Feb 4 01:12:56 2022 -0800
AVRO-3356 simplify naming in DataFileReader (#1507)
* AVRO-3356 simplify naming in DataFileReader
* Tickle to rebuild
* remove change
Co-authored-by: Kyle T. Schoonover <Ky...@nordstrom.com>
(cherry picked from commit 3c55d2610169f299b73bd453c293a4c91d193c2c)
---
lang/csharp/src/apache/main/File/DataFileReader.cs | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
diff --git a/lang/csharp/src/apache/main/File/DataFileReader.cs b/lang/csharp/src/apache/main/File/DataFileReader.cs
index c96b68a..a9033a6 100644
--- a/lang/csharp/src/apache/main/File/DataFileReader.cs
+++ b/lang/csharp/src/apache/main/File/DataFileReader.cs
@@ -30,7 +30,7 @@ namespace Avro.File
/// Provides access to Avro data written using the <see cref="DataFileWriter{T}" />.
/// </summary>
/// <typeparam name="T">Type to deserialze data objects to.</typeparam>
- /// <seealso cref="Avro.File.IFileReader<T>" />
+ /// <seealso cref="IFileReader<T>" />
public class DataFileReader<T> : IFileReader<T>
{
/// <summary>
@@ -334,7 +334,7 @@ namespace Avro.File
if (HasNextBlock())
{
_currentBlock = NextRawBlock(_currentBlock);
- _currentBlock.Data = _codec.Decompress(_currentBlock.Data, (int)this._blockSize);
+ _currentBlock.Data = _codec.Decompress(_currentBlock.Data, (int)_blockSize);
_datumDecoder = new BinaryDecoder(_currentBlock.GetDataAsStream());
}
}
@@ -381,7 +381,7 @@ namespace Avro.File
/// Initializes the specified stream.
/// </summary>
/// <param name="stream">The stream.</param>
- /// <exception cref="Avro.AvroRuntimeException">
+ /// <exception cref="AvroRuntimeException">
/// Not a valid data file!
/// or
/// Not a valid data file!.
@@ -476,7 +476,7 @@ namespace Avro.File
/// </summary>
/// <param name="reuse">The reuse.</param>
/// <returns>Next deserialized data entry.</returns>
- /// <exception cref="Avro.AvroRuntimeException">No more datum objects remaining in block!
+ /// <exception cref="AvroRuntimeException">No more datum objects remaining in block!
/// or
/// Error fetching next object from block: {0}.
/// </exception>
@@ -515,7 +515,7 @@ namespace Avro.File
/// </summary>
/// <param name="reuse">The reuse.</param>
/// <returns>Data Block.</returns>
- /// <exception cref="Avro.AvroRuntimeException">
+ /// <exception cref="AvroRuntimeException">
/// No data remaining in block!
/// or
/// Invalid sync!.
@@ -566,7 +566,7 @@ namespace Avro.File
/// <returns>
/// <c>true</c> if [has next block]; otherwise, <c>false</c>.
/// </returns>
- /// <exception cref="Avro.AvroRuntimeException">
+ /// <exception cref="AvroRuntimeException">
/// Block size invalid or too large for this implementation: " + _blockSize
/// or
/// Error ascertaining if data has next block: {0}.
@@ -602,7 +602,7 @@ namespace Avro.File
}
_blockSize = _decoder.ReadLong(); // read block size
- if (_blockSize > System.Int32.MaxValue || _blockSize < 0)
+ if (_blockSize > int.MaxValue || _blockSize < 0)
{
throw new AvroRuntimeException("Block size invalid or too large for this " +
"implementation: " + _blockSize);
@@ -620,7 +620,7 @@ namespace Avro.File
/// <summary>
/// Encapsulates a block of data read by the <see cref="DataFileReader{T}" />.
/// </summary>
- /// <seealso cref="Avro.File.IFileReader<T>" />
+ /// <seealso cref="IFileReader<T>" />
private class DataBlock
{
/// <summary>