Java RowData类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.alibaba.otter.canal.protocol.CanalEntry.RowData类的典型用法代码示例。如果您正苦于以下问题：Java RowData类的具体用法？Java RowData怎么用？Java RowData使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

RowData类属于com.alibaba.otter.canal.protocol.CanalEntry包，在下文中一共展示了RowData类的14个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: convertProtobufRecord

import com.alibaba.otter.canal.protocol.CanalEntry.RowData; //导入依赖的package包/类
public static <T extends Object> PairWrapper<String, Object> convertProtobufRecord(EntryHeader header, RowData rowData) {
   	PairWrapper<String, Object> wrapper = new PairWrapper<>();
	List<Column> Columns = null;
	if(header.isInsert() || header.isUpdate()){
		Columns = rowData.getAfterColumnsList();	
	}else if(header.isDelete()){
		Columns = rowData.getBeforeColumnsList();
	}
	wrapper.addProperties(Constants.MessageBodyKey.POS, header.getPos());
	wrapper.addProperties(Constants.MessageBodyKey.OP_TS, header.getTsTime());

	Map<String, Object> map = convert2map(Columns);
	for (Map.Entry<String, Object> entry : map.entrySet()) {
		wrapper.addPair(new Pair<>(entry.getKey(), CharSequence.class.isInstance(entry.getValue())?entry.getValue().toString():entry.getValue()));
	}

	return wrapper;
}

开发者ID:BriData，项目名称:DBus，代码行数:19，代码来源:Convertor.java

示例2: createBuilderWithSchema

import com.alibaba.otter.canal.protocol.CanalEntry.RowData; //导入依赖的package包/类
/**
 * 创建DBusMessageBuilder对象,同时生成ums schema
 */
private DbusMessageBuilder createBuilderWithSchema(MetaVersion version, MessageEntry msgEntry) {
    DbusMessageBuilder builder = new DbusMessageBuilder();
    String namespace = builder.buildNameSpace(Utils.getDataSourceNamespace(),
            msgEntry.getEntryHeader().getSchemaName(), msgEntry.getEntryHeader().getTableName(),
            version.getVersion(), msgEntry.getEntryHeader().getPartitionTableName());
    builder.build(DbusMessage.ProtocolType.DATA_INCREMENT_DATA, namespace, table.getBatchId());
    EventType eventType = msgEntry.getEntryHeader().getOperType();
    RowData rowData = msgEntry.getMsgColumn().getRowDataLst().get(0);
    List<Column> columns = Support.getFinalColumns(eventType, rowData);
    for (Column column : columns) {
        String colType = Support.getColumnType(column);
        if (Support.isSupported(colType)) {
            builder.appendSchema(column.getName(), DataType.convertMysqlDataType(colType), true);
        }
    }
    return builder;
}

开发者ID:BriData，项目名称:DBus，代码行数:21，代码来源:MysqlWrapperDefaultHandler.java

示例3: buildMeta

import com.alibaba.otter.canal.protocol.CanalEntry.RowData; //导入依赖的package包/类
private MetaWrapper buildMeta(MessageEntry msgEntry) {
    MetaWrapper metaWrapper = new MetaWrapper();
    EntryHeader header = msgEntry.getEntryHeader();
    RowData rowData = msgEntry.getMsgColumn().getRowDataLst().get(0);
    List<Column> columns = Support.getFinalColumns(header.getOperType(), rowData);
    for (Column column : columns) {
        MetaWrapper.MetaCell cell = new MetaWrapper.MetaCell();
        cell.setColumnName(column.getName());
        cell.setDataType(Support.getColumnType(column));
        int[] ret = Support.getColumnLengthAndPrecision(column);
        cell.setDataLength(ret[0]);
        cell.setDataPrecision(ret[1]);
        cell.setDataScale(0);
        cell.setIsPk(column.getIsKey() ? "Y" : "N");
        cell.setNullAble("N");
        cell.setDdlTime(new Timestamp(header.getExecuteTime()));
        cell.setColumnId(column.getIndex());
        cell.setInternalColumnId(column.getIndex());
        cell.setHiddenColumn("NO");
        cell.setVirtualColumn("NO");
        metaWrapper.addMetaCell(cell);
    }
    return metaWrapper;
}

开发者ID:BriData，项目名称:DBus，代码行数:25，代码来源:MaDefaultHandler.java

示例4: buildEvent

