Class and Description |
---|
AbstractBinaryWriter
Use the special format to write data to a
MemorySegment (its capacity grows
automatically). |
BaseArray
An interface for array used internally in Flink Table/SQL.
|
BaseMap
An interface for map used internally in Flink Table/SQL.
|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
BinaryArray
For fields that hold fixed-length primitive types, such as long, double, or int, we store the
value directly in the field, just like the original java array.
|
BinaryFormat
Binary format spanning
MemorySegment s. |
BinaryGeneric
Internal format to generic.
|
BinaryMap
[4 byte(keyArray size in bytes)] + [Key BinaryArray] + [Value BinaryArray].
|
BinaryRow
A special row which is backed by
MemorySegment instead of Object. |
BinarySection
Binary section of memory.
|
BinaryString
A utf8 string which is backed by
MemorySegment instead of String. |
BinaryWriter
Writer to write a composite data format, like row, array.
|
DataFormatConverters.AbstractBaseRowConverter
Abstract converter for internal base row.
|
DataFormatConverters.BinaryArrayConverter
Converter for BinaryArray.
|
DataFormatConverters.BinaryGenericConverter
Converter for BinaryGeneric.
|
DataFormatConverters.BinaryMapConverter
Converter for BinaryMap.
|
DataFormatConverters.BinaryStringConverter
Converter for BinaryString.
|
DataFormatConverters.BooleanConverter
Converter for boolean.
|
DataFormatConverters.ByteConverter
Converter for byte.
|
DataFormatConverters.DataFormatConverter
Converter between internal data format and java format.
|
DataFormatConverters.DateConverter
Converter for date.
|
DataFormatConverters.DoubleConverter
Converter for double.
|
DataFormatConverters.FloatConverter
Converter for float.
|
DataFormatConverters.IdentityConverter
Identity converter.
|
DataFormatConverters.InstantConverter
Converter for Instant.
|
DataFormatConverters.IntConverter
Converter for int.
|
DataFormatConverters.LocalDateConverter
Converter for LocalDate.
|
DataFormatConverters.LocalDateTimeConverter
Converter for LocalDateTime.
|
DataFormatConverters.LocalTimeConverter
Converter for LocalTime.
|
DataFormatConverters.LongConverter
Converter for long.
|
DataFormatConverters.PrimitiveBooleanArrayConverter
Converter for primitive boolean array.
|
DataFormatConverters.PrimitiveByteArrayConverter
Converter for primitive byte array.
|
DataFormatConverters.PrimitiveDoubleArrayConverter
Converter for primitive double array.
|
DataFormatConverters.PrimitiveFloatArrayConverter
Converter for primitive float array.
|
DataFormatConverters.PrimitiveIntArrayConverter
Converter for primitive int array.
|
DataFormatConverters.PrimitiveLongArrayConverter
Converter for primitive long array.
|
DataFormatConverters.PrimitiveShortArrayConverter
Converter for primitive short array.
|
DataFormatConverters.ShortConverter
Converter for short.
|
DataFormatConverters.StringConverter
Converter for String.
|
DataFormatConverters.TimeConverter
Converter for time.
|
DataFormatConverters.TimestampConverter
Converter for timestamp.
|
Decimal
Sql Decimal value.
|
GenericRow
A GenericRow can have arbitrary number of fields and contain a set of fields, which may all be
different types.
|
JoinedRow
Join two row to one row.
|
LazyBinaryFormat
Lazy binary format.
|
NestedRow
Its memory storage structure is exactly the same with
BinaryRow . |
ObjectArrayRow
An row implementation that uses an array of objects as the underlying storage.
|
TypeGetterSetters
Provide type specialized getters and setters to reduce if/else and eliminate box and unbox.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
BinaryRow
A special row which is backed by
MemorySegment instead of Object. |
GenericRow
A GenericRow can have arbitrary number of fields and contain a set of fields, which may all be
different types.
|
Class and Description |
---|
Decimal
Sql Decimal value.
|
Class and Description |
---|
BinaryString
A utf8 string which is backed by
MemorySegment instead of String. |
Decimal
Sql Decimal value.
|
GenericRow
A GenericRow can have arbitrary number of fields and contain a set of fields, which may all be
different types.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
Class and Description |
---|
BinaryString
A utf8 string which is backed by
MemorySegment instead of String. |
Decimal
Sql Decimal value.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
BinaryRow
A special row which is backed by
MemorySegment instead of Object. |
Class and Description |
---|
BinaryRow
A special row which is backed by
MemorySegment instead of Object. |
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
BinaryRow
A special row which is backed by
MemorySegment instead of Object. |
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
BinaryRow
A special row which is backed by
MemorySegment instead of Object. |
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
JoinedRow
Join two row to one row.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
BinaryRow
A special row which is backed by
MemorySegment instead of Object. |
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
BinaryRow
A special row which is backed by
MemorySegment instead of Object. |
BinaryString
A utf8 string which is backed by
MemorySegment instead of String. |
Decimal
Sql Decimal value.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
Class and Description |
---|
BinaryRow
A special row which is backed by
MemorySegment instead of Object. |
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
Class and Description |
---|
BaseArray
An interface for array used internally in Flink Table/SQL.
|
BaseMap
An interface for map used internally in Flink Table/SQL.
|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
BinaryArray
For fields that hold fixed-length primitive types, such as long, double, or int, we store the
value directly in the field, just like the original java array.
|
BinaryGeneric
Internal format to generic.
|
BinaryMap
[4 byte(keyArray size in bytes)] + [Key BinaryArray] + [Value BinaryArray].
|
BinaryRow
A special row which is backed by
MemorySegment instead of Object. |
BinaryString
A utf8 string which is backed by
MemorySegment instead of String. |
Decimal
Sql Decimal value.
|
Class and Description |
---|
BaseRow
An interface for row used internally in Flink Table/SQL.
|
BinaryRow
A special row which is backed by
MemorySegment instead of Object. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.