diff --git a/core/trino-spi/src/main/java/io/trino/spi/ptf/ConnectorTableFunction.java b/core/trino-spi/src/main/java/io/trino/spi/ptf/ConnectorTableFunction.java index e688f93801a4..fac48b61eef9 100644 --- a/core/trino-spi/src/main/java/io/trino/spi/ptf/ConnectorTableFunction.java +++ b/core/trino-spi/src/main/java/io/trino/spi/ptf/ConnectorTableFunction.java @@ -87,10 +87,7 @@ public ReturnTypeSpecification getReturnTypeSpecification() * * @param arguments actual invocation arguments, mapped by argument names */ - public TableFunctionAnalysis analyze(ConnectorSession session, ConnectorTransactionHandle transaction, Map arguments) - { - throw new UnsupportedOperationException("analyze method not implemented for Table Function " + name); - } + public abstract TableFunctionAnalysis analyze(ConnectorSession session, ConnectorTransactionHandle transaction, Map arguments); static String checkNotNullOrEmpty(String value, String name) {