Packages

class SolrDataMap[Key, Data <: Identifiable[Data]] extends DataMap[Key, Data]

This is the default data store that is used in the example. Without going too far into the Backend, this is an abstraction for a Solr Collection.

Key

The type of the key that's being used. Within the example, it's bigglue.examples.GitID for gitID, bigglue.examples.GitRepo for clonedMap, bigglue.examples.GitCommitInfo for commitInfoMap, and bigglue.examples.GitCommitGroups for authorMap.

Data

The type of the data that's being used. Within the example, it's bigglue.examples.GitID for gitID, bigglue.examples.GitRepo for clonedMap, bigglue.examples.GitCommitInfo for commitInfoMap, and bigglue.examples.GitCommitGroups for authorMap.

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SolrDataMap
  2. DataMap
  3. DataStore
  4. ConfigBuildsDataStore
  5. ConfigBuilds
  6. ConfigChecker
  7. Upstream
  8. AnyRef
  9. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SolrDataMap(serializer: JsonSerializer[Data], coreName: String, config: Config = ConfigFactory.load())

    serializer

    The serializer that needs to be used to serialize the objects into a flat Json file.

    coreName

    The name of the core/collection that is being used. If the core/collection doesn't exist, we just create a new core/collection.

    config

    The configuration file used for the Solr instance. If not specified, this will just be the default file.

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. def +(other: String): String
    Implicit
    This member is added by an implicit conversion from SolrDataMap[Key, Data] to any2stringadd[SolrDataMap[Key, Data]] performed by method any2stringadd in scala.Predef.
    Definition Classes
    any2stringadd
  4. def ->[B](y: B): (SolrDataMap[Key, Data], B)
    Implicit
    This member is added by an implicit conversion from SolrDataMap[Key, Data] to ArrowAssoc[SolrDataMap[Key, Data]] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc
    Annotations
    @inline()
  5. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  6. def add(data: Data): Unit
    Definition Classes
    DataStore
  7. def all(): Seq[Data]

    This gets everything from the data store.

    This gets everything from the data store.

    returns

    Every document that is stored in the data store.

    Definition Classes
    SolrDataMapDataStore
  8. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  9. def checkConfig(conf: PipeConfig): Unit

    Check that paths in configuration file relevant to host class are well-formed.

    Check that paths in configuration file relevant to host class are well-formed. Default does nothing.

    conf

    the config file to check

    Definition Classes
    ConfigChecker
  10. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  11. val configOpt: Option[PipeConfig]
    Definition Classes
    ConfigBuilds
  12. def constructBuilder(config: PipeConfig): DataStoreBuilder
    Definition Classes
    ConfigBuildsDataStoreConfigBuilds
  13. def contains(key: Key): Boolean
    Definition Classes
    SolrDataMapDataMap
  14. def displayName(): String
    Definition Classes
    DataStore
  15. val downstreamConnectors: Seq[Connector[Data]]
    Definition Classes
    Upstream
  16. def ensuring(cond: (SolrDataMap[Key, Data]) ⇒ Boolean, msg: ⇒ Any): SolrDataMap[Key, Data]
    Implicit
    This member is added by an implicit conversion from SolrDataMap[Key, Data] to Ensuring[SolrDataMap[Key, Data]] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  17. def ensuring(cond: (SolrDataMap[Key, Data]) ⇒ Boolean): SolrDataMap[Key, Data]
    Implicit
    This member is added by an implicit conversion from SolrDataMap[Key, Data] to Ensuring[SolrDataMap[Key, Data]] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  18. def ensuring(cond: Boolean, msg: ⇒ Any): SolrDataMap[Key, Data]
    Implicit
    This member is added by an implicit conversion from SolrDataMap[Key, Data] to Ensuring[SolrDataMap[Key, Data]] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  19. def ensuring(cond: Boolean): SolrDataMap[Key, Data]
    Implicit
    This member is added by an implicit conversion from SolrDataMap[Key, Data] to Ensuring[SolrDataMap[Key, Data]] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  20. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  21. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  22. def extract(): Seq[Data]
    Definition Classes
    SolrDataMapDataStore
  23. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  24. def formatted(fmtstr: String): String
    Implicit
    This member is added by an implicit conversion from SolrDataMap[Key, Data] to StringFormat[SolrDataMap[Key, Data]] performed by method StringFormat in scala.Predef.
    Definition Classes
    StringFormat
    Annotations
    @inline()
  25. def get(key: Key): Option[Data]
    Definition Classes
    SolrDataMapDataMap
  26. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
  27. def getConfig(config: PipeConfig): PipeConfig
    Definition Classes
    ConfigBuilds
  28. def getOrElse(key: Key, default: Data): Data
    Definition Classes
    DataMap
  29. def hashCode(): Int
    Definition Classes
    AnyRef → Any
  30. def init(conf: PipeConfig): Unit
    Definition Classes
    DataStore
  31. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  32. def iterator(): Iterator[Data]

    This returns an iterator that iterates over the data store.

    This returns an iterator that iterates over the data store.

    returns

    An iterator that iterates over the data store until all documents have been processed.

    Definition Classes
    SolrDataMapDataStore
  33. var name: String
    Definition Classes
    DataStore
  34. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  35. final def notify(): Unit
    Definition Classes
    AnyRef
  36. final def notifyAll(): Unit
    Definition Classes
    AnyRef
  37. def put(key: Key, data: Data): Unit
    Definition Classes
    DataMap
  38. def put(data: Data): Unit
    Definition Classes
    DataStore
  39. def put(data: Seq[Data]): Unit

    This puts the data into the data store using put_, and then sends the data down the pipeline if the data store is connected to the pipeline.

    This puts the data into the data store using put_, and then sends the data down the pipeline if the data store is connected to the pipeline.

    data

    The data that needs to be put into the data store.

    Definition Classes
    DataStore
  40. def put_(data: Seq[Data]): Unit

    Serializes everything, and then creates the key as the object itself.

    Serializes everything, and then creates the key as the object itself.

    data

    The data to be put into the data store.

    Definition Classes
    SolrDataMapDataStore
  41. def put_(key: Key, data: Data): Unit

    Serializes the data under the key, and then puts that in Solr.

    Serializes the data under the key, and then puts that in Solr.

    key

    The key in which the data should be filed under.

    data

    The data in which we are putting into Solr.

    Definition Classes
    SolrDataMapDataMap
  42. def registerConnector(connector: Connector[Data]): Unit
    Definition Classes
    Upstream
  43. def remove(keys: Seq[Key]): Unit
    Definition Classes
    SolrDataMapDataMap
  44. def remove(key: Key): Unit
    Definition Classes
    SolrDataMapDataMap
  45. def setConfig(pipeConfig: PipeConfig): Unit
    Definition Classes
    ConfigBuilds
  46. def setName(newName: String): Unit
    Definition Classes
    DataStore
  47. def size(): Int
    Definition Classes
    SolrDataMapDataStore
  48. val solrBack: SolrBackend[Data]
  49. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  50. def terminate(): Unit
    Definition Classes
    DataStore
  51. def toString(): String
    Definition Classes
    AnyRef → Any
  52. def transmitDownstream(data: Data): Unit
    Definition Classes
    Upstream
  53. def transmitDownstream(data: Seq[Data]): Unit
    Definition Classes
    Upstream
  54. def transmitDownstreamModified(data: Data): Unit
    Definition Classes
    Upstream
  55. def transmitDownstreamModified(data: Seq[Data]): Unit
    Definition Classes
    Upstream
  56. val url: String
  57. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  58. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  59. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  60. def [B](y: B): (SolrDataMap[Key, Data], B)
    Implicit
    This member is added by an implicit conversion from SolrDataMap[Key, Data] to ArrowAssoc[SolrDataMap[Key, Data]] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc

Inherited from DataMap[Key, Data]

Inherited from DataStore[Data]

Inherited from ConfigBuildsDataStore

Inherited from ConfigBuilds[DataStoreBuilder]

Inherited from ConfigChecker

Inherited from Upstream[Data]

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from SolrDataMap[Key, Data] to any2stringadd[SolrDataMap[Key, Data]]

Inherited by implicit conversion StringFormat from SolrDataMap[Key, Data] to StringFormat[SolrDataMap[Key, Data]]

Inherited by implicit conversion Ensuring from SolrDataMap[Key, Data] to Ensuring[SolrDataMap[Key, Data]]

Inherited by implicit conversion ArrowAssoc from SolrDataMap[Key, Data] to ArrowAssoc[SolrDataMap[Key, Data]]

Ungrouped