removing eventsource for now

aloneguid · Sep 20, 2022 · 6db0e55 · 6db0e55
1 parent e69b9f9
commit 6db0e55
Show file tree

Hide file tree

Showing 4 changed files with 0 additions and 65 deletions.
diff --git a/src/Parquet/File/DataColumnReader.cs b/src/Parquet/File/DataColumnReader.cs
@@ -69,8 +69,6 @@ public DataColumn Read()
 
          _inputStream.Seek(fileOffset, SeekOrigin.Begin);
 
-         ParquetEventSource.Current.SeekColumn(_dataField.Path, fileOffset);
-
          var colData = new ColumnRawData();
          colData.maxCount = (int)_thriftColumnChunk.Meta_data.Num_values;
 
@@ -193,8 +191,6 @@ private void ReadDataPage(Thrift.PageHeader ph, ColumnRawData cd, long maxValues
             //todo: this is ugly, but will be removed once other parts are migrated to System.Memory
             using (var ms = bytes.ToStream())
             {
-               ParquetEventSource.Current.OpenDataPage(_dataField.Path, _thriftColumnChunk.Meta_data.Codec.ToString(), ms.Length);
-
                int valueCount = ph.Data_page_header.Num_values;
                using (var reader = new BinaryReader(ms))
                {

diff --git a/src/Parquet/ParquetEventSource.cs b/src/Parquet/ParquetEventSource.cs
diff --git a/src/Parquet/ParquetReader.cs b/src/Parquet/ParquetReader.cs
@@ -46,8 +46,6 @@ public ParquetReader(Stream input, ParquetOptions parquetOptions = null, bool le
          _meta = ReadMetadata();
          _footer = new ThriftFooter(_meta);
 
-         ParquetEventSource.Current.OpenStream(input.Length, leaveStreamOpen, _meta.Row_groups.Count, _meta.Num_rows);
-
          InitRowGroupReaders();
       }
 

diff --git a/src/Parquet/ParquetRowGroupReader.cs b/src/Parquet/ParquetRowGroupReader.cs
@@ -52,8 +52,6 @@ public DataColumn ReadColumn(DataField field)
       {
          if (field == null) throw new ArgumentNullException(nameof(field));
 
-         ParquetEventSource.Current.ReadColumn(field.Path);
-
          if (!_pathToChunk.TryGetValue(field.Path, out Thrift.ColumnChunk columnChunk))
          {
             throw new ParquetException($"'{field.Path}' does not exist in this file");