diff --git a/presto-spi/src/main/java/io/prestosql/spi/connector/ConnectorPageSourceProvider.java b/presto-spi/src/main/java/io/prestosql/spi/connector/ConnectorPageSourceProvider.java index 7ff8e38753d0d..bd7f6390e4778 100644 --- a/presto-spi/src/main/java/io/prestosql/spi/connector/ConnectorPageSourceProvider.java +++ b/presto-spi/src/main/java/io/prestosql/spi/connector/ConnectorPageSourceProvider.java @@ -26,19 +26,6 @@ default ConnectorPageSource createPageSource( ConnectorSplit split, ConnectorTableHandle table, List columns) - { - return createPageSource(transaction, session, split, columns); - } - - /** - * @param columns columns that should show up in the output page, in this order - */ - @Deprecated - default ConnectorPageSource createPageSource( - ConnectorTransactionHandle transactionHandle, - ConnectorSession session, - ConnectorSplit split, - List columns) { throw new UnsupportedOperationException("createPageSource() must be implemented"); } diff --git a/presto-spi/src/main/java/io/prestosql/spi/connector/classloader/ClassLoaderSafeConnectorPageSourceProvider.java b/presto-spi/src/main/java/io/prestosql/spi/connector/classloader/ClassLoaderSafeConnectorPageSourceProvider.java index 4d93c1f9c9276..e25753b2fbcdc 100644 --- a/presto-spi/src/main/java/io/prestosql/spi/connector/classloader/ClassLoaderSafeConnectorPageSourceProvider.java +++ b/presto-spi/src/main/java/io/prestosql/spi/connector/classloader/ClassLoaderSafeConnectorPageSourceProvider.java @@ -38,14 +38,6 @@ public ClassLoaderSafeConnectorPageSourceProvider(ConnectorPageSourceProvider de this.classLoader = requireNonNull(classLoader, "classLoader is null"); } - @Override - public ConnectorPageSource createPageSource(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorSplit split, List columns) - { - try (ThreadContextClassLoader ignored = new ThreadContextClassLoader(classLoader)) { - return delegate.createPageSource(transactionHandle, session, split, columns); - } - } - @Override public ConnectorPageSource createPageSource(ConnectorTransactionHandle transaction, ConnectorSession session, ConnectorSplit split, ConnectorTableHandle table, List columns) {