Package org.apache.tika.pipes.fetcher.gcs

Class GCSFetcher

java.lang.Object

org.apache.tika.pipes.fetcher.AbstractFetcher

org.apache.tika.pipes.fetcher.gcs.GCSFetcher

All Implemented Interfaces:

Initializable, Fetcher

public class GCSFetcher
extends AbstractFetcher
implements Initializable

Fetches files from google cloud storage. Must set projectId and bucket via the config.

Constructor Summary

Constructors

Constructor	Description
GCSFetcher()

Method Summary

Modifier and Type	Method	Description
void	checkInitialization(InitializableProblemHandler problemHandler)
InputStream	fetch(String fetchKey, Metadata metadata)
void	initialize(Map<String,Param> params)	This initializes the gcs storage client.
void	setBucket(String bucket)
void	setExtractUserMetadata(boolean extractUserMetadata)	Whether or not to extract user metadata from the S3Object
void	setProjectId(String projectId)
void	setSpoolToTemp(boolean spoolToTemp)

Methods inherited from class org.apache.tika.pipes.fetcher.AbstractFetcher

getName, setName

Methods inherited from class java.lang.Object

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

Constructor Details

GCSFetcher

public GCSFetcher()

Method Details

fetch

public InputStream fetch(String fetchKey,
 Metadata metadata)
                  throws TikaException,
IOException

Specified by:

fetch in interface Fetcher

Throws:

TikaException

IOException

setSpoolToTemp

@Field
public void setSpoolToTemp(boolean spoolToTemp)

setProjectId

@Field
public void setProjectId(String projectId)

setBucket

@Field
public void setBucket(String bucket)

setExtractUserMetadata

@Field
public void setExtractUserMetadata(boolean extractUserMetadata)

Whether or not to extract user metadata from the S3Object

Parameters:

extractUserMetadata -

initialize

public void initialize(Map<String,Param> params)
                throws TikaConfigException

This initializes the gcs storage client.

Specified by:

initialize in interface Initializable

Parameters:

params - params to use for initialization

Throws:

TikaConfigException

checkInitialization

public void checkInitialization(InitializableProblemHandler problemHandler)
                         throws TikaConfigException

Specified by:

checkInitialization in interface Initializable

Parameters:

problemHandler - if there is a problem and no custom initializableProblemHandler has been configured via Initializable parameters, this is called to respond.

Throws:

TikaConfigException