Package | Description |
---|---|
org.apache.flink.table.api |
Modifier and Type | Method and Description |
---|---|
static TableException |
TableException.apply(String msg) |
TableException |
TableException$.apply(String msg) |
Modifier and Type | Method and Description |
---|---|
protected void |
TableEnvironment.registerTableInternal(String name,
org.apache.calcite.schema.impl.AbstractTable table)
Registers a Calcite
AbstractTable in the TableEnvironment's catalog. |
Table |
TableEnvironment.scan(scala.collection.Seq<String> tablePath)
Scans a registered table and returns the resulting
Table . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.