Packages

class DeducerSource extends AnyRef

Linear Supertypes
AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DeducerSource
  2. AnyRef
  3. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new DeducerSource(ded: Deducer, initDist: FiniteDistribution[Term], initBatch: Int, batchSize: Int, smooth: (FiniteDistribution[Term]) => FiniteDistribution[Term] = identity, names: Vector[(Term, String)] = Vector())

Value Members

  1. def deduc: Source[FiniteDistribution[Term], NotUsed]
  2. def deducBatches(fdInit: FiniteDistribution[Term], invMap: InvMap): Source[FiniteDistribution[Term], NotUsed]
  3. def deducBatchesConc(threads: Int)(fdInit: FiniteDistribution[Term], invMap: InvMap): Source[FiniteDistribution[Term], NotUsed]
  4. def deducConc(threads: Int): Source[FiniteDistribution[Term], NotUsed]
  5. def deducResult: Source[FiniteDistribution[Term], NotUsed]
  6. def firstBatchConc(threads: Int): Future[(FiniteDistribution[Term], InvMap)]
  7. def firstBatchFut: Future[(FiniteDistribution[Term], InvMap)]
  8. def initSource: Source[(FiniteDistribution[Term], InvMap), NotUsed]
  9. def initSourceConc(threads: Int): Source[(FiniteDistribution[Term], InvMap), NotUsed]
  10. def learnBatches(fdInit: FiniteDistribution[Term], invMap: InvMap): Source[FiniteDistribution[Term], NotUsed]
  11. def learnBatchesConc(threads: Int)(fdInit: FiniteDistribution[Term], invMap: InvMap): Source[FiniteDistribution[Term], NotUsed]
  12. def learnFlow: Flow[FiniteDistribution[Term], FiniteDistribution[Term], NotUsed]
  13. def learnFlowConc(threads: Int): Flow[FiniteDistribution[Term], FiniteDistribution[Term], NotUsed]
  14. def loopy(dedLoops: Long, learnLoops: Long): NotUsed
  15. def loopyConc(dedLoops: Long, learnLoops: Long, threads: Int = 3): NotUsed
  16. def loopySaved(dedLoops: Long, learnLoops: Long, name: String): Future[Done]
  17. def timedRun(dedTime: FiniteDuration, learnTime: FiniteDuration, name: String): Future[Done]
  18. def timedRunConc(dedTime: FiniteDuration, learnTime: FiniteDuration, name: String, threads: Int = 3): Future[Done]