package sources

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. case class ClockifyElement(id: String) extends Product with Serializable
  2. class ClockifySourceExecuter extends SourceExecuter
  3. class ClockifySourceGenerator extends SourceGeneratorBase
  4. class ColumnConverter extends AnyRef
  5. class CsvSourceExecuter extends SourceExecuter
  6. class CsvSourceGenerator extends SourceGeneratorBase
  7. abstract class CustomSource extends AnyRef
  8. class CustomSourceExecuter extends SourceExecuter
  9. class CustomSourceGenerator extends SourceGeneratorBase
  10. class DatabaseSourceExecuter extends SourceExecuter with Logging
  11. class DatabaseSourceGenerator extends SourceGeneratorBase
  12. class EconomicSourceExecuter extends SourceExecuter
  13. class EconomicSourceGenerator extends SourceGeneratorBase
  14. class EnvironmentSourceExecuter extends SourceExecuter
  15. class EnvironmentSourceGenerator extends SourceGeneratorBase
  16. class ExchangeSourceExecuter extends SourceExecuter
  17. class ExchangeSourceGenerator extends SourceGeneratorBase
  18. class RegistrySourceExecuter extends SourceExecuter
  19. class RegistrySourceGenerator extends SourceGeneratorBase
  20. trait SourceExecuter extends AnyRef
  21. case class SourceExecutionScope(session: SparkSession, facades: FacadeApi, connection: ConnectionDescription, source: SourceContent, snapshot: SourceSnapshotInfo, dateRange: Option[TimelineFilter], testSample: Option[Int], tempOutputManager: TempOutputManager, log: (Any) ⇒ Unit, setProgress: (Double) ⇒ Unit) extends Product with Serializable

    Exposes methods and properties that may be useful to access during source execution.

    Exposes methods and properties that may be useful to access during source execution.

    session

    The Apache Spark session that is used during execution.

    facades

    Provides access to the external web service API.

    connection

    The connection properties to be used with the source.

    source

    The properties of the source configuration.

    snapshot

    The properties of the snapshot of the source configuration.

    dateRange

    The date range to fetch data for, if the source is of type ResultTypes.STREAM.

    testSample

    The amount of data to sample during a test run.

    tempOutputManager

    A manager that can handle storage and disposal of temporary output for the run.

    log

    A method that writes to the logs.

    setProgress

    A method that sets the progress.

  22. abstract class SourceGeneratorBase extends AnyRef
  23. class SourceSnapshotExecuter extends AnyRef
  24. class SourceSqlBuilder extends AnyRef
  25. case class SparkExtraArgs(outputRepository: String) extends Product with Serializable
  26. class SystemSourceExecuter extends SourceExecuter
  27. class SystemSourceGenerator extends SourceGeneratorBase
  28. class TestSourceExecuter extends SourceExecuter
  29. case class TimelineFilter(timelineColumn: SourceDataDescriptionColumn, lowerBound: Option[LocalDateTime], upperBound: LocalDateTime) extends Product with Serializable

Value Members

  1. object ClockifyEndpoins
  2. object RegistrySourceExecuter
  3. object SourceContentGenerator
  4. object SourceExecuterFactory
  5. object SourceSnapshotExecuter
  6. object SourceSqlBuilder
  7. object SystemSourceExecuter
  8. object TestSourceExecuter

Ungrouped