Skip to content

Commit e437b16

Browse files
committed
Mark ConnectorPageSource.getNextPage() deprecated for removal
1 parent 7865b2d commit e437b16

File tree

5 files changed

+7
-0
lines changed

5 files changed

+7
-0
lines changed

core/trino-main/src/test/java/io/trino/connector/MockConnectorPageSource.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@ public boolean isFinished()
6161
}
6262

6363
@Override
64+
@SuppressWarnings("removal")
6465
public Page getNextPage()
6566
{
6667
return delegate.getNextPage();

core/trino-spi/src/main/java/io/trino/spi/connector/ConnectorPageSource.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,10 @@ default OptionalLong getCompletedPositions()
5555

5656
/**
5757
* Gets the next page of data. This method is allowed to return null.
58+
*
59+
* @deprecated Use {@link #getNextSourcePage()} instead
5860
*/
61+
@Deprecated(forRemoval = true)
5962
default Page getNextPage()
6063
{
6164
throw new UnsupportedOperationException();

core/trino-spi/src/main/java/io/trino/spi/connector/EmptyPageSource.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@ public boolean isFinished()
3737
}
3838

3939
@Override
40+
@SuppressWarnings("removal")
4041
public Page getNextPage()
4142
{
4243
return null;

core/trino-spi/src/main/java/io/trino/spi/connector/FixedPageSource.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,7 @@ public boolean isFinished()
7474
}
7575

7676
@Override
77+
@SuppressWarnings("removal")
7778
public Page getNextPage()
7879
{
7980
if (isFinished()) {

core/trino-spi/src/main/java/io/trino/spi/connector/RecordPageSource.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -81,6 +81,7 @@ public boolean isFinished()
8181
}
8282

8383
@Override
84+
@SuppressWarnings("removal")
8485
public Page getNextPage()
8586
{
8687
if (!closed) {

0 commit comments

Comments
 (0)