import com.alibaba.otter.canal.protocol.CanalEntry.RowData; //导入依赖的package包/类
private Event buildEvent() {
    Event event = new Event();
    event.setLogIdentity(new LogIdentity());

    Header.Builder headBuilder = Header.newBuilder();
    headBuilder.setEventLength(1000L);
    headBuilder.setExecuteTime(new Date().getTime());
    headBuilder.setLogfileName("mysql-bin.000001");
    headBuilder.setLogfileOffset(1000L);
    headBuilder.setSchemaName("test");
    headBuilder.setTableName("ljh");

    Entry.Builder entryBuilder = Entry.newBuilder();
    entryBuilder.setHeader(headBuilder.build());
    entryBuilder.setEntryType(EntryType.ROWDATA);

    RowChange.Builder rowChangeBuilder = RowChange.newBuilder();
    RowData.Builder rowDataBuilder = RowData.newBuilder();
    rowChangeBuilder.addRowDatas(rowDataBuilder.build());

    entryBuilder.setStoreValue(rowChangeBuilder.build().toByteString());
    Entry entry = entryBuilder.build();
    event.setEntry(entry);
    return event;
}

开发者ID:luoyaogui，项目名称:otter-G，代码行数:26，代码来源:OtterDownStreamHandlerIntergration.java

示例5: convertProtobufRecordBeforeUpdate

import com.alibaba.otter.canal.protocol.CanalEntry.RowData; //导入依赖的package包/类
public static <T extends Object> PairWrapper<String, Object> convertProtobufRecordBeforeUpdate(EntryHeader header, RowData rowData) {
	PairWrapper<String, Object> wrapper = new PairWrapper<>();
	List<Column> Columns = rowData.getBeforeColumnsList();
	Map<String, Object> map = convert2map(Columns);
	for (Map.Entry<String, Object> entry : map.entrySet()) {
		wrapper.addPair(new Pair<>(entry.getKey(), CharSequence.class.isInstance(entry.getValue())?entry.getValue().toString():entry.getValue()));
	}

	return wrapper;
}

开发者ID:BriData，项目名称:DBus，代码行数:11，代码来源:Convertor.java

示例6: getFinalColumns

import com.alibaba.otter.canal.protocol.CanalEntry.RowData; //导入依赖的package包/类
public static List<Column> getFinalColumns(EventType type, RowData rowData){
	List<Column> Columns = null;
	if(type == EventType.INSERT || type == EventType.UPDATE){
		Columns = rowData.getAfterColumnsList();	
	}else if(type == EventType.DELETE){
		Columns = rowData.getBeforeColumnsList();
	}
	return Columns;
}

开发者ID:BriData，项目名称:DBus，代码行数:10，代码来源:Support.java

示例7: checkCompatibleLoopback

import com.alibaba.otter.canal.protocol.CanalEntry.RowData; //导入依赖的package包/类
/**
 * 检查otter3.0的兼容表处理，主要部分业务使用了3.0的功能，需要考虑兼容支持，后续可删除
 */
private int checkCompatibleLoopback(Pipeline pipeline, RowData rowData) {
    // 检查_info字段
    // 首先检查下after记录，从无变有的过程，一般出现在事务头
    Column infokColumn = getColumnIgnoreCase(rowData.getAfterColumnsList(), compatibleMarkInfoColumn);
    // 匹配对应的channel id
    if (infokColumn != null && infokColumn.getValue().toUpperCase().endsWith(RETL_CLIENT_FLAG)) {
        return 1;
    }

    infokColumn = getColumnIgnoreCase(rowData.getBeforeColumnsList(), compatibleMarkInfoColumn);
    if (infokColumn != null && infokColumn.getValue().toUpperCase().endsWith(RETL_CLIENT_FLAG)) {
        return 1;
    }

    // 检查_id字段
    Column markColumn = getColumnIgnoreCase(rowData.getAfterColumnsList(), compatibleMarkIdentifierColumn);
    // 匹配对应的channel id
    if (markColumn != null && pipeline.getChannelId().equals(Long.parseLong(markColumn.getValue()))) {
        return 2;
    }

    markColumn = getColumnIgnoreCase(rowData.getBeforeColumnsList(), compatibleMarkIdentifierColumn);
    if (markColumn != null && pipeline.getChannelId().equals(Long.parseLong(markColumn.getValue()))) {
        return 2;
    }

    return 0;
}

开发者ID:luoyaogui，项目名称:otter-G，代码行数:32，代码来源:MessageParser.java

示例8: doSync

