public interface CommonScan<T>
Modifier and Type | Method and Description |
---|---|
<F extends Function> |
generatedConversionFunction(TableConfig config,
Class<F> functionClass,
TypeInformation<Object> inputType,
TypeInformation<Row> expectedType,
String conversionOperatorName,
scala.collection.Seq<String> fieldNames,
scala.Option<int[]> inputFieldMapping) |
boolean |
needsConversion(TypeInformation<Object> externalTypeInfo,
TypeInformation<T> internalTypeInfo)
We check if the input type is exactly the same as the internal row type.
|
boolean needsConversion(TypeInformation<Object> externalTypeInfo, TypeInformation<T> internalTypeInfo)
externalTypeInfo
- (undocumented)internalTypeInfo
- (undocumented)<F extends Function> GeneratedFunction<F,Row> generatedConversionFunction(TableConfig config, Class<F> functionClass, TypeInformation<Object> inputType, TypeInformation<Row> expectedType, String conversionOperatorName, scala.collection.Seq<String> fieldNames, scala.Option<int[]> inputFieldMapping)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.