Toggle navigation
Home
org.apache.flink.table.type.InternalType to org.apache.flink.table.types.logical.LogicalType
No. of Instances - 131
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Add or Remove Method invocation
typeFactory.createTypeFromInternalType(type,true)
to
typeFactory.createFieldTypeFromLogicalType(type)
rowLength(new RowType(valueTypes))
to
rowLength(RowType.of(valueTypes))
rowLength(new RowType(keyTypes))
to
rowLength(RowType.of(keyTypes))
rowLength(new RowType(valueTypes))
to
rowLength(RowType.of(valueTypes))
rowLength(new RowType(keyTypes))
to
rowLength(RowType.of(keyTypes))
rowLength(new RowType(valueTypes))
to
rowLength(RowType.of(valueTypes))
rowLength(new RowType(keyTypes))
to
rowLength(RowType.of(keyTypes))
rowLength(new RowType(valueTypes))
to
rowLength(RowType.of(valueTypes))
rowLength(new RowType(keyTypes))
to
rowLength(RowType.of(keyTypes))
rowLength(new RowType(valueTypes))
to
rowLength(RowType.of(valueTypes))
rowLength(new RowType(keyTypes))
to
rowLength(RowType.of(keyTypes))
rowType.getTypeAt(0)
to
rowType.getFields().get(0)
MUTABLE_FIELD_TYPES.contains(type)
to
isInFixedLengthPart(type)
RowType.generateDefaultFieldNames(internalTypes.length)
to
generateDefaultFieldNames(logicalTypes.length)
rowType.getTypeAt(0)
to
rowType.getFields().get(0)
typeFactory.createTypeFromInternalType(type,true)
to
typeFactory.createFieldTypeFromLogicalType(type)
Arrays.stream(types).map(TypeConverters::createInternalTypeInfoFromInternalType).map(ti -> ti.createSerializer(config)).toArray(TypeSerializer[]::new)
to
Arrays.stream(types).map((LogicalType type) -> InternalSerializers.create(type,config)).toArray(TypeSerializer[]::new)
RowType.generateDefaultFieldNames(internalTypes.length)
to
generateDefaultFieldNames(logicalTypes.length)
rowLength(new RowType(valueTypes))
to
rowLength(RowType.of(valueTypes))
rowLength(new RowType(keyTypes))
to
rowLength(RowType.of(keyTypes))
rowLength(new RowType(valueTypes))
to
rowLength(RowType.of(valueTypes))
rowLength(new RowType(keyTypes))
to
rowLength(RowType.of(keyTypes))
rowLength(new RowType(valueTypes))
to
rowLength(RowType.of(valueTypes))
rowLength(new RowType(keyTypes))
to
rowLength(RowType.of(keyTypes))
rowLength(new RowType(valueTypes))
to
rowLength(RowType.of(valueTypes))
rowLength(new RowType(keyTypes))
to
rowLength(RowType.of(keyTypes))
rowLength(new RowType(valueTypes))
to
rowLength(RowType.of(valueTypes))
rowLength(new RowType(keyTypes))
to
rowLength(RowType.of(keyTypes))
Cascading Type Change (Similar)
InternalType
to
LogicalType
InternalType
to
LogicalType
Rename Variable
getInternalTypes
to
getLogicalTypes
internalTypes
to
logicalTypes
internalTypes
to
logicalTypes
internalTypes
to
logicalTypes
internalTypes
to
logicalTypes
internalTypes
to
logicalTypes
internalTypes
to
logicalTypes
internalTypes
to
logicalTypes
internalTypes
to
logicalTypes
internalTypes
to
logicalTypes