package facade
- Alphabetic
- Public
- All
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.
-
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) 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]) 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]) 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]) 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]) 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 = ..., timeoutSeconds: Int = ...) 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) 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.
- 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