Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
131 commits
Select commit Hold shift + click to select a range
d295b5c
add interface for addValueOfDataType
jt2594838 Jul 7, 2026
23c2f35
add interface for createValueColumnOfDataType
jt2594838 Jul 7, 2026
76b1c08
add interface for serializeColumn
jt2594838 Jul 7, 2026
2f2b5cf
add interface for readvaluesFromBuffer
jt2594838 Jul 7, 2026
a342057
add interface for equals
jt2594838 Jul 7, 2026
671c97c
add interface for getValue
jt2594838 Jul 7, 2026
93eaa34
add interface for ramBytesUsed
jt2594838 Jul 7, 2026
3c76323
add interface for ramBytesUsed
jt2594838 Jul 7, 2026
b67b008
add interface for createColumn
jt2594838 Jul 7, 2026
46db79b
Add TypeServices
jt2594838 Jul 13, 2026
138d70d
Add TypeServices
jt2594838 Jul 13, 2026
3ca5c85
Add getTsPrimitiveType
jt2594838 Jul 13, 2026
79b6b21
Add arePositionsEqual
jt2594838 Jul 13, 2026
dfe73df
Add arePositionsEqual
jt2594838 Jul 13, 2026
82cba6d
Add getDefaultEncoding
jt2594838 Jul 13, 2026
0e84e70
Add toBytes
jt2594838 Jul 13, 2026
dc087c8
Add getCompressor
jt2594838 Jul 13, 2026
b95cfad
Add calcTypeSize
jt2594838 Jul 13, 2026
657e9e1
Add getDecoder
jt2594838 Jul 14, 2026
0050db8
Add getOneItemMaxSize
jt2594838 Jul 14, 2026
7111b7c
Add updateStatistics
jt2594838 Jul 14, 2026
59a9280
Add getCurrentValue
jt2594838 Jul 14, 2026
f067288
refactor calcTypeSize
jt2594838 Jul 14, 2026
f384a1e
refactor calcTypeSize
jt2594838 Jul 14, 2026
a403a13
refactor currentTsPrimitiveType
jt2594838 Jul 14, 2026
61b44e7
refactor BatchData.init
jt2594838 Jul 14, 2026
baa4722
refactor BatchData.putAnObject
jt2594838 Jul 14, 2026
27b8bbb
refactor BatchData.serializeData
jt2594838 Jul 14, 2026
f715876
refactor DescReadWriteBatchData.new
jt2594838 Jul 14, 2026
d27a487
refactor DescReadWriteBatchData.serializeData
jt2594838 Jul 14, 2026
789ea03
refactor Field.getStringValue
jt2594838 Jul 14, 2026
670514d
add Type.estimateArraySize
jt2594838 Jul 14, 2026
65cc017
add Type.estimateArraySize
jt2594838 Jul 14, 2026
1b57257
add Type.estimateValueSize
jt2594838 Jul 14, 2026
3487c73
add Field.getObjectValue
jt2594838 Jul 14, 2026
e74c2ce
add Field.getField
jt2594838 Jul 14, 2026
8367206
add Field.setTsPrimitiveValue
jt2594838 Jul 14, 2026
560f082
add Type.deserializeColumn
jt2594838 Jul 14, 2026
b431e1c
add Type.deserializeColumn
jt2594838 Jul 14, 2026
8618486
add Column.serializeWithoutNulls
jt2594838 Jul 14, 2026
a410c13
add Type.createNullColumn
jt2594838 Jul 14, 2026
f9ebbe9
add Type.addPoint
jt2594838 Jul 15, 2026
e28b0c5
add READ_PAGE_VALUE_TO_BATCHDATA_SERVICE
jt2594838 Jul 15, 2026
f537048
add READ_PAGE_VALUE_TO_TSBLOCK_SERVICE
jt2594838 Jul 15, 2026
3109428
refactor nextBatch
jt2594838 Jul 15, 2026
45e92b0
refactor nextValue
jt2594838 Jul 15, 2026
74df158
refactor nextValueBatch
jt2594838 Jul 15, 2026
6263681
refactor writeColumnBuilderWithNextBatch
jt2594838 Jul 15, 2026
2496389
refactor writeColumnBuilderWithNextBatch
jt2594838 Jul 15, 2026
c5d0839
refactor writeColumnBuilderWithNextBatch
jt2594838 Jul 15, 2026
20de1d2
refactor writeEmptyDataInOneRow
jt2594838 Jul 15, 2026
b667845
refactor getDataPoint
jt2594838 Jul 15, 2026
d0b1593
refactor write
jt2594838 Jul 15, 2026
09a435d
refactor write
jt2594838 Jul 15, 2026
1fe0a48
refactor write
jt2594838 Jul 15, 2026
94392a3
refactor write
jt2594838 Jul 15, 2026
6a49281
refactor write
jt2594838 Jul 15, 2026
908778e
refactor batchWrite
jt2594838 Jul 15, 2026
276d21c
refactor writeWithTsRecord
jt2594838 Jul 15, 2026
b455d28
refactor getEncoder
jt2594838 Jul 15, 2026
35d3349
refactor getEncoder
jt2594838 Jul 15, 2026
0f17adb
add Type.copyArrayElement
jt2594838 Jul 15, 2026
834c693
add Type.arrayCopyOf
jt2594838 Jul 15, 2026
37c8f36
remove Type.copyArrayElement
jt2594838 Jul 15, 2026
bb44fbc
refactor getEncoder
jt2594838 Jul 15, 2026
f33b505
add Type.setTo
jt2594838 Jul 15, 2026
8788ea9
add REGULAR_ENCODER_SERVICE
jt2594838 Jul 15, 2026
79205ab
add GORILLA_V2_ENCODER_SERVICE
jt2594838 Jul 15, 2026
581ef77
add estimateArraySize
jt2594838 Jul 15, 2026
718d3e8
refactor addValue
jt2594838 Jul 16, 2026
469647f
add Date compatibility
jt2594838 Jul 16, 2026
c648de0
add Date compatibility
jt2594838 Jul 16, 2026
e7959bc
refactor putValueToField
jt2594838 Jul 16, 2026
0ec71f5
add Type.serializeValue
jt2594838 Jul 16, 2026
23ca7f5
refactor fetchRecords
jt2594838 Jul 16, 2026
a1b78eb
add Type.serializeValue
jt2594838 Jul 16, 2026
1a9fc7e
refactor copy
jt2594838 Jul 16, 2026
e8a9784
add Type.deserialize
jt2594838 Jul 16, 2026
da79d14
refactor fillSingleMeasurementColumn
jt2594838 Jul 16, 2026
16cf244
refactor setTo
jt2594838 Jul 16, 2026
da643ec
refactor fillIdColumn
jt2594838 Jul 16, 2026
bae9a84
add Type.serializeArray
jt2594838 Jul 17, 2026
fe0a118
refactor updateWithoutTimeColumn
jt2594838 Jul 17, 2026
cf393a4
refactor rewrite
jt2594838 Jul 17, 2026
e96b0ff
enhance type check
jt2594838 Jul 17, 2026
0b49964
add Type.serializedSize
jt2594838 Jul 17, 2026
f41019e
refactor rewrite
jt2594838 Jul 17, 2026
69cef4c
refactor TsBlockBuilder
jt2594838 Jul 17, 2026
49569b5
refactor buildValueColumnBuilders
jt2594838 Jul 17, 2026
36efcdb
refactor buildValueColumnBuilders
jt2594838 Jul 17, 2026
c00177f
add createStatistics
jt2594838 Jul 17, 2026
fe3dd2e
add getValueAsTsPrimitiveType
jt2594838 Jul 17, 2026
7df7dfd
refactor getSizeByType
jt2594838 Jul 17, 2026
5f9f142
refactor ValueFilterApi
jt2594838 Jul 17, 2026
126f9eb
refactor generate
jt2594838 Jul 17, 2026
c34ecc8
refactor TsFileSequenceRead
jt2594838 Jul 17, 2026
597de8d
refactor ValueConverter
jt2594838 Jul 17, 2026
63f8763
refactor ValueConverter
jt2594838 Jul 17, 2026
5a078a8
refactor TSEncodingBuilder
jt2594838 Jul 17, 2026
4c80fa6
refactor StatisticsTest
jt2594838 Jul 17, 2026
c91071a
refactor StatisticsTest
jt2594838 Jul 17, 2026
25d9414
add write
jt2594838 Jul 17, 2026
6ff37f9
refactor BatchDataTest
jt2594838 Jul 17, 2026
bc87a50
refactor BatchDataTest
jt2594838 Jul 17, 2026
c1dd57b
refactor TsBlockFilterTest
jt2594838 Jul 17, 2026
b1aacf4
refactor PageReaderTest
jt2594838 Jul 17, 2026
b8a355f
refactor TsFileLastReaderTest
jt2594838 Jul 17, 2026
3664684
refactor TableViewTest
jt2594838 Jul 20, 2026
e750e7b
refactor TabletTest
jt2594838 Jul 20, 2026
7e8d5fe
refactor TypeCastTest
jt2594838 Jul 20, 2026
3fd8785
refactor RecordUtils
jt2594838 Jul 20, 2026
ff4843f
refactor castFromSingleValue
jt2594838 Jul 20, 2026
6938be3
refactor castFromArray
jt2594838 Jul 20, 2026
b36c4fe
refactor getDataTypeSize
jt2594838 Jul 20, 2026
b9033a7
refactor isNumeric
jt2594838 Jul 20, 2026
8ad7980
refactor public boolean isComparable() {
jt2594838 Jul 20, 2026
184a2c5
add update
jt2594838 Jul 21, 2026
96c7d4e
fix null binary conversion
jt2594838 Jul 21, 2026
c08c0af
add write
jt2594838 Jul 21, 2026
03cdf35
return serialized size
jt2594838 Jul 22, 2026
f685246
add TsPrimitiveType.copy
jt2594838 Jul 22, 2026
50fdec3
add Type.deserializeArray
jt2594838 Jul 22, 2026
5f65086
spotless
jt2594838 Jul 22, 2026
bab44db
add Column.writeTo
jt2594838 Jul 23, 2026
fc7cae4
add Type.write
jt2594838 Jul 23, 2026
cc0ba01
add Type.write
jt2594838 Jul 23, 2026
1eb9337
add Type.write
jt2594838 Jul 23, 2026
2f4ac13
add Type.write
jt2594838 Jul 23, 2026
6c8f242
add Type.write
jt2594838 Jul 29, 2026
59d0ae1
add Type.write
jt2594838 Jul 30, 2026
355fdf1
add Column.convertTo
jt2594838 Aug 12, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,9 @@
import org.apache.tsfile.utils.Binary;
import org.apache.tsfile.utils.TsPrimitiveType;

import java.io.DataOutputStream;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.util.Arrays;

public interface Column {
Expand All @@ -33,6 +36,9 @@ public interface Column {
/** Get the encoding for this column. */
ColumnEncoding getEncoding();

/** Converts this column to the specified data type. */
Column convertTo(TSDataType type);

/** Gets a boolean at {@code position}. */
default boolean getBoolean(int position) {
throw new UnsupportedOperationException(getClass().getName());
Expand Down Expand Up @@ -108,6 +114,33 @@ default TsPrimitiveType getTsPrimitiveType(int position) {
throw new UnsupportedOperationException(getClass().getName());
}

/** Serializes the value at {@code index} to {@code buffer}. */
default void writeTo(int index, ByteBuffer buffer) {
throw new UnsupportedOperationException(getClass().getName());
}

/** Serializes the value at {@code index} to {@code stream}. */
default void writeTo(int index, DataOutputStream stream) throws IOException {
throw new UnsupportedOperationException(getClass().getName());
}

/** Serializes all non-null values in this column. */
default void serializeWithoutNulls(DataOutputStream output) throws IOException {
throw new UnsupportedOperationException(getClass().getName());
}

/** Returns whether the values at the two positions are equal. */
default boolean arePositionsEqual(int pos1, int pos2) {
return arePositionsEqual(pos1, this, pos2);
}

/**
* Returns whether this value and the value in another column are equal.
*
* <p>For non-null values, this column and {@code that} must provide compatible value accessors.
*/
boolean arePositionsEqual(int thisPos, Column that, int thatPos);

/**
* Is it possible the column may have a null value? If false, the column cannot contain a null,
* but if true, the column may or may not have a null.
Expand Down
Loading
Loading