@@ -36,33 +36,68 @@ def load_and_select(table, data, batch):
3636 pa .array (["神奈川県" , "東京都渋谷区" , "東京都中野区" ]),
3737 pa .array (["groonga developer" , "エロいおっさん" , "がおがお" ]),
3838]
39- users_batch = pa .record_batch (users , names = ["_key" , "name" , "follower" , "favorites" , "location" , "location_str" , "description" ])
39+ users_batch = pa .record_batch (
40+ users , names = ["_key" , "name" , "follower" , "favorites" , "location" , "location_str" , "description" ]
41+ )
4042load_and_select ("Users" , users , users_batch )
4143
4244
4345comments = [
44- pa .array (["daijiro:1" , "tasukuchan:1" , "daijiro:2" , "tasukuchan:2" , "tasukuchan:3" , "tasukuchan:4" , "OffGao:1" , "OffGao:2" ]),
45- pa .array ([
46- "マイクロブログ作ってみました(甘栗むいちゃいました的な感じで)。" ,
47- "初の書き込み。テストテスト。" ,
48- "@tasukuchan ようこそ!!!" ,
49- "@daijiro ありがとう!" ,
50- "groongaなう #groonga" ,
51- "groonga開発合宿のため羽田空港に来ました! #groonga #travel" ,
52- "@daijiro @tasukuchan 登録してみましたよー!" ,
53- "中野ブロードウェイなうなう" ,
54- ]),
55- pa .array ([
56- "2010/03/17 12:05:00" , "2010/03/17 12:00:00" , "2010/03/17 12:05:00" , "2010/03/17 13:00:00" ,
57- "2010/03/17 14:00:00" , "2010/03/17 14:05:00" , "2010/03/17 15:00:00" , "2010/03/17 15:05:00" ,
58- ]),
46+ pa .array (
47+ [
48+ "daijiro:1" ,
49+ "tasukuchan:1" ,
50+ "daijiro:2" ,
51+ "tasukuchan:2" ,
52+ "tasukuchan:3" ,
53+ "tasukuchan:4" ,
54+ "OffGao:1" ,
55+ "OffGao:2" ,
56+ ]
57+ ),
58+ pa .array (
59+ [
60+ "マイクロブログ作ってみました(甘栗むいちゃいました的な感じで)。" ,
61+ "初の書き込み。テストテスト。" ,
62+ "@tasukuchan ようこそ!!!" ,
63+ "@daijiro ありがとう!" ,
64+ "groongaなう #groonga" ,
65+ "groonga開発合宿のため羽田空港に来ました! #groonga #travel" ,
66+ "@daijiro @tasukuchan 登録してみましたよー!" ,
67+ "中野ブロードウェイなうなう" ,
68+ ]
69+ ),
70+ pa .array (
71+ [
72+ "2010/03/17 12:05:00" ,
73+ "2010/03/17 12:00:00" ,
74+ "2010/03/17 12:05:00" ,
75+ "2010/03/17 13:00:00" ,
76+ "2010/03/17 14:00:00" ,
77+ "2010/03/17 14:05:00" ,
78+ "2010/03/17 15:00:00" ,
79+ "2010/03/17 15:05:00" ,
80+ ]
81+ ),
5982 pa .array ([None , None , "tasukuchan:1" , "daijiro:2" , None , None , None , None ]),
6083 pa .array ([None , None , ["tasukuchan" ], ["daijiro" ], None , None , ["daijiro" , "tasukuchan" ], None ]),
6184 pa .array ([None , None , None , None , ["groonga" ], ["groonga" , "travel" ], None , None ]),
62- pa .array ([None , None , None , None , "127972422x503117107" , "127975798x502919856" , "128551935x502796433" , "128551935x502796434" ]),
85+ pa .array (
86+ [
87+ None ,
88+ None ,
89+ None ,
90+ None ,
91+ "127972422x503117107" ,
92+ "127975798x502919856" ,
93+ "128551935x502796433" ,
94+ "128551935x502796434" ,
95+ ]
96+ ),
6397 pa .array (["daijiro" , "tasukuchan" , "daijiro" , "tasukuchan" , "tasukuchan" , "tasukuchan" , "OffGao" , "OffGao" ]),
6498]
65- comments_batch = pa .record_batch (comments , names = [
66- "_key" , "comment" , "last_modified" , "replied_to" , "replied_users" , "hash_tags" , "location" , "posted_by"
67- ])
99+ comments_batch = pa .record_batch (
100+ comments ,
101+ names = ["_key" , "comment" , "last_modified" , "replied_to" , "replied_users" , "hash_tags" , "location" , "posted_by" ],
102+ )
68103load_and_select ("Comments" , comments , comments_batch )
0 commit comments