Package com.github.hakenadu.javalangchains.chains.data.writer

Class WriteDocumentsToLuceneDirectoryChain

java.lang.Object

com.github.hakenadu.javalangchains.chains.data.writer.WriteDocumentsToLuceneDirectoryChain

All Implemented Interfaces:

Chain<Stream<Map<String,String>>,org.apache.lucene.store.Directory>

public class WriteDocumentsToLuceneDirectoryChain
extends Object
implements Chain<Stream<Map<String,String>>,org.apache.lucene.store.Directory>

Stores documents in a lucene Directory

Field Summary

Fields inherited from interface com.github.hakenadu.javalangchains.chains.Chain

LOGGER

Constructor Summary

Constructors

Constructor	Description
WriteDocumentsToLuceneDirectoryChain()	creates a WriteDocumentsToLuceneDirectoryChain with a default temp directory path
WriteDocumentsToLuceneDirectoryChain(Path directoryOutputPath)

Method Summary

Modifier and Type	Method	Description
org.apache.lucene.store.Directory	run(Stream<Map<String,String>> input)	Execute this Chain

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.github.hakenadu.javalangchains.chains.Chain

chain

Constructor Details

WriteDocumentsToLuceneDirectoryChain

public WriteDocumentsToLuceneDirectoryChain(Path directoryOutputPath)

Parameters:

directoryOutputPath - directoryOutputPath

WriteDocumentsToLuceneDirectoryChain

public WriteDocumentsToLuceneDirectoryChain() throws IOException

creates a WriteDocumentsToLuceneDirectoryChain with a default temp directory path

Throws:

IOException - on error creating the temp dir

Method Details

run

public org.apache.lucene.store.Directory run(Stream<Map<String,String>> input)

Description copied from interface: Chain

Execute this Chain

Specified by:

run in interface Chain<Stream<Map<String,String>>,org.apache.lucene.store.Directory>

Parameters:

input - this chain's input

Returns:

this chain's output