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. case class AssetsInsertSchema(name: String, parentId: Option[Long] = None, description: Option[String] = None, source: Option[String] = None, externalId: Option[String] = None, metadata: Option[Map[String, String]] = None, parentExternalId: Option[String] = None) extends Product with Serializable

   

4. case class AssetsReadSchema(externalId: Option[String] = None, name: String, parentId: Option[Long] = None, description: Option[String] = None, metadata: Option[Map[String, String]] = None, source: Option[String] = None, id: Long = 0, createdTime: Instant = Instant.ofEpochMilli(0), lastUpdatedTime: Instant = Instant.ofEpochMilli(0), rootId: Long = 0, aggregates: Option[Map[String, Long]] = None) extends Product with Serializable

   

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

   

6. case class AssetsUpsertSchema(id: Option[Long] = None, name: Option[String] = None, description: Option[String] = None, source: Option[String] = None, externalId: Option[String] = None, metadata: Option[Map[String, String]] = None, parentId: Option[Long] = None, parentExternalId: Option[String] = None) extends WithExternalId with WithId[Option[Long]] with Product with Serializable

   

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

   

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

   

9. abstract class CdfRelation extends BaseRelation with Serializable

   

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

    

11. trait CdpConnector extends AnyRef

    

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

    

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

    

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

    

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

    

16. abstract class DataPointsRelationV1[A] extends CdfRelation with TableScan with PrunedFilteredScan with Serializable with InsertableRelation

    

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

    

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

    

19. abstract class DeleteSchema extends AnyRef

    

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

    

21. case class EventsInsertSchema(startTime: Option[Instant] = None, endTime: Option[Instant] = None, description: Option[String] = None, type: Option[String] = None, subtype: Option[String] = None, metadata: Option[Map[String, String]] = None, assetIds: Option[Seq[Long]] = None, source: Option[String] = None, externalId: Option[String] = None) extends Product with Serializable

    

22. case class EventsReadSchema(id: Long = 0, startTime: Option[Instant] = None, endTime: Option[Instant] = None, description: Option[String] = None, type: Option[String] = None, subtype: Option[String] = None, metadata: Option[Map[String, String]] = None, assetIds: Option[Seq[Long]] = None, source: Option[String] = None, externalId: Option[String] = None, createdTime: Instant = Instant.ofEpochMilli(0), lastUpdatedTime: Instant = Instant.ofEpochMilli(0)) extends Product with Serializable

    

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

    

24. case class EventsUpsertSchema(id: Option[Long] = None, startTime: Option[Instant] = None, endTime: Option[Instant] = None, description: Option[String] = None, type: Option[String] = None, subtype: Option[String] = None, metadata: Option[Map[String, String]] = None, assetIds: Option[Seq[Long]] = None, source: Option[String] = None, externalId: Option[String] = None) extends WithExternalId with WithId[Option[Long]] with Product with Serializable

    

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

    

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

    

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

    

28. trait InsertSchema extends AnyRef

    

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

    

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

    

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

    

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

    

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

    

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

    

35. 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

    

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

    

37. 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

    

38. class NumericDataPointsRelationV1 extends DataPointsRelationV1[DataPointsItem] with WritableRelation

    

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

    

40. sealed trait PushdownExpression extends AnyRef

    

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

    

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

    

43. sealed trait Range extends AnyRef

    

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

    

45. 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, ignoreUnknownIds: Boolean) extends Product with Serializable

    

46. 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

    

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

    

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

    

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

    

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

    

51. 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

    

52. class StringDataPointsRelationV1 extends DataPointsRelationV1[StringDataPointsItem] with WritableRelation

    

53. class ThreeDModelRevisionMappingsRelation extends SdkV1Relation[ThreeDAssetMapping, String]

    

54. class ThreeDModelRevisionNodesRelation extends SdkV1Relation[ThreeDNode, Long]

    

55. class ThreeDModelRevisionsRelation extends SdkV1Relation[ThreeDRevision, Long]

    

56. class ThreeDModelsRelation extends SdkV1Relation[ThreeDModel, Long]

    

57. case class TimeSeriesInsertSchema(externalId: Option[String] = None, name: Option[String] = None, isString: Boolean = false, metadata: Option[Map[String, String]] = None, unit: Option[String] = None, assetId: Option[Long] = None, isStep: Boolean = false, description: Option[String] = None, securityCategories: Option[Seq[Long]] = None) extends Product with Serializable

    

58. case class TimeSeriesReadSchema(name: Option[String] = None, isString: Boolean = false, metadata: Option[Map[String, String]] = None, unit: Option[String] = None, assetId: Option[Long] = None, isStep: Boolean = false, description: Option[String] = None, securityCategories: Option[Seq[Long]] = None, id: Long = 0, externalId: Option[String] = None, createdTime: Instant = Instant.ofEpochMilli(0), lastUpdatedTime: Instant = Instant.ofEpochMilli(0)) extends Product with Serializable

    

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

    

60. case class TimeSeriesUpsertSchema(id: Option[Long] = None, name: Option[String] = None, externalId: Option[String] = None, metadata: Option[Map[String, String]] = None, assetId: Option[Long] = None, description: Option[String] = None, securityCategories: Option[Seq[Long]] = None, isStep: Option[Boolean] = None, isString: Option[Boolean] = None) extends WithExternalId with WithId[Option[Long]] with Product with Serializable

    

61. trait UpdateSchema extends AnyRef

    

62. trait UpsertSchema extends AnyRef

    

63. trait WritableRelation extends AnyRef