Class TableSourceQueryOperation<T>
- java.lang.Object
-
- org.apache.flink.table.operations.TableSourceQueryOperation<T>
-
- All Implemented Interfaces:
Operation
,QueryOperation
- Direct Known Subclasses:
RichTableSourceQueryOperation
@Internal public class TableSourceQueryOperation<T> extends Object implements QueryOperation
Inline scan of aTableSource
. Used only when aTable
was created fromorg.apache.flink.table.api.TableEnvironment#fromTableSource(TableSource)
.
-
-
Constructor Summary
Constructors Constructor Description TableSourceQueryOperation(TableSource<T> tableSource, boolean isBatch)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <R> R
accept(QueryOperationVisitor<R> visitor)
String
asSummaryString()
Returns a string that summarizes this operation for printing to a console.List<QueryOperation>
getChildren()
ResolvedSchema
getResolvedSchema()
Resolved schema of this operation.TableSource<T>
getTableSource()
boolean
isBatch()
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.table.operations.QueryOperation
asSerializableString
-
-
-
-
Constructor Detail
-
TableSourceQueryOperation
public TableSourceQueryOperation(TableSource<T> tableSource, boolean isBatch)
-
-
Method Detail
-
getResolvedSchema
public ResolvedSchema getResolvedSchema()
Description copied from interface:QueryOperation
Resolved schema of this operation.- Specified by:
getResolvedSchema
in interfaceQueryOperation
-
asSummaryString
public String asSummaryString()
Description copied from interface:Operation
Returns a string that summarizes this operation for printing to a console. An implementation might skip very specific properties.- Specified by:
asSummaryString
in interfaceOperation
- Returns:
- summary string of this operation for debugging purposes
-
getTableSource
public TableSource<T> getTableSource()
-
isBatch
public boolean isBatch()
-
getChildren
public List<QueryOperation> getChildren()
- Specified by:
getChildren
in interfaceQueryOperation
-
accept
public <R> R accept(QueryOperationVisitor<R> visitor)
- Specified by:
accept
in interfaceQueryOperation
-
-