Packages

package spark

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package connections
  2. package encryption
  3. package functions
  4. package ml
  5. package sources
  6. package transforms

Type Members

  1. class ArtifactPersistence extends AnyRef
  2. case class ChangeInterval(startDate: LocalDateTime, endDate: LocalDateTime, startIncluded: Boolean, endIncluded: Boolean) extends Product with Serializable
  3. class CustomExecuterProvider extends AnyRef
  4. class CustomTransformExecutors extends AnyRef
  5. trait DashboardDataFrameOperationsContract extends AnyRef
  6. class DashboardDataFrameOperationsImpl extends DashboardDataFrameOperationsContract
  7. case class DataFrameFilterDescription(filterColumn: String, lowerBound: LocalDateTime, upperBound: LocalDateTime) extends Product with Serializable
  8. class DataFrameReader extends AnyRef
  9. class ExecutionCache extends AnyRef

    Handles caching and uncaching of data frames during execution.

  10. class ExecutionContext extends AnyRef
  11. class ExecutionState extends AnyRef
  12. class ExternalExecuterProvider extends AnyRef
  13. trait ExternalTransformExecuter extends TransformExecuter
  14. class FacadeApi extends RealTimeAware with Facades

    Provides access to the external web service API.

  15. case class LazyFunction1[T, R](id: String, code: String) extends Product with Serializable
  16. case class LazyFunction2[T1, T2, R](id: String, code: String) extends Product with Serializable
  17. case class LazyFunction3[T1, T2, T3, R](id: String, code: String) extends Product with Serializable
  18. case class LazyFunction4[T1, T2, T3, T4, R](id: String, code: String) extends Product with Serializable
  19. case class LazyFunction5[T1, T2, T3, T4, T5, R](id: String, code: String) extends Product with Serializable
  20. case class LazyFunction6[T1, T2, T3, T4, T5, T6, R](id: String, code: String) extends Product with Serializable
  21. case class LazyFunction7[T1, T2, T3, T4, T5, T6, T7, R](id: String, code: String) extends Product with Serializable
  22. case class LazyFunction8[T1, T2, T3, T4, T5, T6, T7, T8, R](id: String, code: String) extends Product with Serializable
  23. case class LazyFunction9[T1, T2, T3, T4, T5, T6, T7, T8, T9, R](id: String, code: String) extends Product with Serializable
  24. case class LiveExecution(snapshotsToLoad: Map[String, Array[UUID]], lastHistoryDate: Option[LocalDateTime]) extends Product with Serializable
  25. class LiveTableLoader extends AnyRef
  26. case class LocalSource(localId: String, results: List[(OutputAccess, (UUID, LocalDateTime))], loaded: Map[UUID, TransformExecutionResult], adornWithTimelineMetaData: Boolean, dataFilter: Option[DataFrameFilterDescription]) extends Product with Serializable
  27. class LocalSourceProvider extends AnyRef
  28. class LogReader extends AnyRef
  29. trait ModelConsumerExecuter extends TransformExecuter
  30. class ModelPersistence extends AnyRef
  31. case class Municipality(id: String, weight: Double) extends Product with Serializable
  32. class PipelineExecutionScope extends AnyRef
  33. class PipelineExecutionScopeApi extends AnyRef

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

  34. class PipelineExecutionStateApi extends AnyRef

    Exposes methods and properties that may be used independent of the specific transform.

  35. class PipelineSnapshotExecuter extends AnyRef
  36. class PythonTransformExecuter extends ExternalTransformExecuter with Logging
  37. class QueryContext extends RealTimeAware
  38. trait QueryProvider extends AnyRef
  39. class RTransformExecuter extends ExternalTransformExecuter
  40. trait RegisterCallback extends AnyRef
  41. case class RunningInfo(runningTransformStatus: Option[TransformTestResultStatus], outputTransformIds: Option[List[String]], testInfoContainer: TestInfoContainer) extends Product with Serializable
  42. trait SingleTransformExecuter extends TransformExecuter
  43. class SnapshotCache extends AnyRef
  44. case class SnapshotChanges(interval: ChangeInterval, rebuildTimeLine: Boolean) extends Product with Serializable
  45. case class SnapshotMetaData(snapshot_id: String, timeline_date: Timestamp, timeline_order: Int) extends Product with Serializable
  46. class TempOutputManager extends TempOutputManagerCore with Logging
  47. class TestInfoContainer extends AnyRef
  48. trait TransformExecuter extends AnyRef
  49. class TransformExecuterFactory extends AnyRef
  50. class TransformExecutionParameter extends AnyRef
  51. case class TransformExecutionResult(frame: DataFrame, model: Option[PipelineModel] = None, testInfo: Option[TestExecutionInfo] = None) extends Product with Serializable
  52. class TransformExecutionStateApi extends RealTimeAware

    Exposes methods and properties that are specific to the currently executing transform.

  53. class UserTestSession extends AnyRef

Value Members

  1. object BuiltInFunctionDefinitions
  2. object ChangeInterval extends Serializable
  3. object DanishGeography
  4. object DashboardDataFrameOperations extends DashboardDataFrameOperationsContract
  5. object DataFrameOperations

    Contains simple, useful operations for dataframes.

  6. object DataFrameReader
  7. object DataFrameStatistics
  8. object DataFrameWriter
  9. object DatabaseUtils

    Utility class with methods to help export data frames to a database

  10. object LiveTableLoader
  11. object LogReader
  12. object MetaDataOperations
  13. object ModelPersistence
  14. object PipelineSnapshotExecuter
  15. object SnapshotCache
  16. object SparkHelpers
  17. object SparkSessionManager
  18. object SparkSqlAnalyser
  19. object TimelinePartitioner
  20. object ToolboxFactory
  21. object TransformExecutionParameter
  22. object UdfCompiler

Ungrouped