Examples of com.alibaba.otter.shared.etl.extend.processor.EventProcessor.process()

com.alibaba.otter.shared.etl.extend.processor.EventProcessor.process()

自定义处理单条EventData对象，如果要改变数据内容，请直接修改原对象而非new一个新的对象

 EventData数据格式:  a. schema name / table name b. eventType : insert/update/delete c. executeTime : 执行时间 d. keys / oldKeys : 主键字段 (如果是有主键变更，需要带上老主键的信息在oldKeys中) e. columns :  非主键字段 EventColumn数据格式： a. index : 字段在数据表中的顺序下标 b. columnType : 对应于sqlType c. columnName : 字段名字 d. columnValue : 字段类型 e. isKey : 是否为主键 f. isNull : 是否为空值

@return false需要忽略该条数据，true代表继续处理

                    continue;
                }


                EventProcessor eventProcessor = extensionFactory.getExtension(EventProcessor.class,
                                                                              dataMediaPair.getFilterData());
                boolean process = eventProcessor.process(eventData);
                if (!process) {
                    removeDatas.add(eventData);// 添加到删除记录中
                    break;
                }
            }

                        executorTemplate.submit(new Runnable() {


                            @Override
                            public void run() {
                                MDC.put(OtterConstants.splitPipelineLogFileKey, String.valueOf(pipeline.getId()));
                                boolean process = eventProcessor.process(eventData);
                                if (!process) {
                                    removeDatas.add(eventData);// 添加到删除记录中
                                }
                            }
                        });

                                    removeDatas.add(eventData);// 添加到删除记录中
                                }
                            }
                        });
                    } else {
                        boolean process = eventProcessor.process(eventData);
                        if (!process) {
                            removeDatas.add(eventData);// 添加到删除记录中
                            break;
                        }
                    }

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.