import com.alibaba.otter.canal.protocol.CanalEntry.RowData; //导入依赖的package包/类
@Override
protected void doSync(String database, String table, String index, String type, RowData rowData) {
    List<Column> columns = rowData.getAfterColumnsList();
    String primaryKey = Optional.ofNullable(mappingService.getTablePrimaryKeyMap().get(database + "." + table)).orElse("id");
    Column idColumn = columns.stream().filter(column -> column.getIsKey() && primaryKey.equals(column.getName())).findFirst().orElse(null);
    if (idColumn == null || StringUtils.isBlank(idColumn.getValue())) {
        logger.warn("update_column_find_null_warn update从column中找不到主键,database=" + database + ",table=" + table);
        return;
    }
    logger.debug("update_column_id_info update主键id,database=" + database + ",table=" + table + ",id=" + idColumn.getValue());
    Map<String, Object> dataMap = parseColumnsToMap(columns);
    elasticsearchService.update(index, type, idColumn.getValue(), dataMap);
    logger.debug("update_es_info 同步es插入操作成功！database=" + database + ",table=" + table + ",data=" + dataMap);
}

开发者ID:starcwang，项目名称:canal_mysql_elasticsearch_sync，代码行数:15，代码来源:UpdateCanalListener.java

示例9: doSync

import com.alibaba.otter.canal.protocol.CanalEntry.RowData; //导入依赖的package包/类
@Override
protected void doSync(String database, String table, String index, String type, RowData rowData) {
    List<Column> columns = rowData.getAfterColumnsList();
    String primaryKey = Optional.ofNullable(mappingService.getTablePrimaryKeyMap().get(database + "." + table)).orElse("id");
    Column idColumn = columns.stream().filter(column -> column.getIsKey() && primaryKey.equals(column.getName())).findFirst().orElse(null);
    if (idColumn == null || StringUtils.isBlank(idColumn.getValue())) {
        logger.warn("insert_column_find_null_warn insert从column中找不到主键,database=" + database + ",table=" + table);
        return;
    }
    logger.debug("insert_column_id_info insert主键id,database=" + database + ",table=" + table + ",id=" + idColumn.getValue());
    Map<String, Object> dataMap = parseColumnsToMap(columns);
    elasticsearchService.insertById(index, type, idColumn.getValue(), dataMap);
    logger.debug("insert_es_info 同步es插入操作成功！database=" + database + ",table=" + table + ",data=" + JsonUtil.toJson(dataMap));
}

开发者ID:starcwang，项目名称:canal_mysql_elasticsearch_sync，代码行数:15，代码来源:InsertCanalListener.java

示例10: doSync

import com.alibaba.otter.canal.protocol.CanalEntry.RowData; //导入依赖的package包/类
@Override
protected void doSync(String database, String table, String index, String type, RowData rowData) {
    List<Column> columns = rowData.getBeforeColumnsList();
    String primaryKey = Optional.ofNullable(mappingService.getTablePrimaryKeyMap().get(database + "." + table)).orElse("id");
    Column idColumn = columns.stream().filter(column -> column.getIsKey() && primaryKey.equals(column.getName())).findFirst().orElse(null);
    if (idColumn == null || StringUtils.isBlank(idColumn.getValue())) {
        logger.warn("insert_column_find_null_warn insert从column中找不到主键,database=" + database + ",table=" + table);
        return;
    }
    logger.debug("insert_column_id_info insert主键id,database=" + database + ",table=" + table + ",id=" + idColumn.getValue());
    elasticsearchService.deleteById(index, type, idColumn.getValue());
    logger.debug("insert_es_info 同步es插入操作成功！database=" + database + ",table=" + table + ",id=" + idColumn.getValue());
}

开发者ID:starcwang，项目名称:canal_mysql_elasticsearch_sync，代码行数:14，代码来源:DeleteCanalListener.java

示例11: getRowDataLst

import com.alibaba.otter.canal.protocol.CanalEntry.RowData; //导入依赖的package包/类
public List<RowData> getRowDataLst() {
	return rowDataLst;
}

开发者ID:BriData，项目名称:DBus，代码行数:4，代码来源:MsgColumn.java

示例12: setRowDataLst

import com.alibaba.otter.canal.protocol.CanalEntry.RowData; //导入依赖的package包/类
public void setRowDataLst(List<RowData> rowDataLst) {
	this.rowDataLst = rowDataLst;
}

开发者ID:BriData，项目名称:DBus，代码行数:4，代码来源:MsgColumn.java

示例13: checkLoopback

