v1

Type Members

1. final case class AggregationFilter(aggregation: String) extends Product with Serializable

   

2. final case class AggregationRange(id: Either[Long, String], start: Instant, end: Instant, count: Option[Long], granularity: Granularity, aggregation: String) extends Range with Product with Serializable

   

3. class AssetsRelation extends SdkV1Relation[Asset, Long] with InsertableRelation with WritableRelation

   

4. final case class Bucket(index: Int, ranges: Seq[Range]) extends Partition with Product with Serializable

   

5. case class CdfPartition(index: Int) extends Partition with Product with Serializable

   

6. case class CdpApiErrorPayload(code: Int, message: String) extends Product with Serializable

   

7. trait CdpConnector extends AnyRef

   

8. case class Data[A](data: A) extends Product with Serializable

   

9. case class DataPointsFilter(id: Option[Long], externalId: Option[String], aggregates: Option[Seq[String]], granularity: Option[String]) extends Product with Serializable

   

10. case class DataPointsItem(id: Option[Long], externalId: Option[String], timestamp: Timestamp, value: Double, aggregation: Option[String], granularity: Option[String]) extends Product with Serializable

    

11. final case class DataPointsRange(id: Either[Long, String], start: Instant, end: Instant, count: Option[Long]) extends Range with Product with Serializable

    

12. abstract class DataPointsRelationV1[A] extends BaseRelation with TableScan with PrunedFilteredScan with Serializable with InsertableRelation

    

13. class DefaultSource extends RelationProvider with CreatableRelationProvider with SchemaRelationProvider with DataSourceRegister with CdpConnector

    

14. case class DeleteItem(id: Long) extends Product with Serializable

    

15. abstract class DeleteSchema extends AnyRef

    

16. case class Error[A](error: A) extends Product with Serializable

    

17. class EventsRelation extends SdkV1Relation[Event, Long] with InsertableRelation with WritableRelation

    

18. class FilesRelation extends SdkV1Relation[File, Long] with InsertableRelation

    

19. final case class Granularity(amountOption: Option[Long], unit: ChronoUnit, isLongFormat: Boolean = false) extends Product with Serializable

    

20. case class InsertDataPointsItem(id: Option[Long], externalId: Option[String], timestamp: Instant, value: Double) extends Product with Serializable

    

21. trait InsertSchema extends AnyRef

    

22. case class Items[A](items: Seq[A]) extends Product with Serializable

    

23. abstract class Limit extends Ordered[Limit] with Serializable

    

24. case class Login(user: String, loggedIn: Boolean, project: String, projectId: Long) extends Product with Serializable

    

25. sealed case class Max(value: Instant) extends Limit with Product with Serializable

    

26. sealed case class Min(value: Instant) extends Limit with Product with Serializable

    

27. case class ModelItem(id: Long, name: String, createdTime: Long) extends Product with Serializable

    

28. case class ModelRevisionItem(id: Long, fileId: Long, published: Boolean, rotation: Option[Seq[Double]], camera: Map[String, Seq[Double]], status: String, thumbnailThreedFileId: Option[Long], thumbnailUrl: Option[String], sceneThreedFiles: Option[Seq[Map[String, Long]]], sceneThreedFileId: Option[Long], assetMappingCount: Long, createdTime: Long) extends Product with Serializable

    

29. final case class NoPushdown() extends PushdownExpression with Product with Serializable

    

30. case class NumericDataPointsRdd(sparkContext: SparkContext, config: RelationConfig, ids: Seq[Long], externalIds: Seq[String], timestampLimits: (Instant, Instant), aggregations: Array[AggregationFilter], granularities: Seq[Granularity], toRow: (DataPointsItem) ⇒ Row) extends RDD[Row] with Product with Serializable

    

31. class NumericDataPointsRelationV1 extends DataPointsRelationV1[DataPointsItem] with WritableRelation

    

32. final case class PushdownAnd(left: PushdownExpression, right: PushdownExpression) extends PushdownExpression with Product with Serializable

    

33. sealed trait PushdownExpression extends AnyRef

    

34. final case class PushdownFilter(fieldName: String, value: String) extends PushdownExpression with Product with Serializable

    

35. final case class PushdownFilters(filters: Seq[PushdownExpression]) extends PushdownExpression with Product with Serializable

    

36. sealed trait Range extends AnyRef

    

37. class RawTableRelation extends BaseRelation with InsertableRelation with TableScan with PrunedFilteredScan with CdpConnector with Serializable

    

38. case class RelationConfig(auth: Auth, batchSize: Option[Int], limitPerPartition: Option[Int], partitions: Int, maxRetries: Int, collectMetrics: Boolean, metricsPrefix: String, baseUrl: String, onConflict: OnConflict.Value, applicationId: String, parallelismPerPartition: Int) extends Product with Serializable

    

39. case class SdkV1Rdd[A, I](sparkContext: SparkContext, config: RelationConfig, toRow: (A) ⇒ Row, uniqueId: (A) ⇒ I, getStreams: (GenericClient[IO, Nothing], Option[Int], Int) ⇒ Seq[Stream[IO, A]]) extends RDD[Row] with Product with Serializable

    

40. abstract class SdkV1Relation[A <: Product, I] extends BaseRelation with CdpConnector with Serializable with TableScan with PrunedFilteredScan

    

41. case class StringDataPointsFilter(id: Option[Long], externalId: Option[String]) extends Product with Serializable

    

42. case class StringDataPointsInsertItem(id: Option[Long], externalId: Option[String], timestamp: Instant, value: String) extends Product with Serializable

    

43. case class StringDataPointsItem(id: Option[Long], externalId: Option[String], timestamp: Timestamp, value: String) extends Product with Serializable

    

44. case class StringDataPointsRdd(sparkContext: SparkContext, config: RelationConfig, getIOs: (GenericClient[IO, Nothing]) ⇒ Seq[(StringDataPointsFilter, IO[Seq[StringDataPoint]])], toRow: (StringDataPointsItem) ⇒ Row) extends RDD[Row] with Product with Serializable

    

45. class StringDataPointsRelationV1 extends DataPointsRelationV1[StringDataPointsItem] with WritableRelation

    

46. class ThreeDModelRevisionMappingsRelation extends SdkV1Relation[ThreeDAssetMapping, String]

    

47. class ThreeDModelRevisionNodesRelation extends SdkV1Relation[ThreeDNode, Long]

    

48. class ThreeDModelRevisionsRelation extends SdkV1Relation[ThreeDRevision, Long]

    

49. class ThreeDModelsRelation extends SdkV1Relation[ThreeDModel, Long]

    

50. class TimeSeriesRelation extends SdkV1Relation[TimeSeries, Long] with WritableRelation with InsertableRelation

    

51. trait UpdateSchema extends AnyRef

    

52. trait UpsertSchema extends AnyRef

    

53. trait WritableRelation extends AnyRef