@@ -3,26 +3,34 @@ package org.apache.flinkx.api
33import org .apache .flink .api .common .serialization .{SerializerConfig , SerializerConfigImpl }
44import org .apache .flink .api .common .typeinfo .{BasicTypeInfo , LocalTimeTypeInfo , TypeInformation }
55import org .apache .flink .api .common .typeutils .TypeSerializer
6+ import org .apache .flink .api .common .typeutils .base .{
7+ BooleanSerializer ,
8+ ByteSerializer ,
9+ CharSerializer ,
10+ DoubleSerializer ,
11+ FloatSerializer ,
12+ IntSerializer ,
13+ LongSerializer ,
14+ ShortSerializer
15+ }
616import org .apache .flink .api .common .typeutils .base .array ._
7- import org .apache .flink .api .common .typeutils .base .{ListSerializer , MapSerializer , _ }
817import org .apache .flink .api .java .typeutils .EnumTypeInfo
918import org .apache .flink .types .{Nothing => FlinkNothing }
1019import org .apache .flinkx .api .mapper .{BigDecMapper , BigIntMapper , UuidMapper }
1120import org .apache .flinkx .api .serializer .MappedSerializer .TypeMapper
1221import org .apache .flinkx .api .serializer ._
1322import org .apache .flinkx .api .typeinfo ._
1423
15- import java .lang .{
16- Boolean => JBoolean ,
17- Byte => JByte ,
18- Character => JCharacter ,
19- Double => JDouble ,
20- Float => JFloat ,
21- Integer => JInteger ,
22- Long => JLong ,
23- Short => JShort
24- }
25- import java .math .{BigDecimal => JBigDecimal , BigInteger => JBigInteger }
24+ import java .lang .{Float => JFloat }
25+ import java .lang .{Long => JLong }
26+ import java .lang .{Double => JDouble }
27+ import java .lang .{Short => JShort }
28+ import java .lang .{Byte => JByte }
29+ import java .lang .{Boolean => JBoolean }
30+ import java .lang .{Integer => JInteger }
31+ import java .lang .{Character => JCharacter }
32+ import java .math .{BigInteger => JBigInteger }
33+ import java .math .{BigDecimal => JBigDecimal }
2634import java .time ._
2735import java .util .UUID
2836import scala .collection .immutable .{SortedSet , TreeSet }
@@ -107,12 +115,9 @@ trait serializers extends LowPrioImplicits {
107115 implicit lazy val finiteDurationInfo : TypeInformation [FiniteDuration ] = SimpleTypeInfo (2 , 2 , keyType = true )
108116 implicit lazy val flinkNothingInfo : TypeInformation [FlinkNothing ] =
109117 SimpleTypeInfo (0 )(classTag[FlinkNothing ], new NothingSerializer ().asInstanceOf [TypeSerializer [FlinkNothing ]])
110- implicit lazy val scalaNothingInfo : TypeInformation [scala. Nothing ] =
118+ implicit lazy val scalaNothingInfo : TypeInformation [Nothing ] =
111119 // At runtime scala.Nothing is scala.runtime.Nothing$ and extends Throwable
112- SimpleTypeInfo [scala.Nothing ](6 , 11 )(
113- classTag[scala.Nothing ],
114- new NothingSerializer ().asInstanceOf [TypeSerializer [scala.Nothing ]]
115- )
120+ SimpleTypeInfo [Nothing ](6 , 11 )(classTag[Nothing ], new NothingSerializer ().asInstanceOf [TypeSerializer [Nothing ]])
116121 implicit lazy val timeUnitInfo : TypeInformation [TimeUnit ] = new EnumTypeInfo (classOf [TimeUnit ])
117122 implicit lazy val uuidMapper : TypeMapper [UUID , Array [Byte ]] = new UuidMapper ()
118123 implicit lazy val uuidInfo : TypeInformation [UUID ] = mappedTypeInfo[UUID , Array [Byte ]]
0 commit comments