Package io.deephaven.enterprise.dnd.uri

Class PQUriResolver

java.lang.Object

io.deephaven.enterprise.dnd.uri.PQUriResolver

All Implemented Interfaces:

UriResolver

@Singleton
public class PQUriResolver
extends Object
implements UriResolver

A UriResolver specifically for resolving requests for tables from persistent queries by serial or name.

Constructor Summary

Constructors

Constructor	Description
PQUriResolver(@NotNull BarrageSessionFactoryBuilder builder, @NotNull ScheduledExecutorService executor, @NotNull org.apache.arrow.memory.BufferAllocator allocator, @NotNull SSLConfig sslConfig, @NotNull ClientChannelFactory clientChannelFactory, @NotNull ControllerClientFactory controllerClientFactory)

Method Summary

Modifier and Type	Method	Description
boolean	isResolvable(URI uri)
Table	resolve(URI uri)
Set<String>	schemes()

Methods inherited from class java.lang.Object

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

Constructor Details

PQUriResolver

@Inject
public PQUriResolver(@NotNull
 @NotNull BarrageSessionFactoryBuilder builder,
 @NotNull
 @NotNull ScheduledExecutorService executor,
 @NotNull
 @NotNull org.apache.arrow.memory.BufferAllocator allocator,
 @NotNull @Named("uri.sslConfig")
 @NotNull SSLConfig sslConfig,
 @NotNull
 @NotNull ClientChannelFactory clientChannelFactory,
 @NotNull
 @NotNull ControllerClientFactory controllerClientFactory)

Method Details

schemes

public Set<String> schemes()

Specified by:

schemes in interface UriResolver

isResolvable

public boolean isResolvable(URI uri)

Specified by:

isResolvable in interface UriResolver

resolve

public Table resolve(URI uri)
              throws UncheckedDeephavenException

Specified by:

resolve in interface UriResolver

Throws:

UncheckedDeephavenException