Class AZBlobEmitter

java.lang.Object

org.apache.tika.plugins.AbstractTikaExtension

org.apache.tika.pipes.api.emitter.AbstractStreamEmitter

org.apache.tika.pipes.emitter.azblob.AZBlobEmitter

All Implemented Interfaces:

Emitter, StreamEmitter, TikaExtension

public class AZBlobEmitter
extends AbstractStreamEmitter
implements StreamEmitter

Emitter to write files to Azure Blob Storage.

Example JSON configuration:

{
  "emitters": {
    "az-blob-emitter": {
      "my-azure": {
        "endpoint": "https://myaccount.blob.core.windows.net",
        "sasToken": "sv=2020-08-04&ss=b...",
        "container": "my-container",
        "prefix": "output",
        "fileExtension": "json",
        "overwriteExisting": false
      }
    }
  }
}

Field Summary

Fields inherited from class AbstractTikaExtension

pluginConfig

Method Summary

Modifier and Type	Method	Description
static AZBlobEmitter	build(ExtensionConfig extensionConfig)
void	emit(String emitKey, InputStream inputStream, Metadata userMetadata, ParseContext parseContext)
void	emit(String emitKey, List<Metadata> metadataList, ParseContext parseContext)

Methods inherited from class AbstractStreamEmitter

emit

Methods inherited from class AbstractTikaExtension

getExtensionConfig

Methods inherited from class Object

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

Methods inherited from interface Emitter

emit

Methods inherited from interface TikaExtension

getExtensionConfig

Method Details

build

public static AZBlobEmitter build(ExtensionConfig extensionConfig)
                           throws TikaConfigException,
IOException

Throws:

TikaConfigException

IOException

emit

public void emit(String emitKey,
 List<Metadata> metadataList,
 ParseContext parseContext)
          throws IOException

Specified by:

emit in interface Emitter

Throws:

IOException

emit

public void emit(String emitKey,
 InputStream inputStream,
 Metadata userMetadata,
 ParseContext parseContext)
          throws IOException

Specified by:

emit in interface StreamEmitter

Throws:

IOException