public interface BatchScan extends CommonScan<Row>, DataSetRel
Modifier and Type | Method and Description |
---|---|
DataSet<Row> |
convertToInternalRow(DataSet<Object> input,
FlinkTable<?> flinkTable,
TableConfig config) |
generatedConversionFunction, needsConversion
translateToPlan
estimateDataTypeSize, estimateRowSize, getExpressionString
accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, computeSelfCost, copy, estimateRowCount, explain, getChildExps, getCollationList, getConvention, getCorrelVariable, getExpectedInputRowType, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTable, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, replaceInput
DataSet<Row> convertToInternalRow(DataSet<Object> input, FlinkTable<?> flinkTable, TableConfig config)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.