Package | Description |
---|---|
org.apache.flink.table.dataformat |
Modifier and Type | Interface and Description |
---|---|
interface |
BaseArray
An interface for array used internally in Flink Table/SQL.
|
interface |
BaseRow
An interface for row used internally in Flink Table/SQL.
|
Modifier and Type | Class and Description |
---|---|
class |
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.
|
class |
BinaryRow
A special row which is backed by
MemorySegment instead of Object. |
class |
BoxedWrapperRow
A
ObjectArrayRow that wrap primitive type to boxed object to reuse. |
class |
ColumnarRow
Columnar row to support access to vector column data.
|
class |
GenericArray
A GenericArray is an array where all the elements have the same type.
|
class |
GenericRow
A GenericRow can have arbitrary number of fields and contain a set of fields, which may all be
different types.
|
class |
JoinedRow
Join two row to one row.
|
class |
NestedRow
Its memory storage structure is exactly the same with
BinaryRow . |
class |
ObjectArrayRow
An row implementation that uses an array of objects as the underlying storage.
|
class |
UpdatableRow
Wrap row to a updatable Generic Row.
|
Modifier and Type | Method and Description |
---|---|
static Object |
TypeGetterSetters.get(TypeGetterSetters row,
int ordinal,
LogicalType type) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.