Skip to content

Commit e77bb23

Browse files
lausannellausannel
committed
format code
1 parent 2fd1d84 commit e77bb23

File tree

9 files changed

+36
-36
lines changed

9 files changed

+36
-36
lines changed

‎samples/Apache.IoTDB.Samples/SessionPoolTest.Record.cs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -278,7 +278,7 @@ public async Task TestInsertRecords()
278278
Task.WaitAll(tasks.ToArray());
279279
res = await session_pool.ExecuteQueryStatementAsync(
280280
"select * from " + string.Format("{0}.{1}", testDatabaseName, testDevice));
281-
281+
282282
var record_count = fetchSize * processedSize;
283283

284284
res.ShowTableNames();

‎samples/Apache.IoTDB.Samples/SessionPoolTest.cs‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -612,17 +612,17 @@ public async Task TestMultiNodeDataFetch()
612612
// fetch data
613613
var paths = new List<string>() { string.Format("{0}.{1}", device_id, testMeasurements[0]), string.Format("{0}.{1}", device_id, testMeasurements[1]) };
614614
var res = await session_pool.ExecuteQueryStatementAsync("select * from " + string.Format("{0}.{1}", testDatabaseName, testDevice));
615-
615+
616616
IReadOnlyList<string> columns = res.GetColumnNames();
617617
foreach (string columnName in columns)
618618
{
619619
Console.Write($"{columnName}\t");
620620
}
621621
Console.WriteLine();
622-
622+
623623
var count = 0;
624624
while (res.Next()) count++;
625-
625+
626626
Console.WriteLine(count + " " + (fetchSize * processedSize * 4 + 783));
627627
System.Diagnostics.Debug.Assert(count == fetchSize * processedSize * 4 + 783);
628628
await res.Close();

‎samples/Apache.IoTDB.Samples/UtilsTest.cs‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,9 +18,9 @@
1818
*/
1919

2020
using System;
21+
using System.Collections.Generic;
2122
using System.Diagnostics;
2223
using Apache.IoTDB.DataStructure;
23-
using System.Collections.Generic;
2424

