public interface DataStreamRel extends FlinkRelNode
Modifier and Type | Method and Description |
---|---|
boolean |
consumesRetractions()
Whether the
DataStreamRel consumes retraction messages instead of forwarding them. |
boolean |
needsUpdatesAsRetraction()
Whether the
DataStreamRel requires that update and delete changes are sent with retraction
messages. |
boolean |
producesUpdates()
Whether the
DataStreamRel produces update and delete changes. |
DataStream<CRow> |
translateToPlan(StreamTableEnvironment tableEnv,
StreamQueryConfig queryConfig)
Translates the FlinkRelNode into a Flink operator.
|
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> translateToPlan(StreamTableEnvironment tableEnv, StreamQueryConfig queryConfig)
tableEnv
- The StreamTableEnvironment
of the translated Table.queryConfig
- The configuration for the query to generate.CRow
boolean needsUpdatesAsRetraction()
DataStreamRel
requires that update and delete changes are sent with retraction
messages.boolean producesUpdates()
DataStreamRel
produces update and delete changes.boolean consumesRetractions()
DataStreamRel
consumes retraction messages instead of forwarding them.
The node might or might not produce new retraction messages.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.