Package com.gpudb.filesystem.ingest

Class FileIngestor

java.lang.Object

com.gpudb.filesystem.ingest.FileIngestor

public class FileIngestor
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 uses FileUploader class to upload files to server and then uses insertRecordsFromFile method to ingest the uploaded file.

Constructor Summary

Constructors

Constructor	Description
FileIngestor(GPUdb db, String tableName, List<String> fileNames, IngestOptions ingestOptions, TableCreationOptions createTableOptions)

Method Summary

Modifier and Type	Method	Description
TableCreationOptions	getCreateTableOptions()
IngestOptions	getIngestOptions()
IngestResult	ingestFromFiles()	This method uploads the files using the fileUploader object and calls the method GPUdb.insertRecordsFromFiles(String, List, Map, Map, Map) to ingest from the uploaded files.
void	setCreateTableOptions(TableCreationOptions createTableOptions)
void	setIngestOptions(IngestOptions ingestOptions)

Methods inherited from class java.lang.Object

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

Constructor Detail

FileIngestor

public FileIngestor(GPUdb db,
                    String tableName,
                    List<String> fileNames,
                    IngestOptions ingestOptions,
                    TableCreationOptions createTableOptions)

Method Detail

getIngestOptions

public IngestOptions getIngestOptions()

setIngestOptions

public void setIngestOptions(IngestOptions ingestOptions)

getCreateTableOptions

public TableCreationOptions getCreateTableOptions()

setCreateTableOptions

public void setCreateTableOptions(TableCreationOptions createTableOptions)

ingestFromFiles

public IngestResult ingestFromFiles()

This method uploads the files using the fileUploader object and calls the method GPUdb.insertRecordsFromFiles(String, List, Map, Map, Map) to ingest from the uploaded files. The files are uploaded to the location identified by 'kifs://~/' where '~' indicates the user's home directory on the server and ingested there from.

Returns:

An IngestResult object