import com.alibaba.otter.canal.protocol.CanalEntry.RowData; //导入依赖的package包/类
/**
 * <pre>
 * the table def: 
 *              channel_info varchar
 *              channel_id varchar
 * 每次解析时，每个事务首先获取 retl_mark 下的 channel_info 或 channel_id 字段变更。
 *  a. 如果存在 channel_info 以 '_SYNC'结尾的字符串 ，则忽略本次事务的数据变更；
 *  b. 如果不等于，则执行下面的判断。
 *      i. 如果存在channel_id = "xx"，则检查对应的channel_id是否为当前同步的channelId，如果是则忽略。
 *      ii. 不存在则不处理
 * </pre>
 */
private int checkLoopback(Pipeline pipeline, RowData rowData) {
    // 检查channel_info字段
    // 首先检查下after记录，从无变有的过程，一般出现在事务头
    Column infokColumn = getColumnIgnoreCase(rowData.getAfterColumnsList(), pipeline.getParameters()
        .getSystemMarkTableInfo());

    // 匹配对应的channelInfo，如果以_SYNC结尾，则认为需要忽略
    if (infokColumn != null && StringUtils.endsWithIgnoreCase(infokColumn.getValue(), RETL_CLIENT_FLAG)) {
        return 1;
    }

    // 匹配对应的channelInfo，如果相同，则认为需要忽略，并返回2，代表需要进行回环补救check机制，因为这个变更也是otter系统产生的
    if (infokColumn != null
        && StringUtils.equalsIgnoreCase(infokColumn.getValue(), pipeline.getParameters().getChannelInfo())) {
        return 2;
    }

    infokColumn = getColumnIgnoreCase(rowData.getBeforeColumnsList(), pipeline.getParameters()
        .getSystemMarkTableInfo());
    // 匹配对应的channelInfo，如果以_SYNC结尾，则认为需要忽略
    if (infokColumn != null && StringUtils.endsWithIgnoreCase(infokColumn.getValue(), RETL_CLIENT_FLAG)) {
        return 1;
    }

    // 匹配对应的channelInfo，如果相同，则认为需要忽略，并返回2，代表需要进行回环补救check机制，因为这个变更也是otter系统产生的
    if (infokColumn != null
        && StringUtils.equalsIgnoreCase(infokColumn.getValue(), pipeline.getParameters().getChannelInfo())) {
        return 2;
    }

    // 检查channel_id字段
    Column markColumn = getColumnIgnoreCase(rowData.getAfterColumnsList(), pipeline.getParameters()
        .getSystemMarkTableColumn());
    // 匹配对应的channel id
    if (markColumn != null && pipeline.getChannelId().equals(Long.parseLong(markColumn.getValue()))) {
        return 2;
    }

    markColumn = getColumnIgnoreCase(rowData.getBeforeColumnsList(), pipeline.getParameters()
        .getSystemMarkTableColumn());
    if (markColumn != null && pipeline.getChannelId().equals(Long.parseLong(markColumn.getValue()))) {
        return 2;
    }

    return 0;
}

开发者ID:luoyaogui，项目名称:otter-G，代码行数:59，代码来源:MessageParser.java

示例14: doSync

import com.alibaba.otter.canal.protocol.CanalEntry.RowData; //导入依赖的package包/类
protected abstract void doSync(String database, String table, String index, String type, RowData rowData);

开发者ID:starcwang，项目名称:canal_mysql_elasticsearch_sync，代码行数:2，代码来源:AbstractCanalListener.java

注：本文中的com.alibaba.otter.canal.protocol.CanalEntry.RowData类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java LookupItem类代码示例发布时间：2022-05-22

Java DummyLibraryProperties类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18222|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9658|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8173|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8543|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8450|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9375|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8420|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7855|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8405|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7392|2022-11-06

客服电话

电子邮件

Java RowData类代码示例

示例1: convertProtobufRecord

示例2: createBuilderWithSchema

示例3: buildMeta

示例4: buildEvent

示例5: convertProtobufRecordBeforeUpdate

示例6: getFinalColumns

示例7: checkCompatibleLoopback

示例8: doSync

示例9: doSync

示例10: doSync

示例11: getRowDataLst

示例12: setRowDataLst

示例13: checkLoopback

示例14: doSync

请发表评论

全部评论

上一篇：

下一篇：

librespeed/speedtest: Self-hosted Speedt

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

medfreeman/markdown-it-toc-and-anchor: m

maxcom/lorsource: Linux.org.ru website e

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053