com.facebook.presto.spi

Interface ConnectorPageSink

All Known Implementing Classes:

ClassLoaderSafeConnectorPageSink, RecordPageSink

public interface ConnectorPageSink

Field Summary

Fields

Modifier and Type	Field and Description
static CompletableFuture<?>	NOT_BLOCKED

Method Summary

Modifier and Type	Method and Description
void	abort()
CompletableFuture<?>	appendPage(Page page, Block sampleWeightBlock) Returns a future that will be completed when the page sink can accept more pages.
Collection<io.airlift.slice.Slice>	finish()

Field Detail

NOT_BLOCKED

static final CompletableFuture<?> NOT_BLOCKED

Method Detail

appendPage

CompletableFuture<?> appendPage(Page page,
                                Block sampleWeightBlock)

Returns a future that will be completed when the page sink can accept more pages. If the page sink can accept more pages immediately, this method should return NOT_BLOCKED.

finish

Collection<io.airlift.slice.Slice> finish()

abort

void abort()