package spark
Ordering
- Alphabetic
Visibility
- Public
- Protected
Package Members
- package connections
- package encryption
- package functions
- package ml
- package sources
- package transforms
Type Members
- class ArtifactPersistence extends AnyRef
- case class ChangeInterval(startDate: LocalDateTime, endDate: LocalDateTime, startIncluded: Boolean, endIncluded: Boolean) extends Product with Serializable
- class CustomExecuterProvider extends AnyRef
- class CustomTransformExecutors extends AnyRef
- trait DashboardDataFrameOperationsContract extends AnyRef
- class DashboardDataFrameOperationsImpl extends DashboardDataFrameOperationsContract
- case class DataFrameFilterDescription(filterColumn: String, lowerBound: LocalDateTime, upperBound: LocalDateTime) extends Product with Serializable
- class DataFrameReader extends AnyRef
- class ExecutionCache extends AnyRef
Handles caching and uncaching of data frames during execution.
- class ExecutionContext extends AnyRef
- class ExecutionState extends AnyRef
- class ExternalExecuterProvider extends AnyRef
- trait ExternalTransformExecuter extends TransformExecuter
- class FacadeApi extends RealTimeAware with Facades
Provides access to the external web service API.
- case class LazyFunction1[T, R](id: String, code: String) extends Product with Serializable
- case class LazyFunction2[T1, T2, R](id: String, code: String) extends Product with Serializable
- case class LazyFunction3[T1, T2, T3, R](id: String, code: String) extends Product with Serializable
- case class LazyFunction4[T1, T2, T3, T4, R](id: String, code: String) extends Product with Serializable
- case class LazyFunction5[T1, T2, T3, T4, T5, R](id: String, code: String) extends Product with Serializable
- case class LazyFunction6[T1, T2, T3, T4, T5, T6, R](id: String, code: String) extends Product with Serializable
- case class LazyFunction7[T1, T2, T3, T4, T5, T6, T7, R](id: String, code: String) extends Product with Serializable
- case class LazyFunction8[T1, T2, T3, T4, T5, T6, T7, T8, R](id: String, code: String) extends Product with Serializable
- case class LazyFunction9[T1, T2, T3, T4, T5, T6, T7, T8, T9, R](id: String, code: String) extends Product with Serializable
- case class LiveExecution(snapshotsToLoad: Map[String, Array[UUID]], lastHistoryDate: Option[LocalDateTime]) extends Product with Serializable
- class LiveTableLoader extends AnyRef
- case class LocalSource(localId: String, results: List[(OutputAccess, (UUID, LocalDateTime))], loaded: Map[UUID, TransformExecutionResult], adornWithTimelineMetaData: Boolean, dataFilter: Option[DataFrameFilterDescription]) extends Product with Serializable
- class LocalSourceProvider extends AnyRef
- class LogReader extends AnyRef
- trait ModelConsumerExecuter extends TransformExecuter
- class ModelPersistence extends AnyRef
- case class Municipality(id: String, weight: Double) extends Product with Serializable
- class PipelineExecutionScope extends AnyRef
- class PipelineExecutionScopeApi extends AnyRef
Exposes methods and properties that may be useful to access during pipeline execution.
- class PipelineExecutionStateApi extends AnyRef
Exposes methods and properties that may be used independent of the specific transform.
- class PipelineSnapshotExecuter extends AnyRef
- class PythonTransformExecuter extends ExternalTransformExecuter with Logging
- class QueryContext extends RealTimeAware
- trait QueryProvider extends AnyRef
- class RTransformExecuter extends ExternalTransformExecuter
- trait RegisterCallback extends AnyRef
- case class RunningInfo(runningTransformStatus: Option[TransformTestResultStatus], outputTransformIds: Option[List[String]], testInfoContainer: TestInfoContainer) extends Product with Serializable
- trait SingleTransformExecuter extends TransformExecuter
- class SnapshotCache extends AnyRef
- case class SnapshotChanges(interval: ChangeInterval, rebuildTimeLine: Boolean) extends Product with Serializable
- case class SnapshotMetaData(snapshot_id: String, timeline_date: Timestamp, timeline_order: Int) extends Product with Serializable
- class TempOutputManager extends TempOutputManagerCore with Logging
- class TestInfoContainer extends AnyRef
- trait TransformExecuter extends AnyRef
- class TransformExecuterFactory extends AnyRef
- class TransformExecutionParameter extends AnyRef
- case class TransformExecutionResult(frame: DataFrame, model: Option[PipelineModel] = None, testInfo: Option[TestExecutionInfo] = None) extends Product with Serializable
- class TransformExecutionStateApi extends RealTimeAware
Exposes methods and properties that are specific to the currently executing transform.
- class UserTestSession extends AnyRef
Value Members
- object BuiltInFunctionDefinitions
- object ChangeInterval extends Serializable
- object DanishGeography
- object DashboardDataFrameOperations extends DashboardDataFrameOperationsContract
- object DataFrameOperations
Contains simple, useful operations for dataframes.
- object DataFrameReader
- object DataFrameStatistics
- object DataFrameWriter
- object DatabaseUtils
Utility class with methods to help export data frames to a database
- object LiveTableLoader
- object LogReader
- object MetaDataOperations
- object ModelPersistence
- object PipelineSnapshotExecuter
- object SnapshotCache
- object SparkHelpers
- object SparkSessionManager
- object SparkSqlAnalyser
- object TimelinePartitioner
- object ToolboxFactory
- object TransformExecutionParameter
- object UdfCompiler