com.facebook.presto.spi.classloader

Class ClassLoaderSafeConnectorPageSink

java.lang.Object

com.facebook.presto.spi.classloader.ClassLoaderSafeConnectorPageSink

All Implemented Interfaces:

ConnectorPageSink

public class ClassLoaderSafeConnectorPageSink
extends Object
implements ConnectorPageSink

Field Summary

Fields inherited from interface com.facebook.presto.spi.ConnectorPageSink

NOT_BLOCKED

Constructor Summary

Constructors

Constructor and Description
ClassLoaderSafeConnectorPageSink(ConnectorPageSink delegate, ClassLoader classLoader)

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClassLoaderSafeConnectorPageSink

public ClassLoaderSafeConnectorPageSink(ConnectorPageSink delegate,
                                        ClassLoader classLoader)

Method Detail

appendPage

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

Description copied from interface: ConnectorPageSink

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.

Specified by:

appendPage in interface ConnectorPageSink

finish

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

Specified by:

finish in interface ConnectorPageSink

abort

public void abort()

Specified by:

abort in interface ConnectorPageSink