@@ -223,48 +223,48 @@ The table below provides a quick reference for converting data types when insert
223223
224224[ // ] : # ( TODO: add a "Flink SQL Type" column once table api support is added )
225225
226- | Java Type | ClickHouse Type | Supported | Serialize Method |
227- | -----------------| -----------------| -----------| -----------------------------|
228- | byte/ Byte | Int8 | ✅ | DataWriter.writeInt8 |
229- | short/ Short | Int16 | ✅ | DataWriter.writeInt16 |
230- | int/ Integer | Int32 | ✅ | DataWriter.writeInt32 |
231- | long/ Long | Int64 | ✅ | DataWriter.writeInt64 |
232- | BigInteger | Int128 | ✅ | DataWriter.writeInt124 |
233- | BigInteger | Int256 | ✅ | DataWriter.writeInt256 |
234- | short/ Short | UInt8 | ✅ | DataWriter.writeUInt8 |
235- | int/ Integer | UInt8 | ✅ | DataWriter.writeUInt8 |
236- | int/ Integer | UInt16 | ✅ | DataWriter.writeUInt16 |
237- | long/ Long | UInt32 | ✅ | DataWriter.writeUInt32 |
238- | long/ Long | UInt64 | ✅ | DataWriter.writeUInt64 |
239- | BigInteger | UInt64 | ✅ | DataWriter.writeUInt64 |
240- | BigInteger | UInt128 | ✅ | DataWriter.writeUInt128 |
241- | BigInteger | UInt256 | ✅ | DataWriter.writeUInt256 |
242- | BigDecimal | Decimal | ✅ | DataWriter.writeDecimal |
243- | BigDecimal | Decimal32 | ✅ | DataWriter.writeDecimal |
244- | BigDecimal | Decimal64 | ✅ | DataWriter.writeDecimal |
245- | BigDecimal | Decimal128 | ✅ | DataWriter.writeDecimal |
246- | BigDecimal | Decimal256 | ✅ | DataWriter.writeDecimal |
247- | float/ Float | Float | ✅ | DataWriter.writeFloat32 |
248- | double/ Double | Double | ✅ | DataWriter.writeFloat64 |
249- | boolean/ Boolean | Boolean | ✅ | DataWriter.writeBoolean |
250- | String | String | ✅ | DataWriter.writeString |
251- | String | FixedString | ✅ | DataWriter.writeFixedString |
252- | LocalDate | Date | ✅ | DataWriter.writeDate |
253- | LocalDate | Date32 | ✅ | DataWriter.writeDate32 |
254- | LocalDateTime | DateTime | ✅ | DataWriter.writeDateTime |
255- | ZonedDateTime | DateTime | ✅ | DataWriter.writeDateTime |
256- | LocalDateTime | DateTime64 | ✅ | DataWriter.writeDateTime64 |
257- | ZonedDateTime | DateTime64 | ✅ | DataWriter.writeDateTime64 |
258- | int/ Integer | Time | ❌ | N/A |
259- | long/ Long | Time64 | ❌ | N/A |
260- | byte/ Byte | Enum8 | ✅ | DataWriter.writeInt8 |
261- | int/ Integer | Enum16 | ✅ | DataWriter.writeInt16 |
262- | java.util.UUID | UUID | ✅ | DataWriter.writeIntUUID |
263- | String | JSON | ✅ | DataWriter.writeJSON |
264- | Array<Type > | Array<Type > | ✅ | DataWriter.writeArray |
265- | Map<K,V> | Map<K,V> | ✅ | DataWriter.writeMap |
266- | Tuple<Type,..> | Tuple<T1,T2,..> | ✅ | DataWriter.writeTuple |
267- | Object | Variant | ❌ | N/A |
226+ | Java Type | ClickHouse Type | Supported | Serialize Method |
227+ | --------------------- | ------------------- | -----------| -- -----------------------------|
228+ | ` byte ` / ` Byte ` | ` Int8 ` | ✅ | ` DataWriter.writeInt8 ` |
229+ | ` short ` / ` Short ` | ` Int16 ` | ✅ | ` DataWriter.writeInt16 ` |
230+ | ` int ` / ` Integer ` | ` Int32 ` | ✅ | ` DataWriter.writeInt32 ` |
231+ | ` long ` / ` Long ` | ` Int64 ` | ✅ | ` DataWriter.writeInt64 ` |
232+ | ` BigInteger ` | ` Int128 ` | ✅ | ` DataWriter.writeInt124 ` |
233+ | ` BigInteger ` | ` Int256 ` | ✅ | ` DataWriter.writeInt256 ` |
234+ | ` short ` / ` Short ` | ` UInt8 ` | ✅ | ` DataWriter.writeUInt8 ` |
235+ | ` int ` / ` Integer ` | ` UInt8 ` | ✅ | ` DataWriter.writeUInt8 ` |
236+ | ` int ` / ` Integer ` | ` UInt16 ` | ✅ | ` DataWriter.writeUInt16 ` |
237+ | ` long ` / ` Long ` | ` UInt32 ` | ✅ | ` DataWriter.writeUInt32 ` |
238+ | ` long ` / ` Long ` | ` UInt64 ` | ✅ | ` DataWriter.writeUInt64 ` |
239+ | ` BigInteger ` | ` UInt64 ` | ✅ | ` DataWriter.writeUInt64 ` |
240+ | ` BigInteger ` | ` UInt128 ` | ✅ | ` DataWriter.writeUInt128 ` |
241+ | ` BigInteger ` | ` UInt256 ` | ✅ | ` DataWriter.writeUInt256 ` |
242+ | ` BigDecimal ` | ` Decimal ` | ✅ | ` DataWriter.writeDecimal ` |
243+ | ` BigDecimal ` | ` Decimal32 ` | ✅ | ` DataWriter.writeDecimal ` |
244+ | ` BigDecimal ` | ` Decimal64 ` | ✅ | ` DataWriter.writeDecimal ` |
245+ | ` BigDecimal ` | ` Decimal128 ` | ✅ | ` DataWriter.writeDecimal ` |
246+ | ` BigDecimal ` | ` Decimal256 ` | ✅ | ` DataWriter.writeDecimal ` |
247+ | ` float ` / ` Float ` | ` Float ` | ✅ | ` DataWriter.writeFloat32 ` |
248+ | ` double ` / ` Double ` | ` Double ` | ✅ | ` DataWriter.writeFloat64 ` |
249+ | ` boolean ` / ` Boolean ` | ` Boolean ` | ✅ | ` DataWriter.writeBoolean ` |
250+ | ` String ` | ` String ` | ✅ | ` DataWriter.writeString ` |
251+ | ` String ` | ` FixedString ` | ✅ | ` DataWriter.writeFixedString ` |
252+ | ` LocalDate ` | ` Date ` | ✅ | ` DataWriter.writeDate ` |
253+ | ` LocalDate ` | ` Date32 ` | ✅ | ` DataWriter.writeDate32 ` |
254+ | ` LocalDateTime ` | ` DateTime ` | ✅ | ` DataWriter.writeDateTime ` |
255+ | ` ZonedDateTime ` | ` DateTime ` | ✅ | ` DataWriter.writeDateTime ` |
256+ | ` LocalDateTime ` | ` DateTime64 ` | ✅ | ` DataWriter.writeDateTime64 ` |
257+ | ` ZonedDateTime ` | ` DateTime64 ` | ✅ | ` DataWriter.writeDateTime64 ` |
258+ | ` int ` / ` Integer ` | ` Time ` | ❌ | N/A |
259+ | ` long ` / ` Long ` | ` Time64 ` | ❌ | N/A |
260+ | ` byte ` / ` Byte ` | ` Enum8 ` | ✅ | ` DataWriter.writeInt8 ` |
261+ | ` int ` / ` Integer ` | ` Enum16 ` | ✅ | ` DataWriter.writeInt16 ` |
262+ | ` java.util.UUID ` | ` UUID ` | ✅ | ` DataWriter.writeIntUUID ` |
263+ | ` String ` | ` JSON ` | ✅ | ` DataWriter.writeJSON ` |
264+ | ` Array<Type> ` | ` Array<Type> ` | ✅ | ` DataWriter.writeArray ` |
265+ | ` Map<K,V> ` | ` Map<K,V> ` | ✅ | ` DataWriter.writeMap ` |
266+ | ` Tuple<Type,..> ` | ` Tuple<T1,T2,..> ` | ✅ | ` DataWriter.writeTuple ` |
267+ | ` Object ` | ` Variant ` | ❌ | N/A |
268268
269269Notes:
270270* A ` ZoneId ` must be provided when performing date operations.
0 commit comments