Klasse ElasticsearchTool.ElasticsearchWorkerPool<R>

java.lang.Object
org.xbib.interlibrary.api.action.worker.AbstractWorkerPool<R>
org.xbib.interlibrary.catalog.builder.ConverterWorkerPool<R>
org.xbib.interlibrary.catalog.elasticsearch.ElasticsearchTool.ElasticsearchWorkerPool<R>
Alle implementierten Schnittstellen:
Closeable, AutoCloseable, Iterable<org.xbib.interlibrary.api.action.worker.WorkerRequest<R>>, org.xbib.interlibrary.api.action.worker.WorkerPool<R>
Bekannte direkte Unterklassen:
Addresses.AddressesWorkerPool, BRSSearch.BRSSearchWorkerPool, ElasticsearchToolOAI.ElasticsearchOAIWorkerPool, EZBWeb.EZBWebWorkerPool, EZBWebFile.EZBWebFileWorkerPool, EZBXML.EZBXMLWorkerPool, GNDRdfXml.GNDRdfXmlWorkerPool, HbzAlma.HbzAlmaWorkerPool, HbzAlmaExport.HbzAlmaExportWorkerPool, HbzAlmaGvi.HbzAlmaGviWorkerPool, HbzFix.HbzFixWorkerPool, JsonLines.JsonLinesWorkerPool, MarcBibliographic.MarcBibliographicWorkerPool, MarcHoldings.MarcHoldingsWorkerPool, Mesh.MeshWorkerPool, OpenAlex.OpenAlexPool, OpenAlexFromAmazonS3.OpenAlexPool, Pubmed.PubmedWorkerPool, SpringerCitations.SpringerCitationsWorkerPool, TitleHoldings.TitleHoldingsWorkerPool, XMLClobs.XMLClobsWorkerPool, ZDBEZB.ZDBEZBWorkerPool
Umschließende Klasse:
ElasticsearchTool<R>

public abstract static class ElasticsearchTool.ElasticsearchWorkerPool<R> extends org.xbib.interlibrary.catalog.builder.ConverterWorkerPool<R>
  • Konstruktordetails

    • ElasticsearchWorkerPool

      public ElasticsearchWorkerPool(String poolName, org.xbib.settings.Settings settings) throws IOException
      Löst aus:
      IOException
  • Methodendetails

    • openInput

      protected void openInput() throws IOException, InterruptedException
      Setzt außer Kraft:
      openInput in Klasse org.xbib.interlibrary.catalog.builder.ConverterWorkerPool<R>
      Löst aus:
      IOException
      InterruptedException
    • openOutput

      protected void openOutput() throws IOException
      Setzt außer Kraft:
      openOutput in Klasse org.xbib.interlibrary.catalog.builder.ConverterWorkerPool<R>
      Löst aus:
      IOException
    • closeInput

      protected void closeInput(int returncode) throws IOException
      Setzt außer Kraft:
      closeInput in Klasse org.xbib.interlibrary.catalog.builder.ConverterWorkerPool<R>
      Löst aus:
      IOException
    • closeOutput

      protected void closeOutput(int returncode) throws IOException
      Setzt außer Kraft:
      closeOutput in Klasse org.xbib.interlibrary.catalog.builder.ConverterWorkerPool<R>
      Löst aus:
      IOException
    • closeMetrics

      protected void closeMetrics() throws IOException
      Setzt außer Kraft:
      closeMetrics in Klasse org.xbib.interlibrary.catalog.builder.ConverterWorkerPool<R>
      Löst aus:
      IOException
    • getInputIndexDefinitionMap

      public Map<String,ElasticsearchIndexDefinition> getInputIndexDefinitionMap()
    • getOutputIndexDefinitionMap

      public Map<String,ElasticsearchIndexDefinition> getOutputIndexDefinitionMap()
    • searchClient

      public org.xbib.elx.api.SearchClient searchClient()
    • bulkIndex

      public void bulkIndex(org.xbib.elx.api.IndexDefinition indexDefinition, String id, boolean create, String content)
    • bulkIndex

      public void bulkIndex(org.elasticsearch.action.index.IndexRequest indexRequest)
    • delete

      public void delete(org.xbib.elx.api.IndexDefinition indexDefinition, String id)
    • getNamespaceContext

      public org.xbib.content.resource.IRINamespaceContext getNamespaceContext()