Skip to content

Commit 2ab9bca

Browse files
ezvzezvz
committed
Reset sample/production dir to match remote
1 parent 160b2eb commit 2ab9bca

18 files changed

+2819
-0
lines changed

‎api/python/test/sample/production/joins/sample_team/sample_backfill_mutation_join.v0

Lines changed: 72 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,72 @@
1+
{
2+
"metaData": {
3+
"name": "sample_team.sample_backfill_mutation_join.v0",
4+
"team": "sample_team",
5+
"outputNamespace": "chronon_db",
6+
"tableProperties": {
7+
"source": "chronon"
8+
},
9+
"online": 0,
10+
"production": 0,
11+
"samplePercent": 100.0,
12+
"executionInfo": {
13+
"scheduleCron": "@daily"
14+
}
15+
},
16+
"left": {
17+
"events": {
18+
"table": "sample_namespace.sample_table_group_by",
19+
"query": {
20+
"selects": {
21+
"event": "event_expr",
22+
"group_by_subject": "group_by_expr",
23+
"ts": "ts"
24+
},
25+
"startPartition": "2021-04-09",
26+
"timeColumn": "ts"
27+
}
28+
}
29+
},
30+
"joinParts": [
31+
{
32+
"groupBy": {
33+
"metaData": {
34+
"name": "sample_team.mutation_sample_group_by.v0",
35+
"team": "sample_team",
36+
"executionInfo": {
37+
"scheduleCron": "@daily",
38+
"historicalBackfill": 0
39+
}
40+
},
41+
"sources": [
42+
{
43+
"entities": {
44+
"snapshotTable": "sample_table.sample_entity_snapshot",
45+
"mutationTable": "sample_table.sample_entity_mutations/hr=00:00",
46+
"mutationTopic": "sample_topic",
47+
"query": {
48+
"selects": {
49+
"group_by_subject": "group_by_subject_expr",
50+
"entity": "entity_expr"
51+
},
52+
"startPartition": "2021-03-01",
53+
"timeColumn": "ts"
54+
}
55+
}
56+
}
57+
],
58+
"keyColumns": [
59+
"group_by_subject"
60+
],
61+
"aggregations": [
62+
{
63+
"inputColumn": "entity",
64+
"operation": 3,
65+
"argMap": {}
66+
}
67+
],
68+
"accuracy": 0
69+
}
70+
}
71+
]
72+
}

‎api/python/test/sample/production/joins/sample_team/sample_chaining_join.v1

