public interface StreamScan extends CommonScan<CRow>, DataStreamRel
Modifier and Type | Method and Description |
---|---|
DataStream<CRow> |
convertToInternalRow(RowSchema schema,
DataStream<Object> input,
FlinkTable<?> flinkTable,
TableConfig config) |
generatedConversionFunction, needsConversion
consumesRetractions, needsUpdatesAsRetraction, producesUpdates, 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
DataStream<CRow> convertToInternalRow(RowSchema schema, DataStream<Object> input, FlinkTable<?> flinkTable, TableConfig config)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.