Package org.gcube.socialnetworking.socialdataindexer

Class SocialDataIndexerPlugin

java.lang.Object
org.gcube.vremanagement.executor.plugin.Plugin
org.gcube.socialnetworking.socialdataindexer.SocialDataIndexerPlugin
All Implemented Interfaces:
org.gcube.vremanagement.executor.plugin.PluginDefinition
public class SocialDataIndexerPlugin extends org.gcube.vremanagement.executor.plugin.Plugin
The SocialDataIndexerPlugin synchronizes and indexes data coming from the cassandra cluster in the elasticsearch engine.
Author:
Costantino Perciante at ISTI-CNR, Luca Frosini (ISTI-CNR)

  • Field Summary

    Fields inherited from class org.gcube.vremanagement.executor.plugin.Plugin

    DESCRIPTION_PROPERTY, GROUP_PROPERTY, iterationNumber, NAME_PROPERTY, percentageSetter, PLUGIN_PROPERTIES_SUFFIX_FILENAME, properties, uuid, VERSION_PROPERTY

  • Constructor Summary

    Constructors
    Constructor
    Description
    SocialDataIndexerPlugin()
    Default constructor.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    deleteDocumentsWithTimestampLowerThan(long timestamp)
    Delete disabled feeds in the index
    void
    launch(Map<String,Object> inputs)
    protected void
    onStop()

    Methods inherited from class org.gcube.vremanagement.executor.plugin.Plugin

    getDescription, getGroup, getIterationNumber, getName, getSupportedCapabilities, getUUID, getVersion, setIterationNumber, setPercentageEvolution, setPercentageSetter, setUUID, stop

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • SocialDataIndexerPlugin

      public SocialDataIndexerPlugin()
      Default constructor.

  • Method Details

    • launch

      public void launch(Map<String,Object> inputs) throws Exception
      Specified by:
      launch in class org.gcube.vremanagement.executor.plugin.Plugin
      Throws:
      Exception - if the synchronization fails.

    • deleteDocumentsWithTimestampLowerThan

      public void deleteDocumentsWithTimestampLowerThan(long timestamp)
      Delete disabled feeds in the index
      Parameters:
      timestamp - delete feeds whose _timestamp is lower than timestamp

    • onStop

      protected void onStop() throws Exception
      Specified by:
      onStop in class org.gcube.vremanagement.executor.plugin.Plugin
      Throws:
      Exception