com.gpudb.filesystem.upload

Class FullFileDispatcher

java.lang.Object

com.gpudb.filesystem.upload.FullFileDispatcher

public class FullFileDispatcher
extends Object

This is an internal class and not meant to be used by the end users of the filesystem API. The consequences of using this class directly in client code is not guaranteed and maybe undesirable. This class is used to handle batches of full file uploads using a threadpool of a certain configurable size. The default size for the thread pool is configured in the class GPUdbFileHandler.Options

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FullFileDispatcher.FullFileDownloadTask This class represents a task handling the upload of a bunch of full file uploads.
static class	FullFileDispatcher.FullFileUploadTask This class represents a task handling the upload of a bunch of full file uploads.

Constructor Summary

Constructors

Constructor and Description
FullFileDispatcher(GPUdbFileHandler.Options fileHandlerOptions, FileUploadListener callback)

Method Summary

Modifier and Type	Method and Description
void	collect() Wait for the tasks submitted to the thread pool and collect the results Result using the futures accessed using the jobExecutor object.
void	submit(FullFileDispatcher.FullFileUploadTask task) Submit an instance of FullFileDispatcher.FullFileUploadTask to the internal threadpool.
void	terminate() This method is called to terminate the threadpool once an instance of the class FullFileDispatcher has done its job.

Methods inherited from class java.lang.Object

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

Constructor Detail

FullFileDispatcher

public FullFileDispatcher(GPUdbFileHandler.Options fileHandlerOptions,
                          FileUploadListener callback)

Method Detail

submit

public void submit(FullFileDispatcher.FullFileUploadTask task)

Submit an instance of FullFileDispatcher.FullFileUploadTask to the internal threadpool.

Parameters:

task - a FullFileDispatcher.FullFileUploadTask object

collect

public void collect()
             throws GPUdbException

Wait for the tasks submitted to the thread pool and collect the results Result using the futures accessed using the jobExecutor object.

Throws:

GPUdbException

terminate

public void terminate()

This method is called to terminate the threadpool once an instance of the class FullFileDispatcher has done its job.