@@ -238,27 +238,27 @@ public static void main(String[] args) throws Exception{
238
238
List <String > sche = Lists .newArrayList ("table:varchar" ,"op_type:varchar" ,"op_ts:varchar" ,"current_ts:varchar" ,"pos:varchar" ,"before:varchar" ,"after:varchar" );
239
239
Hdfs .schema = sche ;
240
240
241
- for (int i =0 ;i <1 ;i ++){
242
- new Thread (new Runnable (){
243
-
244
- @ Override
245
- public void run () {
246
- // TODO Auto-generated method stub
247
-
248
- Hdfs hdfs = new Hdfs (Maps .newConcurrentMap ());
249
- hdfs .prepare ();
250
- for (int i =0 ;i <100000 ;i ++){
251
- Map <String ,Object > event = Maps .newConcurrentMap ();
252
- event .put ("table" , "TEST.T" );
253
- event .put ("op_type" , "U" );
254
- event .put ("op_ts" , "2017-09-05 09:47:45.040103" );
255
- event .put ("current_ts" , "2017-09-05T17:47:52.868000" );
256
- event .put ("before" , "{\" ID\" :12,\" NAME\" :\" dsasasdas\" }" );
257
- event .put ("after" , "{\" ID\" :12,\" NAME\" :\" 1234455\" }" );
258
- hdfs .emit (event );
259
- }
260
- }
261
- }).start ();
262
- }
241
+ // for(int i =0;i<1;i++){
242
+ // new Thread(new Runnable(){
243
+ //
244
+ // @Override
245
+ // public void run() {
246
+ // // TODO Auto-generated method stub
247
+ //
248
+ // Hdfs hdfs = new Hdfs(Maps.newConcurrentMap());
249
+ // hdfs.prepare();
250
+ // for(int i=0;i<100000;i++){
251
+ // Map<String,Object> event = Maps.newConcurrentMap();
252
+ // event.put("table", "TEST.T");
253
+ // event.put("op_type", "U");
254
+ // event.put("op_ts", "2017-09-05 09:47:45.040103");
255
+ // event.put("current_ts", "2017-09-05T17:47:52.868000");
256
+ // event.put("before", "{\"ID\":12,\"NAME\":\"dsasasdas\"}");
257
+ // event.put("after", "{\"ID\":12,\"NAME\":\"1234455\"}");
258
+ // hdfs.emit(event);
259
+ // }
260
+ // }
261
+ // }).start();
262
+ // }
263
263
}
264
264
}
0 commit comments