Type Members

1.  case class ClockifyElement(id: String) extends Product with Serializable
2.  class ClockifySourceExecuter extends SourceExecuter
3.  class ClockifySourceGenerator extends SourceGeneratorBase
4.  class ColumnConverter extends AnyRef
5.  class CsvSourceExecuter extends SourceExecuter
6.  class CsvSourceGenerator extends SourceGeneratorBase
7.  abstract class CustomSource extends AnyRef
8.  class CustomSourceExecuter extends SourceExecuter
9.  class CustomSourceGenerator extends SourceGeneratorBase
10.  class DatabaseSourceExecuter extends SourceExecuter with Logging
11.  class DatabaseSourceGenerator extends SourceGeneratorBase
12.  class EconomicSourceExecuter extends SourceExecuter
13.  class EconomicSourceGenerator extends SourceGeneratorBase
14.  class EnvironmentSourceExecuter extends SourceExecuter
15.  class EnvironmentSourceGenerator extends SourceGeneratorBase
16.  class ExcelSourceExecuter extends SourceExecuter
17.  class ExcelSourceGenerator extends SourceGeneratorBase
18.  class ExchangeSourceExecuter extends SourceExecuter
19.  class ExchangeSourceGenerator extends SourceGeneratorBase
20.  case class FacebookCursor(after: Option[String], before: Option[String]) extends Product with Serializable
21.  case class FacebookEntity(id: String, name: String) extends Product with Serializable
22.  case class FacebookMessage(id: String, message: Option[String], story: Option[String], created_time: LocalDateTime) extends Product with Serializable
23.  class FacebookMessageCursor extends AnyRef
24.  class FacebookMessageQuery extends AnyRef
25.  case class FacebookMessagesResponse(data: List[FacebookMessage], paging: FacebookPaging) extends Product with Serializable
26.  case class FacebookPaging(cursors: FacebookCursor, previous: Option[String], next: Option[String]) extends Product with Serializable
27.  case class FacebookPostComment(postId: String, comment: String, date: Timestamp) extends Product with Serializable
28.  case class FacebookResponse(paging: FacebookPaging) extends Product with Serializable
29.  class FacebookSourceExecuter extends SourceExecuter
30.  class FacebookSourceGenerator extends SourceGeneratorBase
31.  class FacebookTimeStampSerializer extends CustomSerializer[LocalDateTime]
32.  case class InsightMetric(name: String, values: List[MetricValue]) extends Product with Serializable
33.  case class InsightMetrics(data: List[InsightMetric]) extends Product with Serializable
34.  class LinkedinSourceExecuter extends SourceExecuter
35.  class LinkedinSourceGenerator extends SourceGeneratorBase
36.  class LinkedinTimeStampSerializer extends CustomSerializer[LocalDateTime]
37.  case class MessageFilter(dateFilter: (LocalDateTime) ⇒ Boolean, sampleFilter: (Int) ⇒ Boolean) extends Product with Serializable
38.  case class MetricValue(value: Int) extends Product with Serializable
39.  case class PageInsights(views: Int, engagements: Int, impressions: Int, accumulated_likes: Int, date: Timestamp) extends Product with Serializable
40.  case class PagingResult(messages: List[FacebookMessage], break: Boolean) extends Product with Serializable
41.  case class PostCommentSummary(total_count: Int) extends Product with Serializable
42.  case class PostComments(summary: PostCommentSummary) extends Product with Serializable
43.  case class PostInsights(post_impressions_unique: Int, post_clicks_unique: Int, post_reactions_like_total: Int, post_reactions_love_total: Int, post_reactions_wow_total: Int) extends Product with Serializable
44.  case class PostResult(id: String, text: String, post_created: Timestamp, impressions: Int, clicks: Int, likes: Int, loves: Int, wows: Int, shares: Int, comments: Int, date: Timestamp) extends Product with Serializable
45.  case class PostSharesCount(count: Int) extends Product with Serializable
46.  case class PostSharesSummary(id: String, shares: Option[PostSharesCount], comments: PostComments) extends Product with Serializable
47.  class RegistrySourceExecuter extends SourceExecuter
48.  class RegistrySourceGenerator extends SourceGeneratorBase
49.  trait SourceExecuter extends AnyRef
50.  case class SourceExecutionScope(session: SparkSession, facades: FacadeApi, connection: ConnectionDescription, source: SourceContent, snapshot: SourceSnapshotInfo, dateRange: Option[TimelineFilter], testSample: Option[Int], tempOutputManager: TempOutputManager, log: (Any) ⇒ Unit, setProgress: (Double) ⇒ Unit) extends Product with Serializable

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

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

    session

    The Apache Spark session that is used during execution.

    facades

    Provides access to the external web service API.

    connection

    The connection properties to be used with the source.

    source

    The properties of the source configuration.

    snapshot

    The properties of the snapshot of the source configuration.

    dateRange

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

    testSample

    The amount of data to sample during a test run.

    tempOutputManager

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

    log

    A method that writes to the logs.

    setProgress

    A method that sets the progress.

51.  abstract class SourceGeneratorBase extends AnyRef
52.  class SourceSnapshotExecuter extends AnyRef
53.  class SourceSqlBuilder extends AnyRef
54.  case class SparkExtraArgs(outputRepository: String) extends Product with Serializable
55.  class SystemSourceExecuter extends SourceExecuter
56.  class SystemSourceGenerator extends SourceGeneratorBase
57.  class TestSourceExecuter extends SourceExecuter
58.  case class TimelineFilter(timelineColumn: SourceDataDescriptionColumn, lowerBound: Option[LocalDateTime], upperBound: LocalDateTime) extends Product with Serializable
59.  case class UpdateComment(comment: String, timestamp: LocalDateTime) extends Product with Serializable
60.  case class UpdateComments(values: List[UpdateComment]) extends Product with Serializable
61.  case class UpdateCommentsResult(key: String, comment: String, linkedin_time: Timestamp) extends Product with Serializable
62.  case class UpdateId(timestamp: LocalDateTime, updateKey: String, updateType: String) extends Product with Serializable
63.  case class UpdateIds(values: List[UpdateId]) extends Product with Serializable
64.  case class UpdateStatistics(clickCount: Long, commentCount: Long, engagement: Double, impressionCount: Long, likeCount: Long, shareCount: Long, time: LocalDateTime) extends Product with Serializable
65.  case class UpdateStatisticsCollection(_total: Long, values: List[UpdateStatistics]) extends Product with Serializable
66.  case class UpdateStatisticsResult(id: String, created: Timestamp, clicks: Long, comments: Long, engagement: Double, impressions: Long, likes: Long, shares: Long, date: Timestamp) extends Product with Serializable
67.  case class WufooEntries(Entries: Array[JObject]) extends Product with Serializable
68.  case class WufooEntryCount(EntryCount: String) extends Product with Serializable
69.  case class WufooForm(Name: String, Description: String) extends Product with Serializable
70.  case class WufooFormField(Title: String, Type: String, ID: String, SubFields: Option[Array[WufooSubField]]) extends Product with Serializable
71.  case class WufooFormFields(Fields: Array[WufooFormField]) extends Product with Serializable
72.  case class WufooForms(Forms: Array[WufooForm]) extends Product with Serializable
73.  class WufooSourceExecuter extends SourceExecuter
74.  class WufooSourceGenerator extends SourceGeneratorBase
75.  case class WufooSubField(ID: String, Label: String) extends Product with Serializable