@Internal public final class ExternalSchemaTranslator extends Object
DataType
, Schema
, and projections when entering or
leaving the table ecosystem from and to other APIs where TypeInformation
is required.Modifier and Type | Class and Description |
---|---|
static class |
ExternalSchemaTranslator.InputResult
|
static class |
ExternalSchemaTranslator.OutputResult
|
Constructor and Description |
---|
ExternalSchemaTranslator() |
Modifier and Type | Method and Description |
---|---|
static ExternalSchemaTranslator.InputResult |
fromExternal(DataTypeFactory dataTypeFactory,
TypeInformation<?> inputTypeInfo,
Schema declaredSchema)
Converts the given
TypeInformation and an optional declared Schema (possibly
incomplete) into the final ExternalSchemaTranslator.InputResult . |
static ExternalSchemaTranslator.OutputResult |
fromInternal(DataTypeFactory dataTypeFactory,
ResolvedSchema inputSchema,
AbstractDataType<?> targetDataType)
Converts the given
DataType into the final ExternalSchemaTranslator.OutputResult . |
static ExternalSchemaTranslator.OutputResult |
fromInternal(ResolvedSchema inputSchema,
Schema declaredSchema)
Converts the given
DataType into the final ExternalSchemaTranslator.OutputResult . |
public static ExternalSchemaTranslator.OutputResult fromInternal(ResolvedSchema inputSchema, @Nullable Schema declaredSchema)
DataType
into the final ExternalSchemaTranslator.OutputResult
.
This method serves three types of use cases:
public static ExternalSchemaTranslator.OutputResult fromInternal(DataTypeFactory dataTypeFactory, ResolvedSchema inputSchema, AbstractDataType<?> targetDataType)
DataType
into the final ExternalSchemaTranslator.OutputResult
.
This method serves one type of use case:
public static ExternalSchemaTranslator.InputResult fromExternal(DataTypeFactory dataTypeFactory, TypeInformation<?> inputTypeInfo, @Nullable Schema declaredSchema)
TypeInformation
and an optional declared Schema
(possibly
incomplete) into the final ExternalSchemaTranslator.InputResult
.
This method serves three types of use cases:
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.