2525
namespace Apache.IoTDB.Samples
2626
{
@@ -158,7 +158,7 @@ static public void PrintDataSetByObject(SessionDataSet sessionDataSet)
158158
Console.WriteLine();
159159
}
160160
}
161-
161+
162162
static public void PrintDataSetByString(SessionDataSet sessionDataSet)
163163
{
164164
IReadOnlyList<string> columns = sessionDataSet.GetColumnNames();
@@ -171,7 +171,7 @@ static public void PrintDataSetByString(SessionDataSet sessionDataSet)
171171

172172
while (sessionDataSet.Next())
173173
{
174-
for (int i = 0; i<columns.Count; i++)
174+
for (int i = 0; i < columns.Count; i++)
175175
{
176176
string columnName = columns[i];
177177
Console.Write(sessionDataSet.GetString(columnName));

‎src/Apache.IoTDB.Data/IoTDBDataReader.cs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ public class IoTDBDataReader : DbDataReader
4545
private bool _closeConnection;
4646

4747
private int _fieldCount;
48-
48+
4949
RowRecord rowdata = null;
5050

5151

‎src/Apache.IoTDB/DataStructure/Column.cs‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,7 @@ public TimeColumn(int arrayOffset, int positionCount, long[] values)
155155
positionCount: positionCount,
156156
valueIsNull: null,
157157
values: values)
158-
{}
158+
{ }
159159

160160
public override long GetLong(int position) => _values[position + _arrayOffset];
161161
public override long[] GetLongs() => _values.Skip(_arrayOffset).Take(_positionCount).ToArray();
@@ -177,7 +177,7 @@ public BinaryColumn(int arrayOffset, int positionCount, bool[] valueIsNull, Bina
177177
positionCount: positionCount,
178178
valueIsNull: null,
179179
values: values)
180-
{}
180+
{ }
181181

182182
public override Binary GetBinary(int position) => _values[position + _arrayOffset];
183183
public override Binary[] GetBinaries() => _values.Skip(_arrayOffset).Take(_positionCount).ToArray();
@@ -195,7 +195,7 @@ public IntColumn(int arrayOffset, int positionCount, bool[] valueIsNull, int[] v
195195
positionCount: positionCount,
196196
valueIsNull: null,
197197
values: values)
198-
{}
198+
{ }
199199

200200
public override int GetInt(int position) => _values[position + _arrayOffset];
201201
public override int[] GetInts() => _values.Skip(_arrayOffset).Take(_positionCount).ToArray();
@@ -213,7 +213,7 @@ public FloatColumn(int arrayOffset, int positionCount, bool[] valueIsNull, float
213213
positionCount: positionCount,
214214
valueIsNull: null,
215215
values: values)
216-
{}
216+
{ }
217217

218218
public override float GetFloat(int position) => _values[position + _arrayOffset];
219219
public override float[] GetFloats() => _values.Skip(_arrayOffset).Take(_positionCount).ToArray();
@@ -231,7 +231,7 @@ public LongColumn(int arrayOffset, int positionCount, bool[] valueIsNull, long[]
231231
positionCount: positionCount,
232232
valueIsNull: null,
233233
values: values)
234-
{}
234+
{ }
235235

236236
public override long GetLong(int position) => _values[position + _arrayOffset];
237237
public override long[] GetLongs() => _values.Skip(_arrayOffset).Take(_positionCount).ToArray();
@@ -249,7 +249,7 @@ public DoubleColumn(int arrayOffset, int positionCount, bool[] valueIsNull, doub
249249
positionCount: positionCount,
250250
valueIsNull: null,
251251
values: values)
252-
{}
252+
{ }
253253

254254
public override double GetDouble(int position) => _values[position + _arrayOffset];
255255
public override double[] GetDoubles() => _values.Skip(_arrayOffset).Take(_positionCount).ToArray();
@@ -267,7 +267,7 @@ public BooleanColumn(int arrayOffset, int positionCount, bool[] valueIsNull, boo
267267
positionCount: positionCount,
268268
valueIsNull: null,
269269
values: values)
270-
{}
270+
{ }
271271

272272
public override bool GetBoolean(int position) => _values[position + _arrayOffset];
273273
public override bool[] GetBooleans() => _values.Skip(_arrayOffset).Take(_positionCount).ToArray();
@@ -321,4 +321,4 @@ public RunLengthEncodedColumn(Column value, int positionCount)
321321

322322
public override int GetPositionCount() => _positionCount;
323323
}
324-
}
324+
}

‎src/Apache.IoTDB/DataStructure/ColumnDecoder.cs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ public interface ColumnDecoder
3131

3232
public class BaseColumnDecoder
3333
{
34-
34+
3535
private static Dictionary<ColumnEncoding, ColumnDecoder> decoders = new Dictionary<ColumnEncoding, ColumnDecoder>
3636
{
3737
{ ColumnEncoding.Int32Array, new Int32ArrayColumnDecoder() },
@@ -217,4 +217,4 @@ public Column ReadColumn(ByteBuffer reader, TSDataType dataType, int positionCou
217217
return new RunLengthEncodedColumn(column, positionCount);
218218
}
219219
}
220-
}
220+
}

‎src/Apache.IoTDB/DataStructure/RpcDataSet.cs‎

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,8 @@
2020
using System;
2121
using System.Collections.Generic;
2222
using System.Linq;
23-
using System.Threading.Tasks;
2423
using System.Text;
24+
using System.Threading.Tasks;
2525
using Thrift;
2626

