Package org.apache.pinot.common.utils.fetcher

Class SegmentFetcherFactory

java.lang.Object

org.apache.pinot.common.utils.fetcher.SegmentFetcherFactory

public class SegmentFetcherFactory
extends Object

Method Summary

Modifier and Type	Method	Description
static void	fetchAndDecryptSegmentToLocal(String uri, File dest, String crypterName)	Fetches a segment from a URI location to a local file and decrypts it if needed
static void	fetchSegmentToLocal(String uri, File dest)	Fetches a segment from URI location to local.
static void	fetchSegmentToLocal(URI uri, File dest)	Fetches a segment from URI location to local.
static SegmentFetcherFactory	getInstance()
static SegmentFetcher	getSegmentFetcher(String protocol)	Returns the segment fetcher associated with the given protocol, or the default segment fetcher (HttpSegmentFetcher for "http" and "https", PinotFSSegmentFetcher for other protocols).
static void	init(PinotConfiguration config)	Initializes the segment fetcher factory.

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static SegmentFetcherFactory getInstance()

init

public static void init(PinotConfiguration config)
                 throws Exception

Initializes the segment fetcher factory. This method should only be called once.

Throws:

Exception

getSegmentFetcher

public static SegmentFetcher getSegmentFetcher(String protocol)

Returns the segment fetcher associated with the given protocol, or the default segment fetcher (HttpSegmentFetcher for "http" and "https", PinotFSSegmentFetcher for other protocols).

fetchSegmentToLocal

public static void fetchSegmentToLocal(URI uri,
                                       File dest)
                                throws Exception

Fetches a segment from URI location to local.

Throws:

Exception

fetchSegmentToLocal

public static void fetchSegmentToLocal(String uri,
                                       File dest)
                                throws Exception

Fetches a segment from URI location to local.

Throws:

Exception

fetchAndDecryptSegmentToLocal

public static void fetchAndDecryptSegmentToLocal(String uri,
                                                 File dest,
                                                 String crypterName)
                                          throws Exception

Fetches a segment from a URI location to a local file and decrypts it if needed

Parameters:

uri - remote segment location

dest - local file

Throws:

Exception