@@ -74,6 +74,7 @@ cube('Users', {
7474 dimensions: [Users .name ],
7575 timeDimension: Users .createdAt ,
7676 granularity: ` day` ,
77+ partitionGranularity: ` day` ,
7778 buildRangeStart: {
7879 sql: ` SELECT '2020-01-01'`
7980 },
@@ -108,6 +109,17 @@ streaming.
108109cube (' StreamingUsers' , {
109110 ... ,
110111 dataSource: ' ksql' ,
112+
113+ preAggregations: {
114+ streaming: {
115+ type: ` rollup` ,
116+ measures: [StreamingUsers .count ],
117+ dimensions: [StreamingUsers .name ],
118+ timeDimension: StreamingUsers .createdAt ,
119+ granularity: ` day` ,
120+ partitionGranularity: ` day` ,
121+ }
122+ }
111123});
112124
113125// This cube uses a data source such as Clickhouse or BigQuery
@@ -116,28 +128,23 @@ cube('Users', {
116128 preAggregations: {
117129 batchStreamingLambda: {
118130 type: ` rollupLambda` ,
119- rollups: [Users .batch , streaming]
131+ rollups: [Users .batch , StreamingUsers . streaming ]
120132 },
121133 batch: {
122134 type: ` rollup` ,
123135 measures: [Users .count ],
124136 dimensions: [Users .name ],
125137 timeDimension: Users .createdAt ,
126138 granularity: ` day` ,
139+ partitionGranularity: ` day` ,
127140 buildRangeStart: {
128141 sql: ` SELECT '2020-01-01'`
129142 },
130143 buildRangeEnd: {
131144 sql: ` SELECT '2022-05-30'`
132145 }
133146 },
134- streaming: {
135- type: ` rollup` ,
136- measures: [StreamingUsers .count ],
137- dimensions: [StreamingUsers .name ],
138- timeDimension: StreamingUsers .createdAt ,
139- granularity: ` day`
140- }}
147+
141148 },
142149)
143150` ` `
0 commit comments