2727
namespace Apache.IoTDB.DataStructure
@@ -663,7 +663,7 @@ public RowRecord GetRow()
663663
string err_msg = "value format not supported";
664664
throw new TException(err_msg, null);
665665
}
666-
if(localfield != null)
666+
if (localfield != null)
667667
fieldList.Add(localfield);
668668
i += 1;
669669
}
@@ -775,7 +775,7 @@ private int GetTsBlockColumnIndexForColumnName(string columnName)
775775
throw new ArgumentException($"Column {columnName} not found");
776776
return index;
777777
}
778-
778+
779779
public int FindColumn(string columnName)
780780
{
781781
if (!_columnOrdinalMap.TryGetValue(columnName, out int ordinal))
@@ -787,9 +787,9 @@ public string FindColumnNameByIndex(int columnIndex)
787787
{
788788
if (columnIndex <= 0)
789789
throw new ArgumentOutOfRangeException(nameof(columnIndex), "Column index should start from 1");
790-
790+
791791
if (columnIndex > _columnNameList.Count)
792-
throw new ArgumentOutOfRangeException(nameof(columnIndex),
792+
throw new ArgumentOutOfRangeException(nameof(columnIndex),
793793
$"Column index {columnIndex} out of range {_columnNameList.Count}");
794794

795795
return _columnNameList[columnIndex - 1];
@@ -799,17 +799,17 @@ private int GetTsBlockColumnIndexForColumnIndex(int columnIndex)
799799
{
800800
int adjustedIndex = columnIndex - 1;
801801
if (adjustedIndex < 0 || adjustedIndex >= _columnIndex2TsBlockColumnIndexList.Count)
802-
throw new ArgumentOutOfRangeException(nameof(columnIndex),
802+
throw new ArgumentOutOfRangeException(nameof(columnIndex),
803803
$"Index {adjustedIndex} out of range {_columnIndex2TsBlockColumnIndexList.Count}");
804-
804+
805805
return _columnIndex2TsBlockColumnIndexList[adjustedIndex];
806806
}
807807

808808
private void CheckRecord()
809809
{
810-
if (_queryResultIndex > _queryResultSize ||
811-
_tsBlockIndex >= _tsBlockSize ||
812-
_queryResult == null ||
810+
if (_queryResultIndex > _queryResultSize ||
811+
_tsBlockIndex >= _tsBlockSize ||
812+
_queryResult == null ||
813813
_curTsBlock == null)
814814
{
815815
throw new InvalidOperationException("No record remains");
@@ -844,4 +844,4 @@ public bool HasCachedRecord
844844

845845
public bool IsIgnoreTimestamp() => _ignoreTimestamp;
846846
}
847-
}
847+
}

‎src/Apache.IoTDB/DataStructure/SessionDataSet.cs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ public SessionDataSet(
6767
_columnTypeLst = ColumnTypeList;
6868
_zoneId = zoneId;
6969
_clientQueue = _clientQueueS;
70-
70+
7171
_rpcDataSet = new RpcDataSet(
7272
_sql, _columnNames, _columnTypeLst, _columnNameIndexMap, IgnoreTimeStamp,
7373
MoreData, _queryId, _statementId, _client, _client.SessionId, QueryResult, FetchSize,

‎src/Apache.IoTDB/DataStructure/TsBlock.cs‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -44,9 +44,9 @@ public TsBlock(int positionCount, Column timeColumn, params Column[] valueColumn
4444
for (int i = 0; i < ValueColumnCount; i++)
4545
{
4646
if (valueColumns[i].GetPositionCount() != positionCount)
47-
throw new ArgumentException(
48-
$"input positionCount {positionCount} does not match valueColumn{i}.positionCount {valueColumns[i].GetPositionCount()}"
49-
);
47+
throw new ArgumentException(
48+
$"input positionCount {positionCount} does not match valueColumn{i}.positionCount {valueColumns[i].GetPositionCount()}"
49+
);
5050
}
5151
}
5252

@@ -72,10 +72,10 @@ public static TsBlock Deserialize(ByteBuffer reader)
7272
// Read position count
7373
var positionCount = reader.GetInt();
7474

75-
// Read column encodings
75+
// Read column encodings
7676
// Read time column encoding
7777
ColumnEncoding timeColumnEncodings = DeserializeColumnEncoding(reader);
78-
78+
7979
// Read value column encodings
8080
var valuecolumnEncodings = new ColumnEncoding[valueColumnCount];
8181
for (int i = 1; i < valueColumnCount + 1; i++)
@@ -121,4 +121,4 @@ private static ColumnEncoding DeserializeColumnEncoding(ByteBuffer reader)
121121
public IReadOnlyList<Column> ValueColumns => _valueColumns;
122122
public Column GetColumn(int columnIndex) => _valueColumns[columnIndex];
123123
}
124-
}
124+
}

0 commit comments

Comments
 (0)