package facade
- Alphabetic
- Public
- Protected
Type Members
- case class AdditionalSidebarItem(title: String, url: String, access: UserAccess, environments: List[String], faIcon: String) extends Product with Serializable
Holds information for displaying an additional sidebar item w.
Holds information for displaying an additional sidebar item w. title, icon and link
- case class Annotation(row: Int, col: Int, text: Seq[String], type: String) extends Product with Serializable
Holds information compile check annotation (error or warning).
- trait ApplicationFacade extends ServiceFacadeWithDatabase with ServiceFacade[ApplicationFacade]
- class ApplicationWebFacade extends ApplicationFacade with ServiceWebFacadeWithDatabase with ServiceFacade[ApplicationFacade]
- class ArithmeticEvaluator extends JavaTokenParsers
Similar to ArithmeticInterpreter, but builds evaluators for expressions to be used with different symbol resolvers.
- class ArithmeticInterpreter extends JavaTokenParsers
An interpreter for evaluating simple arithmetic or boolean expressions.
An interpreter for evaluating simple arithmetic or boolean expressions. Supported arithmetic operators are +, -, *, /. Supported boolean operators are <, <=, >, >=, =, !=, and, or, xor. Supported functions are pow, max, min, floor, ceil, round, log, log10, sqrt, exp, abs. Boolean expressions in arithmetic expressions are interpreted as indicator functions.
- case class Artifact(name: String, content: Array[Byte]) extends Product with Serializable
Holds the name and data for an artifact
- case class ArtifactsInfo(names: List[String], pipelineId: String, transformId: String, pipelineVersion: UUID, pipelineTag: String) extends Product with Serializable
Holds metadata on which artifacts are produced by a pipeline snapshot.
- case class AuditLogEntry(date: String, timestamp: String, endpoint: String, serviceId: String, serviceName: String, cpuUsedPercent: Double, memoryUsedPercent: Double, numberOfCores: Int, memoryTotalMb: Int, id: String, action: String, resource: String, queryParameters: String, userId: String, ipAddress: Option[String], environmentId: String, responseStatus: Int, responseTimeMs: Int) extends LogEntryBase with Product with Serializable
Holds information on an audit log entry.
- case class AuthorizationInfo(userId: String, userOptions: Option[Map[String, String]], authorization: Option[Map[String, List[String]]], groups: List[String], tags: Option[List[String]]) extends Product with Serializable
Holds information on a users authorization.
Holds information on a users authorization.
- userId
The unique id of the user.
- userOptions
The user options.
- authorization
The final authorization labels (including groups) keyed by environment. For admin users this is
None.- groups
The ids of groups that the user is a member of.
- tags
The tags that the user may query, if applicable.
- class AuthorizationManager extends AnyRef
- case class AutoComplete(name: String, methodSignature: String, score: Int, meta: String, type: String) extends Product with Serializable
Holds information an auto-complete request candidate.
- case class AutoCompleteRequest(code: String, intOffset: Int, language: String, pluginType: Option[String], id: String, importModules: Option[List[String]]) extends CodeRequest with Product with Serializable
Holds information on a request for auto-complete information on a code snippet.
- trait BaseHttpClient extends AnyRef
- class BaseHttpClientFactory extends AnyRef
- case class BatchContent(id: String, name: String, description: String, data_raw: Option[BatchData]) extends VersionedEntityContentAuth[BatchContent] with BatchDataProperties with WithOptions with Product with Serializable
- case class BatchData(options: Map[String, String], sources: List[SourceElement], pipelines: List[PipelineElement], batches: List[String]) extends BatchDataProperties with Product with Serializable
- trait BatchDataProperties extends AnyRef
- case class BatchInfo(version: UUID, deletionTime: Option[LocalDateTime], creationUser: String, content: BatchContent, versionDateTime: LocalDateTime) extends VersionedEntityInfo[BatchContent] with Product with Serializable
- case class BatchJobInfo(batchId: String, id: UUID, idDateTime: LocalDateTime, snapshotVersion: LocalDateTime, state: String, progress: Double, lastModified: LocalDateTime, sourceJobs: List[UUID], pipelineJobs: List[UUID], retries: Int, tag: String, startTime: Option[LocalDateTime], endTime: Option[LocalDateTime]) extends Product with Serializable
Holds information on a batch job.
Holds information on a batch job. A batch job connects multiple jobs for source and pipeline runs, and provides aggregated data on their collective state and progress.
- case class BatchSnapshotInfo(batchId: String, version: LocalDateTime, batchVersion: UUID, batchVersionDateTime: LocalDateTime, creationUser: String, sourceSnapshots: List[SnapshotId], pipelineSnapshots: List[SnapshotNode], tag: String, expires: Option[LocalDateTime]) extends Product with Serializable
Holds information on a batch snapshot.
Holds information on a batch snapshot. A batch snapshot has data on the timestamp, tag and configuration version used for determining the source and pipeline snapshots to be build for the batch. It also logs which user created the snapshot and when the snapshot may expire (after which it will eventually be deleted). Additionally it has information on which source and pipeline snapshots the batch snapshot includes.
- case class BatchUpdates(sources: List[String], pipelines: List[String]) extends Product with Serializable
Wraps collections of source and pipeline ids that should be updated by a batch job.
- class BooleanEvaluator extends AnyRef
An evaluator for a boolean expression.
- trait BoundedMapLike extends AnyRef
- case class BugReport(description: String, reporter: String, environment: String, screenshot: String) extends Product with Serializable
Holds information on a user bug report.
- case class BuildLabels(version: String, revision: String, timestamp: String) extends Product with Serializable
Holds information on the current build of the software
- class ByOptionSequence[T] extends AnyRef
- class BypassHostnameVerifier extends HostnameVerifier
- class BypassX509TrustManager extends X509TrustManager
- case class CacheStatistics(id: String, capacity: Int, size: Int, requests: Long, misses: Long) extends Product with Serializable
- case class ClusterContent(id: String, name: String, description: String, data_raw: Option[ClusterData]) extends VersionedEntityContentAuth[ClusterContent] with ClusterDataProperties with WithOptions with Product with Serializable
- case class ClusterData(options: Map[String, String], scalingGroup: String, memoryLevel: Int, scalingDescription: ScalingDescription, runnerService: RunnerServiceData) extends ClusterDataProperties with Product with Serializable
- trait ClusterDataProperties extends AnyRef
- case class ClusterInfo(version: UUID, versionDateTime: LocalDateTime, deletionTime: Option[LocalDateTime], creationUser: String, content: ClusterContent) extends VersionedEntityInfo[ClusterContent] with Product with Serializable
- case class ClusterStateInfo(clusterId: String, enabled: Boolean, lastScaleOut: Option[LocalDateTime], lastScaleIn: Option[LocalDateTime], currentCapacity: Int, desiredCapacity: Int) extends Product with Serializable
Holds information on the current state of a cluster.
- trait CodeRequest extends AnyRef
Defines base properties for a code snippet.
- case class Column(name: String, table: String, originTable: String = "", aliases: List[String] = List(), type: String = "") extends Product with Serializable
A column candidate for auto-completion in an SQL snippet.
- case class ColumnDeletion(outputId: String, column: String, created: LocalDateTime, processed: Option[LocalDateTime]) extends Product with Serializable
Holds the state information on a deleted column
- case class CompileRequest(code: String, language: String, pluginType: Option[String], importModules: Option[List[String]]) extends CodeRequest with Product with Serializable
Holds information on a request for checking compilation of code snippet.
- case class ConfigAccess(read: Option[UserAccess], write: Option[UserAccess]) extends Product with Serializable
Holds information on who can read and write for an entity.
- trait ConfigFacade extends ServiceFacadeWithDatabase with ServiceFacade[ConfigFacade]
The interface for the external API of the Config Service.
The interface for the external API of the Config Service.
The Config Service is responsible for the management of configuration related to data import and transformation, including embedded custom apps and internal data sources such as registries and files.
- case class ConfigGraph(sources: List[SourceInfo], pipelines: List[PipelineInfo]) extends Product with Serializable
- case class ConfigParameterContent(id: String, name: String, description: String, data_raw: Option[ConfigParameterData]) extends VersionedEntityContentAuth[ConfigParameterContent] with ConfigParameterDataProperties with Product with Serializable
- case class ConfigParameterData(options: Map[String, String], serviceClass: Option[String], serviceName: Option[String], key: String, value: String) extends ConfigParameterDataProperties with Product with Serializable
- trait ConfigParameterDataProperties extends AnyRef
- case class ConfigParameterInfo(version: UUID, versionDateTime: LocalDateTime, deletionTime: Option[LocalDateTime], creationUser: String, content: ConfigParameterContent) extends VersionedEntityInfo[ConfigParameterContent] with Product with Serializable
- case class ConfigServiceData(options: Map[String, String], name: String, memoryLimit: String, port: Option[Int]) extends ServiceData with Product with Serializable
- class ConfigWebFacade extends ConfigFacade with ServiceWebFacadeWithDatabase with ServiceFacade[ConfigFacade]
- case class ConfigurationContent(sources: List[SourceContent], pipelines: List[PipelineContent], connections: List[ConnectionContent]) extends Product with Serializable
Wraps collections of connections, sources and pipelines.
- case class ConfigurationInfo(sources: List[SourceInfo], pipelines: List[PipelineInfo], connections: List[ConnectionInfo]) extends Product with Serializable
Holds information from ConfigurationContent, but also includes properties from VersionedEntityInfo.
- case class ConnectionContent(id: String, name: String, description: String, data_raw: Option[ConnectionData]) extends VersionedEntityContentAuth[ConnectionContent] with ConnectionDataProperties with Product with Serializable
- case class ConnectionData(connectionDescription: ConnectionDescription, access: Option[ConfigAccess]) extends ConnectionDataProperties with Product with Serializable
- trait ConnectionDataProperties extends AnyRef
- case class ConnectionDescription(protocol: String, host: String, username: Option[String], password: Option[String]) extends Product with Serializable
- case class ConnectionInfo(version: UUID, deletionTime: Option[LocalDateTime], creationUser: String, content: ConnectionContent, versionDateTime: LocalDateTime) extends VersionedEntityInfo[ConnectionContent] with Product with Serializable
- case class Cpu(systemLoad: Option[Double], systemLastMinAverageLoad: Option[Double], processLoad: Option[Double], cpuSeconds: Option[Double], cores: Option[Int]) extends Product with Serializable
- class CrossEnvironmentResultAccess extends AnyRef
- case class CustomAppContent(id: String, name: String, description: String, data_raw: Option[CustomAppData]) extends VersionedEntityContentAuth[CustomAppContent] with CustomAppDataProperties with Product with Serializable
- case class CustomAppData(head: List[String], body: List[String], script: List[String], style: List[String], bundle: Option[String], access: Option[UserAccess]) extends CustomAppDataProperties with Product with Serializable
- trait CustomAppDataProperties extends AnyRef
- case class CustomAppInfo(version: UUID, versionDateTime: LocalDateTime, creationUser: String, deletionTime: Option[LocalDateTime], content: CustomAppContent) extends VersionedEntityInfo[CustomAppContent] with Product with Serializable
- case class CustomFunctionContent(id: String, name: String, description: String, data_raw: Option[CustomFunctionData]) extends VersionedEntityContentAuth[CustomFunctionContent] with CustomFunctionDataProperties with Product with Serializable
- case class CustomFunctionData(code: List[String], access: Option[ConfigAccess]) extends Product with Serializable
- trait CustomFunctionDataProperties extends AnyRef
- case class CustomFunctionInfo(version: UUID, deletionTime: Option[LocalDateTime], creationUser: String, content: CustomFunctionContent, versionDateTime: LocalDateTime) extends VersionedEntityInfo[CustomFunctionContent] with Product with Serializable
- case class CustomModuleContent(id: String, name: String, description: String, data_raw: Option[CustomModuleData]) extends VersionedEntityContentAuth[CustomModuleContent] with CustomModuleDataProperties with Product with Serializable
- case class CustomModuleData(language: String, code: List[String], imports: List[String], access: Option[ConfigAccess]) extends Product with Serializable
- trait CustomModuleDataProperties extends AnyRef
- case class CustomModuleInfo(version: UUID, deletionTime: Option[LocalDateTime], creationUser: String, content: CustomModuleContent, versionDateTime: LocalDateTime) extends VersionedEntityInfo[CustomModuleContent] with Product with Serializable
- trait CustomServiceFacadeFactory[T <: ServiceFacade[T]] extends AnyRef
- case class CustomTransformContent(id: String, name: String, description: String, data_raw: Option[CustomTransformData]) extends VersionedEntityContentAuth[CustomTransformContent] with CustomTransformDataProperties with Product with Serializable
- case class CustomTransformData(language: String, code: List[String], access: Option[ConfigAccess]) extends Product with Serializable
- trait CustomTransformDataProperties extends AnyRef
- case class CustomTransformInfo(version: UUID, deletionTime: Option[LocalDateTime], creationUser: String, content: CustomTransformContent, versionDateTime: LocalDateTime) extends VersionedEntityInfo[CustomTransformContent] with Product with Serializable
- case class DashboardComponent(id: String, name: String, description: String, query: List[String], step: Option[String], displays: List[DashboardDisplay], sections: List[DashboardComponentSection], filterColumns: List[String], storedFilters: Map[String, DashboardComponentFilter], searchKeys: List[DashboardComponentSearchKey] = List(), defaultFilter: Option[DashboardComponentFilter] = None, enablePreview: Option[Boolean] = None) extends Product with Serializable
- case class DashboardComponentColumn(dashboardId: String, componentId: String, column: String, alias: Option[String]) extends Product with Serializable
Defines a dashboard component column in a search result with an optional alias rename.
- case class DashboardComponentColumnFilter(columnName: String, filterMode: String, min: Option[String], max: Option[String], selected: Option[List[String]]) extends Product with Serializable
- case class DashboardComponentFilter(columnFilters: List[DashboardComponentColumnFilter], combineMode: String, sql: String) extends Product with Serializable
- case class DashboardComponentMetadata(dashboardId: String, componentId: String, columnMetadata: Array[TableColumnMetadataInfo], rowCount: Option[Long]) extends Product with Serializable
Defines a collection of metadata for a dashboard component.
- case class DashboardComponentSearchContent(dashboardId: String, componentId: String, filter: List[DashboardComponentFilter]) extends Product with Serializable
Defines a dashboard component data set in a search result with a list of filters to apply in conjunction.
- case class DashboardComponentSearchKey(name: String, column: String, converter: Option[String]) extends Product with Serializable
- case class DashboardComponentSection(id: String, name: String, position: Int) extends Product with Serializable
- case class DashboardComponentState(dashboardId: String, componentId: String, completion: Double, errors: List[ExceptionChain]) extends Product with Serializable
Summarizes the overall state of a dashboard component across multiple dates.
- case class DashboardContent(id: String, name: String, description: String, data_raw: Option[DashboardData]) extends VersionedEntityContentAuth[DashboardContent] with DashboardDataProperties with WithOptions with Product with Serializable
- case class DashboardContentAndFilters(content: DashboardContent, filters: List[DashboardComponentFilter]) extends Product with Serializable
Wraps a dashboard definition and a list of filters.
- case class DashboardData(options: Map[String, String], timeline: DashboardTimeline, components: List[DashboardComponent], access: Option[UserAccess]) extends DashboardDataProperties with Product with Serializable
- trait DashboardDataProperties extends AnyRef
- case class DashboardDisplay(id: String, name: String, description: String, category: String, select: List[String], groupBy: List[String], filter: Option[DashboardComponentFilter], drillDown: List[String], layout: LayoutParameters, notes: List[DashboardDisplayNote], selectOptions: Map[String, SelectOptions], groupByOptions: Map[String, GroupByOptions], displayOptions: Map[String, String], alerts: List[DashboardDisplayAlert]) extends Product with Serializable
- case class DashboardDisplayAlert(name: String, havingClause: String) extends Product with Serializable
- case class DashboardDisplayContentInfo(dashboardId: String, componentId: String, displayId: String, date: LocalDateTime, schema: List[TableColumn], content: String, tag: String) extends Product with Serializable
Holds information on the persisted data for a specific display on a given dashboard, component and date.
- case class DashboardDisplayNote(creationTime: LocalDateTime, creationUser: String, date: Option[LocalDateTime], subject: String, body: String, dataKey: Option[List[String]] = None) extends Product with Serializable
- case class DashboardDisplaySummary(dashboardId: String, componentId: String, displayId: String, lastUpdated: LocalDateTime) extends Product with Serializable
Holds information on when a display in a dashboard was last updated.
- case class DashboardDisplayTrendsInfo(dashboardId: String, componentId: String, displayId: String, trends: List[TrendGroup]) extends Product with Serializable
Holds information on the trends and outliers a specific display on a given dashboard and component.
- case class DashboardExecutionArgs(dashboardId: String, options: DashboardExecutionOptions) extends Product with Serializable
The dashboard specific information contained in the input to a job execution.
- case class DashboardExecutionOptions(testSample: Option[Int] = None, memoryGb: Option[Int] = None) extends Product with Serializable
The options associated with a job execution for a specific dashboard.
- case class DashboardInfo(version: UUID, deletionTime: Option[LocalDateTime], creationUser: String, content: DashboardContent, versionDateTime: LocalDateTime) extends VersionedEntityInfo[DashboardContent] with Product with Serializable
- case class DashboardStateInfo(dashboardId: String, componentId: String, dashboardVersion: Option[UUID], presentationVersions: List[PresentationVersion], date: LocalDateTime, state: String, metadata: List[TableColumnMetadataInfo], rowCount: Option[Long], errors: List[ExceptionChain], basePath: String, tag: String) extends Product with Serializable
Holds information on the state of output data for a dashboard component on a given date.
- case class DashboardSummary(id: String, timelineStart: Option[LocalDateTime], timelineEnd: Option[LocalDateTime], lastUpdated: Option[LocalDateTime]) extends Product with Serializable
Summarizes update information for a dashboard.
- case class DashboardTimeline(min: Option[LocalDateTime], max: Option[LocalDateTime], step: String, limit: Option[Int], requiredSources: List[String] = List(), requiredPipelines: List[String] = List()) extends Product with Serializable
- case class DataFrameInfo(version: UUID, path: String, isPersisted: Boolean) extends Product with Serializable
- case class DatasolvrAuthenticationException(specificReason: String, context: String = null, cause: Throwable = null, chain: ExceptionChain = null) extends RuntimeException with DatasolvrExceptionBase with Product with Serializable
Defines an error that occured during authentication.
- case class DatasolvrAuthorizationException(specificReason: String, context: String = null, cause: Throwable = null, chain: ExceptionChain = null) extends RuntimeException with DatasolvrExceptionBase with Product with Serializable
Defines an error that was caused by missing authorization.
- case class DatasolvrException(message: String, context: String = null, cause: Throwable = null, chain: ExceptionChain = null) extends RuntimeException with DatasolvrExceptionBase with Product with Serializable
Defines an internal unexpected error in the application.
Defines an internal unexpected error in the application. The exception is used for guard checks (that should never occur) and for wrapping exceptions from external code.
- trait DatasolvrExceptionBase extends AnyRef
- case class DatasolvrNotFoundException(message: String, context: String = null, cause: Throwable = null, chain: ExceptionChain = null) extends RuntimeException with DatasolvrExceptionBase with Product with Serializable
Defines an error caused by a request for a resource that does not exist.
Defines an error caused by a request for a resource that does not exist. The exception is used when asking for non-existing entities in the database or through the web API.
- case class DatasolvrShutdownException(message: String, context: String = null, cause: Throwable = null, chain: ExceptionChain = null) extends RuntimeException with DatasolvrExceptionBase with Product with Serializable
Informs that the system is temporarily unavailable due to a shutdown
- case class DatasolvrUserException(message: String, context: String = null, cause: Throwable = null, chain: ExceptionChain = null) extends RuntimeException with DatasolvrExceptionBase with Product with Serializable
Defines an error caused by a user action (or lack thereof).
Defines an error caused by a user action (or lack thereof). The exception is used for all errors that can (in principle) be fixed by the user. It will often be the message from the first user exception in a chain of exceptions that is displayed in the web client.
- class DelegatingHttpClient extends HttpClient
- case class DisplayEvent(date: LocalDateTime, category: String, groups: List[DisplayEventTrend]) extends Product with Serializable
- case class DisplayEventTrend(group: List[String], unit: String, leftTrend: TimeSeriesTrend, rightTrend: Option[TimeSeriesTrend]) extends Product with Serializable
- case class DisplayFormatHelper(groupFormatter: (List[String]) => List[String], groupElementFormatter: (String, Int) => String, contentFormatter: (String, Int) => String, header: Array[String], display: DashboardDisplay) extends Product with Serializable
- class DisplayOutputHelper extends AnyRef
- class DoubleEvaluator extends AnyRef
An evaluator for a numeric expression.
- case class Email(id: String, attachments: Long, attachmentNames: String, body: String, categories: String, folderName: String, lastModified: LocalDateTime, mailbox: String, sender: String, subject: String, recipient: String, received: LocalDateTime, uniqueBody: String, msgContent: String, emlContent: String) extends Product with Serializable
- case class EmailFilter(inMailboxes: Array[String], inFolder: String, includeSubFolders: Boolean, includeMsgContent: Boolean, includeEmlContent: Boolean, timelineColumn: Option[String], fromDate: Option[LocalDateTime], toDate: Option[LocalDateTime], ids: Array[String], testSample: Option[Int] = None) extends Product with Serializable
- case class EmailMessage(subject: String, body: String, isHtml: Boolean) extends Product with Serializable
Defines the properties required for an email message body.
- case class EmailReceipt(recipient: String, error: Option[ExceptionChain]) extends Product with Serializable
Holds information on the result of an attempt to send an email.
- case class EmailRequest(connection: ExchangeConnection, filter: EmailFilter) extends Product with Serializable
- case class EmlContent(id: String, content: String) extends Product with Serializable
- class Entry[TKey, TValue] extends AnyRef
- trait EnvironmentVariablesLike extends AnyRef
- case class ErrorReport(description: String, error: String, errorInfo: String, cookie: String) extends Product with Serializable
Holds information on an internal error report.
- case class EventLogEntry(date: String, timestamp: String, endpoint: String, serviceId: String, serviceName: String, cpuUsedPercent: Double, memoryUsedPercent: Double, numberOfCores: Int, memoryTotalMb: Int, category: String, context: String, message: String, auditId: String) extends LogEntryBase with Product with Serializable
Holds information on an event log entry.
- class ExcelReader extends AnyRef
A class that helps reading data sheets from Excel workbooks.
- case class ExcelSheetRange(columnStart: Int, columnEnd: Int, rowStart: Int, rowEnd: Option[Int]) extends Product with Serializable
Defines an Excel range in a sheet in a workbook
- class ExcelWriter extends ExcelWriterBase
A class that helps writing data sheets to Excel workbooks.
- abstract class ExcelWriterBase extends AnyRef
A class that helps writing data sheets to Excel workbooks.
- class ExcelWriterInMemory extends ExcelWriterBase
This excel writer is in memory, thus slower than the ExcelWriter, but it supports pivot tables and formula evaluations.
- case class ExceptionChain(state: Map[String, String], content: List[ExceptionContent], environment: Option[String]) extends Product with Serializable
Defines a chain of exceptions that may span multiple services.
Defines a chain of exceptions that may span multiple services. This is used to get the full picture of how an error has been propagated from its source
- state
Information on the ambient state of the service, such as build information and environment variables.
- content
The chain of exceptions that have occurred. The first element in the list is the last one thrown.
- case class ExceptionContent(message: Option[String], exceptionType: String, exceptionClass: String, context: Option[String], stacktrace: String) extends Product with Serializable
- case class ExchangeConnection(exchangeServerLocation: String, user: String, password: String) extends Product with Serializable
- case class ExchangeEmail(to: String, subject: String, body: String, isHtml: Boolean) extends Product with Serializable
- trait Facades extends AnyRef
Has references to most services in Datasolvr
- case class FacadesImpl(application: ApplicationFacade, config: ConfigFacade, scheduler: SchedulerFacade, output: OutputFacade, query: QueryFacade) extends Facades with Product with Serializable
Wraps a collection of service facades in Datasolvr.
- trait FacadesWithRunner extends Facades
Has references to all services in Datasolvr
- case class FieldItem(value: String, name: String, group: String) extends Product with Serializable
- case class FileContent(id: String, tag: String, name: String, description: String, data_raw: Option[FileData]) extends VersionedEntityContentAuth[FileContent] with FileDataProperties with WithOptions with WithTag with Product with Serializable
- case class FileData(options: Map[String, String], storageType: String, contentType: String, body: List[String], access: Option[UserAccess]) extends FileDataProperties with Product with Serializable
- trait FileDataProperties extends AnyRef
- case class FileInfo(version: UUID, deletionTime: Option[LocalDateTime], creationUser: String, content: FileContent, versionDateTime: LocalDateTime) extends VersionedEntityInfo[FileContent] with Product with Serializable
- case class FormatRequest(code: String, language: String) extends Product with Serializable
Holds information on a request for formatting a code snippet.
- case class GroupByOptions(label: Option[String] = None, unit: Option[Double] = None, step: Option[Double] = None) extends Product with Serializable
- case class Heap(initial: Option[Double], max: Option[Double], used: Option[Double], committed: Option[Double]) extends Product with Serializable
- trait HttpClient extends AnyRef
- class HttpClientFactory extends AnyRef
- case class IndexFilterDescription(lowerBound: Int, upperBound: Int, timelineDate: LocalDateTime) extends ResultFilterDescription with Product with Serializable
- class IndexResultFilter extends ResultFilterBase
- case class InlineFunction(id: String, name: Option[String], description: Option[String], code: List[String]) extends Product with Serializable
- case class InlineModule(id: String, name: Option[String], description: Option[String], code: List[String]) extends Product with Serializable
- trait JacksonJsonSerialization extends AnyRef
Trait containing methods for reading and writing JSON given implicit formats.
Trait containing methods for reading and writing JSON given implicit formats. This is used internally for all web service communication.
- class JacksonJsonSerializer extends AnyRef
Class for serializing and deserializing JSON using given formats
- case class JobInfo(host: String, mode: String, id: UUID, state: String, data: SparkArgs, progress: Double, lastModified: LocalDateTime, idDateTime: LocalDateTime, priority: Option[Int], startTime: Option[LocalDateTime], endTime: Option[LocalDateTime]) extends Product with Serializable
Holds information on a job.
Holds information on a job. The job represents a unit of work to be executed by a runner service, and has data on what should be run and what properties are required from the runner.
- trait JsonSerialization extends AnyRef
Trait containing methods for reading and writing JSON given implicit formats.
Trait containing methods for reading and writing JSON given implicit formats. This is used internally for all web service communication.
- case class LayoutParameters(widthFraction: Double, heightToContainerWidth: Double) extends Product with Serializable
- case class LdapEntry(dn: String, attributes: Map[String, List[String]]) extends Product with Serializable
Holds information on an LDAP entry.
- case class LdapQuery(filter: String, attributes: List[String]) extends Product with Serializable
Defines parameter for an LDAP query.
- case class LinkContent(redirect: String, authorization: List[String], groups: List[String], environment: String, expiration: Option[LocalDateTime]) extends Product with Serializable
- case class LinkInfo(id: String, version: UUID, versionDateTime: LocalDateTime, deletionTime: Option[LocalDateTime], creationUser: String, redirect: String, userId: String, expiration: Option[LocalDateTime], environment: String) extends Product with Serializable
- case class LinkLoginResult(token: UUID, userId: String, environment: String, redirect: String) extends Product with Serializable
Holds the result of logging in via a link, and the relative URL the user should be redirected to.
- case class LiveDashboardUpdate(id: String, componentId: String) extends Product with Serializable
- class LocalDateSerializer extends CustomSerializer[LocalDate]
- class LocalDateTimeSerializer extends CustomSerializer[LocalDateTime]
- trait LogEntryBase extends AnyRef
Interface for all log entries.
- trait LoggingLike extends RealTimeAware
Interface for logging
- case class Login(userId: String, password: String) extends Product with Serializable
Holds a set of user credentials.
- case class LoginResult(userId: String, token: UUID, totpSecret: Option[TotpSecret], totpChallenge: Boolean) extends Product with Serializable
Holds a the result of a successful login attempt.
Holds a the result of a successful login attempt. If TOTP is enabled the TOTP secret will be included on first login, and subsequently the user is presented with a TOTP challenge, which must be responded to by calling ApplicationFacade.postLogin with the token as user id and the one-time code as password.
- class LruMap[TKey, TValue] extends LruMapLike[TKey, TValue]
Class defining a map with limited capacity that uses an LRU (least recently used) algorithm for automatic eviction.
Class defining a map with limited capacity that uses an LRU (least recently used) algorithm for automatic eviction. The primary use case is for caches that need to be limited in size while still maintaining good performance. The map is thread safe.
- TKey
The type of the map keys.
- TValue
The type of the map values.
- trait LruMapLike[TKey, TValue] extends BoundedMapLike
- class LruNode[TKey, TValue] extends AnyRef
- class LruTreeMap extends LruMapLike[Seq[Any], TreeOrLeaf]
Class defining a tree map with limited capacity that uses an LRU (least recently used) algorithm for automatic eviction.
Class defining a tree map with limited capacity that uses an LRU (least recently used) algorithm for automatic eviction. The primary use case is for caches that need to be limited in size while still maintaining good performance. The map uses a key structure with a sequence of objects denoting the address of the value on each level in the tree from top to bottom. A prefix of the key may represent a subtree of values. The map is thread safe.
- case class MachineContent(id: String, name: String, description: String, data_raw: Option[MachineData]) extends VersionedEntityContentAuth[MachineContent] with MachineDataProperties with WithOptions with Product with Serializable
- case class MachineData(options: Map[String, String], instanceId: String, instanceType: String, condition: Option[String], configServices: List[ConfigServiceData], schedulerServices: List[SchedulerServiceData], outputServices: List[OutputServiceData], runnerServices: List[RunnerServiceData], queryServices: List[QueryServiceData]) extends MachineDataProperties with Product with Serializable
- trait MachineDataProperties extends AnyRef
- case class MachineInfo(version: UUID, versionDateTime: LocalDateTime, deletionTime: Option[LocalDateTime], creationUser: String, content: MachineContent) extends VersionedEntityInfo[MachineContent] with Product with Serializable
- case class MachineStateInfo(machineId: String, enabled: Boolean, lastStarted: Option[LocalDateTime], lastStopped: Option[LocalDateTime], stopAfter: Option[LocalDateTime], state: String) extends Product with Serializable
Holds information on the current state of a machine.
- case class Memo[K, O](f: (K) => O) extends (K) => O with Product with Serializable
Generic way to create memoized functions (even recursive and multiple-arg ones)
Generic way to create memoized functions (even recursive and multiple-arg ones)
- K
the keys we should use in cache instead of I
- O
output of f
- f
the function to memoize
- case class ModelInputSpecification(sql: String, tag: String, dateFrom: LocalDateTime, dateTo: LocalDateTime) extends Product with Serializable
Defines a specification of input to an ML model
- case class MoveEmail(id: String, sender: String, received: String, fromMailbox: String, toMailbox: String, toFolder: String, systemFolder: String = SystemFolders.inbox) extends Product with Serializable
- case class MoveEmailResult(id: String, moved: Boolean, details: String) extends Product with Serializable
- case class MoveEmailsRequest(connection: ExchangeConnection, moveEmails: Array[MoveEmail], addCategories: Array[String]) extends Product with Serializable
- case class MoveEmailsResponse(results: Array[MoveEmailResult]) extends Product with Serializable
- class OkHttpBaseHttpClient extends BaseHttpClient
- case class OkHttpWebServiceRequest(client: OkHttpClient, url: String, headers: Map[String, String] = Map(), parameters: Map[String, String] = Map(), mediaType: String = "application/json") extends WebServiceRequest with Product with Serializable
- case class OkHttpWebServiceResponseBody(response: Response) extends WebServiceResponseBody with Product with Serializable
- case class OptionDescription(name: String, isMandatory: Boolean, default: Option[String], validation: (String) => Option[String]) extends Product with Serializable
- trait OptionDescriptionBuilder extends AnyRef
- class OptionDescriptions extends AnyRef
- class Options extends RealTimeAware
Convenience class for working with configured options.
- case class OutgoingEmail(audience: UserAudience, message: EmailMessage, from: Option[String] = None) extends Product with Serializable
Defines the properties for an outgoing mail send by the service.
- case class OutlierCluster(id: UUID, likelihood: Double) extends Product with Serializable
Defines a cluster of outliers, which may be seen collectively as a single outlier.
- case class OutputAccess(repository: String, configId: String, tag: String, result: String, part: Option[Int]) extends Product with Serializable
- trait OutputFacade extends ServiceFacadeWithDatabase with ServiceFacade[OutputFacade]
The interface for the external API of the Output Service.
The interface for the external API of the Output Service.
The Output Service is responsible for the management of output data and metadata from runs of sources, pipelines and batches. It creates point-in-time snapshots of the configuration which are used to maintain a complete revision history knowing exactly which other data sets a given data set depends on, and which version of the configuration was used to build them.
- class OutputFormatter extends AnyRef
- case class OutputServiceData(options: Map[String, String], name: String, port: Option[Int], memoryLimit: String, sparkCores: String, sparkUIPort: Option[Int], extraJars: List[String]) extends SparkServiceData with Product with Serializable
- class OutputWebFacade extends OutputFacade with ServiceWebFacadeWithDatabase with ServiceFacade[OutputFacade]
- case class PageLink(text: String, address: String) extends Product with Serializable
- case class PerformanceMetrics(cpu: Cpu, systemMemory: SystemMemory, heap: Heap) extends Product with Serializable
- case class PipelineCheckpoint(transform: String, parallelPart: Option[Int], reusable: Boolean = true) extends Product with Serializable
Holds the checkpoint information for transforms in a pipeline snapshot
- case class PipelineContent(id: String, tag: String, name: String, description: String, data_raw: Option[PipelineData]) extends VersionedEntityContentAuth[PipelineContent] with PipelineDataProperties with WithOptions with WithTag with Product with Serializable
- case class PipelineContentAndSnapshots(content: PipelineContent, sourceSnapshots: List[SourceSnapshotInfo], pipelineSnapshots: List[PipelineSnapshotInfo]) extends Product with Serializable
Wraps a pipeline definition with collections of source and pipeline snapshots
- case class PipelineData(options: Map[String, String], resultType: String, sourceImports: List[PipelineSourceImport], timelines: List[TimelineDescription], functions: List[InlineFunction], modules: List[InlineModule], transforms: List[PipelineTransform], access: Option[ConfigAccess]) extends PipelineDataProperties with Product with Serializable
- trait PipelineDataProperties extends AnyRef
- case class PipelineElement(id: String, includePredecessors: Boolean, includeSuccessors: Boolean) extends Product with Serializable
- case class PipelineExecutionArgs(pipelineId: String, pipelineSnapshotId: UUID, options: PipelineExecutionOptions) extends Product with Serializable
The pipeline specific information contained in the input to a job execution.
- case class PipelineExecutionOptions(testSample: Option[Int] = None, liveDate: Option[LocalDateTime] = None, requireLocal: Boolean = false, memoryGb: Option[Int] = None, parallelPart: Option[Int] = None) extends Product with Serializable
The options associated with a job execution for a specific pipeline.
- case class PipelineInfo(version: UUID, deletionTime: Option[LocalDateTime], creationUser: String, content: PipelineContent, versionDateTime: LocalDateTime) extends VersionedEntityInfo[PipelineContent] with Product with Serializable
- case class PipelineKey(id: String, tag: String) extends Product with Serializable
Defines a pipeline data identifier
- case class PipelineSnapshotInfo(version: UUID, versionDateTime: LocalDateTime, isPersisted: Boolean, lastModified: LocalDateTime, creationUser: String, sourceSnapshotVersions: List[SourceSnapshotVersion], transformSnapshotVersions: List[TransformSnapshotVersion], pluginVersions: List[PluginVersion], configId: String, configVersion: UUID, tag: String, outputTransformIds: List[String], expires: Option[LocalDateTime], checkpoints: List[PipelineCheckpoint] = List(), deletedColumns: List[ColumnDeletion] = List(), dataVersion: Option[Int] = None, sizeBytes: Option[Long] = None) extends SnapshotInfoBase with Product with Serializable
Holds information on a pipeline snapshot.
Holds information on a pipeline snapshot. A pipeline snapshot has data on the timestamp, tag, configuration versions and other snapshots used for building the result data and whether result data is persisted. It also logs which user created the snapshot and when the snapshot may expire (after which it will eventually be deleted). Additionally it has information on which transforms has a result data set and whether they can used as checkpoints.
- case class PipelineSourceImport(localId: String, sourceId: Option[String], pipelineId: Option[String], transformId: Option[String], timelineId: Option[String]) extends Product with Serializable
- case class PipelineTransform(id: String, name: Option[String], description: Option[String], parentIds: List[String], transformType: String, dataTransform: List[String], options: Map[String, String]) extends WithOptions with Product with Serializable
- case class PluginVersion(pluginId: String, pluginType: String, version: UUID) extends Product with Serializable
Holds information on a plugin version used in a pipeline snapshot.
- case class PluginsContent(customFunctions: List[CustomFunctionContent], customTransforms: List[CustomTransformContent], customModules: List[CustomModuleContent]) extends Product with Serializable
Wraps collections of custom functions, transforms and modules.
- case class PluginsInfo(customFunctions: List[CustomFunctionInfo], customTransforms: List[CustomTransformInfo], customModules: List[CustomModuleInfo]) extends Product with Serializable
Holds information from PluginsContent, but also includes properties from VersionedEntityInfo.
- case class PointEvent(date: LocalDateTime, category: String, groups: List[String], unit: String, leftTrend: TimeSeriesTrend, rightTrend: Option[TimeSeriesTrend]) extends Product with Serializable
- case class PresentationContent(id: String, name: String, description: String, data_raw: Option[PresentationData]) extends VersionedEntityContentAuth[PresentationContent] with PresentationDataProperties with WithOptions with Product with Serializable
- case class PresentationData(options: Map[String, String], timeline: DashboardTimeline, pages: List[PresentationPage], access: Option[UserAccess]) extends PresentationDataProperties with Product with Serializable
- trait PresentationDataProperties extends AnyRef
- case class PresentationDisplay(display: DashboardDisplay, dashboardId: String, componentId: String, periods: Int, offset: Int, step: String, options: Map[String, String]) extends Product with Serializable
- case class PresentationInfo(version: UUID, deletionTime: Option[LocalDateTime], creationUser: String, content: PresentationContent, versionDateTime: LocalDateTime) extends VersionedEntityInfo[PresentationContent] with Product with Serializable
- case class PresentationPage(id: String, name: String, displays: List[PresentationDisplay]) extends Product with Serializable
- case class PresentationSummary(id: String, timelineStart: Option[LocalDateTime], timelineEnd: Option[LocalDateTime], lastUpdated: Option[LocalDateTime]) extends Product with Serializable
Summarizes update information for a presentation.
- case class PresentationVersion(id: String, version: UUID) extends Product with Serializable
Defines a specific version of a presentation.
- case class Quantile(probability: Double, value: Double) extends Product with Serializable
- trait QueryFacade extends ServiceFacadeWithDatabase with ServiceFacade[QueryFacade]
The interface for the external API of the Query Service.
The interface for the external API of the Query Service.
The Query Service is responsible for the management of configuration related to dashboards and presentations, and it also handles live queries against source and pipeline result data, whether previewing unsaved changes to a dashboard or presentation, or submitting a SQL request.
- case class QueryRefreshContent(addPipelineSnapshots: List[PipelineSnapshotInfo] = List(), removePipelineSnapshots: List[PipelineSnapshotInfo] = List(), addSourceSnapshots: List[SourceSnapshotInfo] = List(), removeSourceSnapshots: List[SourceSnapshotInfo] = List(), addCustomFunctions: List[CustomFunctionContent] = List(), addInMemoryPipelines: List[PipelineContent] = List(), updateLiveDashboards: List[LiveDashboardUpdate] = List()) extends Product with Serializable
Holds information on changes that may trigger an update of a dashboard state.
- case class QueryServiceData(options: Map[String, String], name: String, port: Option[Int], memoryLimit: String, sparkCores: String, sparkUIPort: Option[Int], extraJars: List[String]) extends SparkServiceData with Product with Serializable
- class QueryWebFacade extends QueryFacade with ServiceWebFacadeWithDatabase with ServiceFacade[QueryFacade]
- trait RealTimeAware extends AnyRef
Trait containing methods for accessing information on the real system time
- case class RegistryAccess(view: Option[UserAccess], create: Option[UserAccess], modify: Option[UserAccess], delete: Option[UserAccess]) extends Product with Serializable
- case class RegistryContent(id: String, name: String, description: String, data_raw: Option[RegistryData]) extends VersionedEntityContentAuth[RegistryContent] with RegistryDataProperties with WithOptions with Product with Serializable
- case class RegistryContentAndData(content: RegistryContent, data: String) extends Product with Serializable
Wraps a registry definition and entity data.
- case class RegistryData(options: Map[String, String], schema: String, access: RegistryAccess) extends RegistryDataProperties with Product with Serializable
- trait RegistryDataProperties extends AnyRef
- case class RegistryEntityContent(id: String, name: String, description: String, data_raw: Option[RegistryEntityData]) extends VersionedEntityContentAuth[RegistryEntityContent] with RegistryEntityDataProperties with Product with Serializable
- case class RegistryEntityData(options: Map[String, String], entityData: String, registryId: String, access: Option[UserAccess]) extends RegistryEntityDataProperties with Product with Serializable
- trait RegistryEntityDataProperties extends AnyRef
- case class RegistryEntityInfo(version: UUID, deletionTime: Option[LocalDateTime], creationUser: String, content: RegistryEntityContent, versionDateTime: LocalDateTime) extends VersionedEntityInfo[RegistryEntityContent] with Product with Serializable
- case class RegistryInfo(version: UUID, deletionTime: Option[LocalDateTime], creationUser: String, content: RegistryContent, versionDateTime: LocalDateTime) extends VersionedEntityInfo[RegistryContent] with Product with Serializable
- trait RequiredActions[TFacade <: ServiceFacadeBase] extends AnyRef
- trait RequiredDataActions[TFacade <: ServiceFacadeBase] extends RequiredActions[TFacade]
- trait ResultFilter extends AnyRef
- abstract class ResultFilterBase extends ResultFilter
- trait ResultFilterDescription extends AnyRef
- case class ResultKeys(sources: Seq[SourceKey], transforms: Seq[TransformKey], tag: String) extends Product with Serializable
Holds a collection of result identifiers for sources and pipeline transforms.
- case class RunOffset(timelineOffsetPeriods: Int, unit: String) extends Product with Serializable
- trait RunnerFacade extends ServiceFacade[RunnerFacade]
The interface for the external API of the Runner Service.
The interface for the external API of the Runner Service.
The Runner Service is responsible for executing jobs to compute source and pipeline output or updating dashboards. It also provides functionality to assist the development process such as test execution of source and pipeline definitions, compilation checks and intellisense support.
- case class RunnerInfo(name: String, category: String, modes: List[String], memoryGb: Int, minMemoryLevel: Int, state: String, instanceId: Option[String] = None) extends Product with Serializable
Holds information on a registered runner service
- case class RunnerServiceData(options: Map[String, String], name: String, port: Option[Int], memoryLimit: String, sparkCores: String, sparkUIPort: Option[Int], schedulers: String, extraJars: List[String]) extends SparkServiceData with Product with Serializable
- class RunnerWebFacade extends RunnerFacade with ServiceWebFacade
- case class ScalingDescription(minCapacity: Int, maxCapacity: Int, scaleOutMinInterval: Int, scaleInMinInterval: Int, scaleOutMaxStep: Option[Int] = None, scaleInMaxStep: Option[Int] = None, scaleOutDelay: Option[Int] = None, scaleInDelay: Option[Int] = None) extends Product with Serializable
- case class ScheduleContent(id: String, name: String, description: String, data_raw: Option[ScheduleData]) extends VersionedEntityContentAuth[ScheduleContent] with ScheduleDataProperties with WithOptions with Product with Serializable
- case class ScheduleData(options: Map[String, String], batchId: String, startDate: LocalDateTime, endDate: Option[LocalDateTime], timelineFrequency: TimelineFrequency, runFrequency: RunOffset) extends ScheduleDataProperties with Product with Serializable
- trait ScheduleDataProperties extends AnyRef
- case class ScheduleInfo(version: UUID, deletionTime: Option[LocalDateTime], creationUser: String, content: ScheduleContent, versionDateTime: LocalDateTime) extends VersionedEntityInfo[ScheduleContent] with Product with Serializable
- case class ScheduleStateInfo(scheduleId: String, enabled: Boolean, lastActive: Option[LocalDateTime], state: String, progress: Double) extends Product with Serializable
Holds information on the state of a schedule.
Holds information on the state of a schedule. The schedule state has data on the activity and collective state and progress of the jobs that the schedule is responsible for.
- trait SchedulerFacade extends ServiceFacadeWithDatabase with ServiceFacade[SchedulerFacade]
The interface for the external API of the Scheduler Service.
The interface for the external API of the Scheduler Service.
The Scheduler Service is responsible for the management of configuration related to execution and scheduling of sources and pipelines, as well as scripts and wizards for task automation. It handles both automated and manual job scheduling, and monitors the state of jobs until completion.
- case class SchedulerServiceData(options: Map[String, String], name: String, memoryLimit: String, port: Option[Int]) extends ServiceData with Product with Serializable
- class SchedulerWebFacade extends SchedulerFacade with ServiceWebFacadeWithDatabase with ServiceFacade[SchedulerFacade]
- case class ScriptContent(id: String, name: String, description: String, data_raw: Option[ScriptData]) extends VersionedEntityContentAuth[ScriptContent] with ScriptDataProperties with WithOptions with Product with Serializable
- case class ScriptContentAndBody(content: ScriptContent, body: String) extends Product with Serializable
Wraps a script definition and a body of input for a script execution.
- case class ScriptData(options: Map[String, String], script: List[String], access: Option[UserAccess]) extends ScriptDataProperties with Product with Serializable
- trait ScriptDataProperties extends AnyRef
- case class ScriptInfo(version: UUID, versionDateTime: LocalDateTime, creationUser: String, deletionTime: Option[LocalDateTime], content: ScriptContent) extends VersionedEntityInfo[ScriptContent] with Product with Serializable
- case class ScriptParameters(values: Option[Map[String, String]]) extends Product with Serializable
Wraps a map of input parameters for a script execution.
- case class ScriptResults(response: Option[String], values: Option[Map[String, String]]) extends Product with Serializable
Wraps the map of results for a script execution.
- case class SearchContent(key: String, required: List[DashboardComponentSearchContent], optional: List[DashboardComponentSearchContent], output: List[DashboardComponentColumn]) extends Product with Serializable
Defines a search specification.
Defines a search specification.
- key
The DashboardComponentSearchKey.name which is used for joining data.
- required
The component data sets that are required in the search result (inner join).
- optional
The component data sets that are optional in the search result (left join).
- output
The component columns to include in the search result.
- case class SelectOptions(label: Option[String] = None, unit: Option[Double] = None, decimals: Option[Int] = None) extends Product with Serializable
- case class SendEmailRequest(connection: ExchangeConnection, mail: ExchangeEmail) extends Product with Serializable
- case class SendEmailResult(sent: Boolean, details: String) extends Product with Serializable
- trait ServiceData extends AnyRef
- case class ServiceEnvironmentContent(id: String, name: String, description: String, data_raw: Option[ServiceEnvironmentData]) extends VersionedEntityContentAuth[ServiceEnvironmentContent] with ServiceEnvironmentDataProperties with Product with Serializable
- case class ServiceEnvironmentData(options: Map[String, String], state: String, services: Map[String, String], customServices: Map[String, String]) extends ServiceEnvironmentDataProperties with Product with Serializable
- trait ServiceEnvironmentDataProperties extends AnyRef
- case class ServiceEnvironmentInfo(version: UUID, versionDateTime: LocalDateTime, deletionTime: Option[LocalDateTime], creationUser: String, content: ServiceEnvironmentContent) extends VersionedEntityInfo[ServiceEnvironmentContent] with Product with Serializable
- trait ServiceFacade[TService <: ServiceFacadeBase] extends ServiceFacadeBase
- trait ServiceFacadeBase extends AnyRef
- class ServiceFacadeEnvironment extends RealTimeAware
- trait ServiceFacadeFactory extends AnyRef
- case class ServiceFacadeSettings(connectAttempts: Int = EnvironmentVariables.web_service_connect_attempts, timeoutSeconds: Int = EnvironmentVariables.web_service_timeout) extends Product with Serializable
- trait ServiceFacadeWithDatabase extends ServiceFacadeBase
- case class ServiceLocationInfo(id: String, name: String, buildInfo: BuildLabels, hostname: String, port: Int, lastHeartbeat: LocalDateTime, startTime: LocalDateTime, environments: Set[String]) extends Product with Serializable
- case class ServiceUserActivity(userId: String, lastLogin: LocalDateTime, lastAction: LocalDateTime) extends Product with Serializable
Holds data on the most recent activity of a user.
- case class ServiceUserContent(id: String, name: String, description: String, data_raw: Option[ServiceUserData]) extends VersionedEntityContentAuth[ServiceUserContent] with ServiceUserDataProperties with WithOptions with Product with Serializable
- case class ServiceUserData(options: Map[String, String], authorization: Map[String, List[String]], groups: List[String], tags: Option[List[String]], hash: String, email: String) extends ServiceUserDataProperties with Product with Serializable
- trait ServiceUserDataProperties extends AnyRef
- case class ServiceUserGroupContent(id: String, name: String, description: String, data_raw: Option[ServiceUserGroupData]) extends VersionedEntityContentAuth[ServiceUserGroupContent] with ServiceUserGroupDataProperties with WithOptions with Product with Serializable
- case class ServiceUserGroupData(options: Map[String, String], authorization: Map[String, List[String]], tags: Option[List[String]]) extends ServiceUserGroupDataProperties with Product with Serializable
- trait ServiceUserGroupDataProperties extends AnyRef
- case class ServiceUserGroupInfo(version: UUID, versionDateTime: LocalDateTime, deletionTime: Option[LocalDateTime], creationUser: String, content: ServiceUserGroupContent) extends VersionedEntityInfo[ServiceUserGroupContent] with Product with Serializable
- case class ServiceUserInfo extends VersionedEntityInfo[ServiceUserContent] with Product with Serializable
- trait ServiceWebFacade extends ServiceFacadeBase
- class ServiceWebFacadeFactory extends ServiceFacadeFactory
- trait ServiceWebFacadeWithDatabase extends ServiceWebFacade
- case class SnapshotId(id: String, version: UUID, tag: Option[String]) extends Product with Serializable
Identifies a specific source or pipeline snapshot
- trait SnapshotInfoBase extends AnyRef
Base properties for source and pipeline snapshots
- case class SnapshotNode(snapshotId: SnapshotId, predecessors: List[SnapshotId]) extends Product with Serializable
Identifies a specific snapshot which depends on other snapshots
- case class SourceContent(id: String, tag: String, name: String, description: String, data_raw: Option[SourceData]) extends VersionedEntityContentAuth[SourceContent] with SourceDataProperties with WithOptions with WithTag with Product with Serializable
- case class SourceData(options: Map[String, String], sourceDescription: SourceDescription, dataDescription: SourceDataDescription, access: Option[ConfigAccess]) extends SourceDataProperties with Product with Serializable
- case class SourceDataDescription(defaultNumberLocale: Option[String], defaultDateFormat: Option[String], columns: List[SourceDataDescriptionColumn]) extends Product with Serializable
- case class SourceDataDescriptionColumn(name: String, datatype: String, importName: Option[String], numberLocale: Option[String], dateFormat: Option[String]) extends Product with Serializable
- trait SourceDataProperties extends AnyRef
- case class SourceDescription(connection: String, sourceType: String, sourceRepository: String, sourceObject: String) extends Product with Serializable
- case class SourceDescriptionAndOptions(description: SourceDescription, options: Map[String, String], tag: String = Tags.empty) extends Product with Serializable
Wraps a source description, source options and the tag.
- case class SourceElement(id: String, includeSuccessors: Boolean) extends Product with Serializable
- case class SourceExecutionArgs(sourceId: String, sourceSnapshotId: UUID, options: SourceExecutionOptions) extends Product with Serializable
The source specific information contained in the input to a job execution.
- case class SourceExecutionOptions(testSample: Option[Int] = None, liveDate: Option[LocalDateTime] = None, memoryGb: Option[Int] = None) extends Product with Serializable
The options associated with a job execution for a specific source.
- case class SourceInfo(version: UUID, deletionTime: Option[LocalDateTime], creationUser: String, content: SourceContent, versionDateTime: LocalDateTime) extends VersionedEntityInfo[SourceContent] with Product with Serializable
- case class SourceKey(id: String, tag: String) extends Product with Serializable
Defines a source data identifier
- case class SourceSnapshotInfo(version: UUID, versionDateTime: LocalDateTime, isPersisted: Boolean, lastModified: LocalDateTime, creationUser: String, configId: String, configVersion: UUID, tag: String, pluginVersions: List[PluginVersion], expires: Option[LocalDateTime], deletedColumns: List[ColumnDeletion] = List(), dataVersion: Option[Int] = None, sizeBytes: Option[Long] = None) extends SnapshotInfoBase with Product with Serializable
Holds information on a source snapshot.
Holds information on a source snapshot. A source snapshot has data on the timestamp, tag and configuration version used for building the result data and whether result data is persisted. It also logs which user created the snapshot and when the snapshot may expire (after which it will eventually be deleted).
- case class SourceSnapshotVersion(sourceId: String, localId: String, version: UUID, versionDateTime: LocalDateTime, tag: Option[String]) extends Product with Serializable
Holds information on a source snapshot used by a pipeline snapshot.
- case class SparkApplicationMetrics(id: String, name: String) extends Product with Serializable
- case class SparkArgs(sourceArgs: Option[SourceExecutionArgs], pipelineArgs: Option[PipelineExecutionArgs], dashboardArgs: Option[DashboardExecutionArgs]) extends Product with Serializable
The parts of the input to a job execution that are specific to either a source, a pipeline or a dashboard.
- case class SparkJobLog(log: String, error: Option[ExceptionChain]) extends Product with Serializable
Wraps the log and error information for a job.
- case class SparkJobMetrics(jobId: Int, numTasks: Int, numActiveTasks: Int, numCompletedTasks: Int, numSkippedTasks: Int, numFailedTasks: Int, numKilledTasks: Int, status: String, jobGroup: Option[String]) extends Product with Serializable
- trait SparkMetricsFacade extends AnyRef
- class SparkMetricsWebFacade extends SparkMetricsFacade
- trait SparkServiceData extends ServiceData
- case class StateItem(id: String, values: Map[String, String], items: List[StateItem]) extends Product with Serializable
- case class SystemMemory(totalPhysical: Option[Double], totalSwap: Option[Double], committedVirtual: Option[Double], freePhysical: Option[Double], freeSwap: Option[Double]) extends Product with Serializable
- case class TableColumn(columnName: String, columnType: String) extends Product with Serializable
Holds the name and type of a column.
- case class TableColumnMetadataInfo(column: TableColumn, min: Option[Double], max: Option[Double], values: Option[List[String]], quantiles: Option[List[Quantile]]) extends Product with Serializable
- case class TableMetadataInfo(tableId: String, tableColumns: List[TableColumn]) extends Product with Serializable
Holds information on the column metadata for data set.
- case class TestConnectionRequest(connection: ExchangeConnection, mailboxes: Array[String]) extends Product with Serializable
- case class TestExecutionInfo(log: String, artifacts: Map[String, String], cacheable: Boolean = true) extends Product with Serializable
Holds information on a completed test result for a specific transform in a pipeline.
- case class TestResult(output: Map[String, String], info: Map[String, TestExecutionInfo], error: Option[ExceptionChain]) extends Product with Serializable
Holds information on a completed test result for a pipeline.
- case class TestResultOutput(transformId: String, dataTableContent: String, log: String, artifacts: Map[String, String], error: Option[ExceptionChain]) extends Product with Serializable
Wraps information on the test result output of a transform in a pipeline.
- case class TestResultRequest(pipelineId: String, tag: String, excludeTransformIds: List[String]) extends Product with Serializable
Wraps information on the request to fetch test results for a pipeline.
- case class TestSessionKey(pipelineId: String, pipelineTag: String, date: LocalDateTime, sampleSize: Option[Int]) extends Product with Serializable
The key used to uniquely identify test sessions.
- case class TimeSeriesOutlier(date: LocalDateTime, value: Double, likelihood: Double, cluster: Option[OutlierCluster] = None) extends Product with Serializable
Defines an outlier in a trend, optionally as part of a cluster of outliers.
- case class TimeSeriesTrend(start: LocalDateTime, end: LocalDateTime, unit: String, rate: Double, offset: Double, sigma: Double, period: Option[String], outliers: List[TimeSeriesOutlier]) extends Product with Serializable
Defines a linear time series trend with outliers and periodicity relative to another trend on a larger scale.
- case class Timeline(id: String, lowerBound: LocalDateTime, upperBound: LocalDateTime, filterStream: Boolean) extends Product with Serializable
- case class TimelineDescription(id: String, lowerBound: String, upperBound: String) extends Product with Serializable
- case class TimelineFilterDescription(lowerBound: LocalDateTime, upperBound: LocalDateTime) extends ResultFilterDescription with Product with Serializable
- case class TimelineFrequency(intervalPeriods: Int, unit: String) extends Product with Serializable
- class TimelineResultFilter extends ResultFilterBase
- case class TitleWithOptions(title: String, options: Set[String]) extends Product with Serializable
- case class TotpSecret(secret: String, qrDataUri: String) extends Product with Serializable
Holds information on a TOTP secret including a QR code for easy display.
- case class TransformKey(pipeline: PipelineKey, transformId: String) extends Product with Serializable
Defines a pipeline transform data identifier
- case class TransformSnapshotVersion(pipelineId: String, transformId: String, localId: String, version: UUID, versionDateTime: LocalDateTime, tag: Option[String]) extends Product with Serializable
Holds information on a transform in a pipeline snapshot used by another pipeline snapshot.
- case class TransformTestResultStatus(transform: String, status: String) extends Product with Serializable
Wraps information on the test result status of a transform in a pipeline.
- case class TreeOrLeaf(tree: Option[LruTreeMap], leaf: Option[Any]) extends Product with Serializable
- case class TrendGroup(group: List[String], trends: List[TimeSeriesTrend]) extends Product with Serializable
Defines a group of trends.
- class UUIDSerializer extends CustomSerializer[UUID]
- case class UserAccess(groups: List[String], users: List[String]) extends Product with Serializable
- case class UserAudience(users: List[String] = List(), groups: List[String] = List()) extends Product with Serializable
Defines a collection of users and groups.
- case class ValidityRange(validityBegin: Option[LocalDateTime], validityEnd: Option[LocalDateTime]) extends Product with Serializable
- trait VersionedEntityContent extends AnyRef
- trait VersionedEntityContentAuth[TEntityContent] extends VersionedEntityContent
- trait VersionedEntityInfo[TContent <: VersionedEntityContent] extends AnyRef
- case class WebServiceException(message: String, chain: ExceptionChain) extends RuntimeException with Product with Serializable
Defines an error that occured during a web service call.
- trait WebServiceRequest extends AnyRef
- case class WebServiceResponse(status: Int, body: WebServiceResponseBody, headers: Map[String, Seq[String]]) extends Product with Serializable
- trait WebServiceResponseBody extends AnyRef
- trait WindowsFacade extends ServiceFacade[WindowsFacade]
- class WindowsWebFacade extends WindowsFacade with ServiceWebFacade
- trait WithOptions extends AnyRef
Interface for an entity that includes an options map.
- trait WithTag extends AnyRef
An interface for entities that uses tags to create multiple valid versions for a specific id.
- case class WizardAction(id: UUID, actionType: String, input: Option[Map[String, String]] = None, executeStage: Option[WizardExecutionStage] = None) extends Product with Serializable
- case class WizardContent(id: String, name: String, description: String, data_raw: Option[WizardData]) extends VersionedEntityContentAuth[WizardContent] with WizardDataProperties with WithOptions with Product with Serializable
- case class WizardData(options: Map[String, String], script: List[String], access: Option[UserAccess]) extends WizardDataProperties with Product with Serializable
- trait WizardDataProperties extends AnyRef
- case class WizardExecutionStage(pageNumber: Int, stage: String) extends Product with Serializable
- case class WizardField(id: String, title: String, hint: String, instructions: String, value: String, isRequired: Boolean, selector: Option[WizardFieldSelector], isFile: Boolean = false, lines: Int = 0, isDate: Boolean = false) extends Product with Serializable
- case class WizardFieldSelector(isMultiSelect: Boolean, values: List[FieldItem]) extends Product with Serializable
- case class WizardFields(id: String, version: UUID, title: String, description: String, numberOfPages: Int) extends Product with Serializable
- case class WizardInfo(version: UUID, versionDateTime: LocalDateTime, creationUser: String, deletionTime: Option[LocalDateTime], content: WizardContent) extends VersionedEntityInfo[WizardContent] with Product with Serializable
- case class WizardLogMessage(timestamp: LocalDateTime, page: Int, message: String) extends Product with Serializable
- case class WizardPage(pageNumber: Int, title: String, paragraphs: List[String], fields: List[WizardField], links: List[PageLink]) extends Product with Serializable
- case class WizardSessionContent(fields: WizardFields, pages: List[WizardPage], stages: List[WizardStage], logMessages: List[WizardLogMessage]) extends Product with Serializable
- case class WizardSessionExecution(lastExecutedStage: WizardExecutionStage, exceptionChain: Option[ExceptionChain]) extends Product with Serializable
- case class WizardSessionInfo(id: UUID, name: String, creationTime: LocalDateTime, creationUser: String, wizardId: String, wizardVersion: UUID, lastModified: LocalDateTime, lastModifiedBy: String, state: String, progress: Option[Int], execution: WizardSessionExecution, content: WizardSessionContent) extends Product with Serializable
- case class WizardStage(id: WizardStageId, state: WizardState) extends Product with Serializable
- case class WizardStageId(page: Int, stageType: String) extends Product with Serializable
- case class WizardState(userInput: Map[String, String], item: StateItem) extends Product with Serializable
Value Members
- object ApplicationFacade
- object Authorization
An object providing access to al authorization labels.
- object AuthorizationInfo extends Serializable
- object BaseHttpClientFactory
- object BatchContent extends Serializable
- object BatchOptions extends OptionDescriptionBuilder
Defines the options that can be used on a batch.
- object BuildLabels extends Serializable
- object BuiltInFunctions
The SQL functions that are available as standard in addition to ones included in Apache Spark.
- object BuiltInTransforms
The values below are referenced in customer transforms as well as in the documentation.
The values below are referenced in customer transforms as well as in the documentation. They should not be changed.
- case object CaseClassHelper extends Product with Serializable
- object ClusterContent extends Serializable
- object ClusterOptions extends OptionDescriptionBuilder
Defines the options that can be used on a cluster.
- object CodeLanguage extends Enumeration
The programming languages supported for compilation checks and auto-completion.
- object CodecHelpers
- object CollectionPipelineOptions extends OptionDescriptionBuilder
Defines the options that can be used on a pipeline of collection type.
- object CollectionSourceOptions extends OptionDescriptionBuilder
Defines the options that can be used on a source of collection type.
- object ColumnDataTypes
- object ConfigHelper
- object ConfigParameterContent extends Serializable
- object ConnectionContent extends Serializable
- object ConnectionProtocols
- object ConsoleLogging extends LoggingLike with RealTimeAware
- object CsvHandler
Utility class for handling CSV content
- object CustomAppContent extends Serializable
- object CustomFunctionContent extends Serializable
- object CustomModuleContent extends Serializable
- object CustomModuleLanguages
- object CustomTransformContent extends Serializable
- object CustomTransformLanguages
- object DashboardComponent extends Serializable
- object DashboardComponentFilter extends Serializable
- object DashboardContent extends Serializable
- object DashboardDisplayCategory
- object DashboardDisplayOptions extends OptionDescriptionBuilder
- object DashboardDisplayTrendsHelper
- object DashboardOptions extends OptionDescriptionBuilder
Defines the options that can be used on a dashboard.
- object DashboardTimeOfDay
Represents either start-of-day (e.g.
Represents either start-of-day (e.g. 2021-08-01 00:00) or end-of-day (e.g. 2021-07-31 23:59).
- object DashboardTimelineStep
- object DatasolvrAuthorizationException extends Serializable
- object DateTimeSupport
Utility class for handling date and time
- object DisplaySuggestions
- object DoubleHelpers
- object EnvironmentStates
- object EnvironmentUtils
- object EnvironmentVariables extends EnvironmentVariablesLike
- object EnvironmentVariablesLike
- object EventCategories
- object ExcelExtensions
- object ExceptionChain extends Serializable
- object ExceptionTypes
A categorization of exceptions.
- object FieldItem extends Serializable
- object FileContent extends Serializable
- object FileContentTypes
- object FileOptions extends OptionDescriptionBuilder
Defines the options that can be used on a file.
- object FileStorageTypes
- object FilterCombineModes
- object FilterModes
- object FrequencyUnit
- object FutureHelpers
- object GeneralPipelineOptions extends OptionDescriptionBuilder
Defines the options that can be used on any pipeline.
- object GeneralResultOptions extends OptionDescriptionBuilder
Defines the options that can be used on any source or pipeline.
- object GeneralSourceOptions extends OptionDescriptionBuilder
Defines the options that can be used on any source.
- object HtmlHelper
- object HttpMethods
- object HttpStatusCodes
- object IndexFilterEvaluator
- object JacksonJsonHandler extends JacksonJsonSerializer
Object providing support for parsing and writing JSON.
- object JobStates
The possible states for a job.
- object JsonFormats
Object providing default JSON formats.
- object JsonHandler extends JsonSerialization
Object providing support for parsing and writing JSON.
- object LayoutParameters extends Serializable
- object LiveAggregationMode
The possible options for aggregation of volatile results.
- object LocalDateSerializer
- object LocalDateTimeSerializer
- object LogEntryBase
- object LogEventCategories
- object LoggingLike
- object LruCacheManager
- object MachineContent extends Serializable
- object MachineOptions extends OptionDescriptionBuilder
Defines the options that can be used on a machine.
- object Memo extends Serializable
- object OkHttpBaseHttpClient
- object OutputAccess extends Serializable
- object OutputFacade
- object ParallelHelper
- object PipelineContent extends Serializable
- object PluginType extends Enumeration
The plugin types supported for compilation checks and auto-completion.
- object PluginTypes
A categorization of plugin types
- object PresentationContent extends Serializable
- object PresentationDisplayOptions extends OptionDescriptionBuilder
- object PresentationOptions extends OptionDescriptionBuilder
Defines the options that can be used on a presentation.
- object QueryFacade
- object RealTimeHandling extends RealTimeAware
- object RegistryContent extends Serializable
- object RegistryEntityContent extends Serializable
- object RegistryOptions extends OptionDescriptionBuilder
Defines the options that can be used on a registry.
- object RequiredActions
- object ResourceManager
Manages code resources for a service at runtime.
- object ResultFilterFactory
- object ResultFilterParser
- object ResultFilterTypes
- object ResultKeys extends Serializable
Helper to build result keys from identifiers.
- object ResultTypes
- object RunnerCategories
A categorization of runner services, based on their Apache Spark usage.
- object RunnerModes
The possible modes that a runner service may allow.
- object RunnerStates
The possible states of a runner service.
- object ScheduleContent extends Serializable
- object ScheduleOptions extends OptionDescriptionBuilder
Defines the options that can be used on a schedule.
- object SchedulerFacade
- object ScriptContent extends Serializable
- object ScriptOptions extends OptionDescriptionBuilder
Defines the options that can be used in a script.
- object ServiceEnvironmentContent extends Serializable
- object ServiceFacade
- object ServiceLifeCycle extends RealTimeAware
- object ServiceUserContent extends Serializable
- object ServiceUserGroupContent extends Serializable
- object ServiceUserInfo extends Serializable
- object SimpleDataTypes
The data types supported in column metadata.
- object SnapshotInfoBase
- object SourceContent extends Serializable
- object StreamPipelineOptions extends OptionDescriptionBuilder
Defines the options that can be used on a pipeline of stream type.
- object StreamSourceOptions extends OptionDescriptionBuilder
Defines the options that can be used on a source of stream type.
- object SystemFolders
- object TableColumnMetadataInfo extends Serializable
- object Tags
- object TestResultStatus
The possible values for the status of a test result.
- object TimelineFilterEvaluator
- object TimelineTransforms
- object TitleWithOptions extends Serializable
- object TotpSetting
- object TransformOptions
Defines the options that can be used on a pipeline transform.
- object TransformTypes
- object UserOptions extends OptionDescriptionBuilder
Defines the options that can be used on user.
- object WithTag
- object WizardActions
- object WizardContent extends Serializable
- object WizardExecutionStages
- object WizardLogMessages
- object WizardOptions extends OptionDescriptionBuilder
Defines the options that can be used on a wizard.
- object WizardSessionStates
- object WizardStages