Lines changed: 226 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,226 @@
1+
{
2+
"metaData": {
3+
"name": "sample_team.sample_chaining_join.v1",
4+
"team": "sample_team",
5+
"outputNamespace": "chronon_db",
6+
"tableProperties": {
7+
"source": "chronon"
8+
},
9+
"online": 1,
10+
"production": 0,
11+
"consistencyCheck": 1,
12+
"samplePercent": 100.0,
13+
"consistencySamplePercent": 5.0,
14+
"executionInfo": {
15+
"scheduleCron": "@daily"
16+
}
17+
},
18+
"left": {
19+
"events": {
20+
"table": "sample_namespace.sample_table_group_by",
21+
"query": {
22+
"selects": {
23+
"event": "event_expr",
24+
"group_by_subject": "group_by_expr",
25+
"ts": "ts"
26+
},
27+
"startPartition": "2021-04-09",
28+
"timeColumn": "ts"
29+
}
30+
}
31+
},
32+
"joinParts": [
33+
{
34+
"groupBy": {
35+
"metaData": {
36+
"name": "sample_team.chaining_group_by.chaining_group_by_v1",
37+
"team": "sample_team",
38+
"outputNamespace": "sample_namespace",
39+
"tableProperties": {
40+
"sample_config_json": "{\"sample_key\": \"sample_value\"}",
41+
"description": "sample description"
42+
},
43+
"online": 1,
44+
"production": 1,
45+
"executionInfo": {
46+
"scheduleCron": "@daily",
47+
"historicalBackfill": 0
48+
}
49+
},
50+
"sources": [
51+
{
52+
"joinSource": {
53+
"join": {
54+
"metaData": {
55+
"online": 1,
56+
"production": 0,
57+
"consistencyCheck": 1,
58+
"samplePercent": 100.0,
59+
"consistencySamplePercent": 5.0,
60+
"executionInfo": {
61+
"scheduleCron": "@daily",
62+
"historicalBackfill": 0
63+
}
64+
},
65+
"left": {
66+
"events": {
67+
"table": "sample_namespace.sample_table_group_by",
68+
"query": {
69+
"selects": {
70+
"event": "event_expr",
71+
"group_by_subject": "group_by_expr",
72+
"ts": "ts"
73+
},
74+
"startPartition": "2021-04-09",
75+
"timeColumn": "ts"
76+
}
77+
}
78+
},
79+
"joinParts": [
80+
{
81+
"groupBy": {
82+
"metaData": {
83+
"name": "sample_team.event_sample_group_by.v1",
84+
"team": "sample_team",
85+
"outputNamespace": "sample_namespace",
86+
"online": 1,
87+
"executionInfo": {
88+
"scheduleCron": "@daily",
89+
"historicalBackfill": 0
90+
}
91+
},
92+
"sources": [
93+
{
94+
"events": {
95+
"table": "sample_namespace.sample_table_group_by",
96+
"query": {
97+
"selects": {
98+
"event": "event_expr",
99+
"group_by_subject": "group_by_expr"
100+
},
101+
"startPartition": "2021-04-09",
102+
"timeColumn": "ts"
103+
}
104+
}
105+
}
106+
],
107+
"keyColumns": [
108+
"group_by_subject"
109+
],
110+
"aggregations": [
111+
{
112+
"inputColumn": "event",
113+
"operation": 7,
114+
"argMap": {},
115+
"windows": [
116+
{
117+
"length": 7,
118+
"timeUnit": 1
119+
}
120+
]
121+
},
122+
{
123+
"inputColumn": "event",
124+
"operation": 7,
125+
"argMap": {}
126+
},
127+
{
128+
"inputColumn": "event",
129+
"operation": 12,
130+
"argMap": {
131+
"k": "200",
132+
"percentiles": "[0.99, 0.95, 0.5]"
133+
}
134+
}
135+
]
136+
},
137+
"keyMapping": {
138+
"subject": "group_by_subject"
139+
}
140+
},
141+
{
142+
"groupBy": {
143+
"metaData": {
144+
"name": "sample_team.entity_sample_group_by_from_module.v1",
145+
"team": "sample_team",
146+
"online": 1,
147+
"executionInfo": {
148+
"scheduleCron": "@daily",
149+
"historicalBackfill": 0
150+
}
151+
},
152+
"sources": [
153+
{
154+
"entities": {
155+
"snapshotTable": "sample_table.sample_entity_snapshot",
156+
"mutationTable": "sample_table.sample_entity_mutations/hr=00:00",
157+
"mutationTopic": "sample_topic",
158+
"query": {
159+
"selects": {
160+
"group_by_subject": "group_by_subject_expr",
161+
"entity": "entity_expr"
162+
},
163+
"startPartition": "2021-03-01",
164+
"timeColumn": "ts"
165+
}
166+
}
167+
}
168+
],
169+
"keyColumns": [
170+
"group_by_subject"
171+
],
172+
"aggregations": [
173+
{
174+
"inputColumn": "entity",
175+
"operation": 3,
176+
"argMap": {}
177+
},
178+
{
179+
"inputColumn": "entity",
180+
"operation": 3,
181+
"argMap": {},
182+
"windows": [
183+
{
184+
"length": 7,
185+
"timeUnit": 1
186+
}
187+
]
188+
}
189+
]
190+
},
191+
"keyMapping": {
192+
"subject": "group_by_subject"
193+
}
194+
}
195+
]
196+
},
197+
"query": {
198+
"selects": {
199+
"event": "event_expr",
200+
"group_by_subject": "group_by_expr",
201+
"user_id": "user_id"
202+
},
203+
"startPartition": "2023-04-15",
204+
"timeColumn": "ts"
205+
}
206+
}
207+
}
208+
],
209+
"keyColumns": [
210+
"user_id"
211+
],
212+
"aggregations": [
213+
{
214+
"inputColumn": "event",
215+
"operation": 3,
216+
"argMap": {}
217+
}
218+
],
219+
"accuracy": 0
220+
},
221+
"keyMapping": {
222+
"subject": "user_id"
223+
}
224+
}
225+
]
226+
}

0 commit comments

Comments
 (0)