源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：com.alibaba.otter.canal.filter.CanalEventFilter

示例1
public void setEventFilter(CanalEventFilter eventFilter) {
    super.setEventFilter(eventFilter);

    // 触发一下filter变更
    if (eventFilter != null && eventFilter instanceof AviaterRegexFilter) {
        if (binlogParser instanceof LogEventConvert) {
            ((LogEventConvert) binlogParser).setNameFilter((AviaterRegexFilter) eventFilter);
        }

        if (tableMetaTSDB != null && tableMetaTSDB instanceof DatabaseTableMeta) {
            ((DatabaseTableMeta) tableMetaTSDB).setFilter(eventFilter);
        }
    }
}
示例2
public void setEventBlackFilter(CanalEventFilter eventBlackFilter) {
    super.setEventBlackFilter(eventBlackFilter);

    // 触发一下filter变更
    if (eventBlackFilter != null && eventBlackFilter instanceof AviaterRegexFilter) {
        if (binlogParser instanceof LogEventConvert) {
            ((LogEventConvert) binlogParser).setNameBlackFilter((AviaterRegexFilter) eventBlackFilter);
        }

        if (tableMetaTSDB != null && tableMetaTSDB instanceof DatabaseTableMeta) {
            ((DatabaseTableMeta) tableMetaTSDB).setBlackFilter(eventBlackFilter);
        }
    }
}
示例3
public void setEventFilter(CanalEventFilter eventFilter) {
    super.setEventFilter(eventFilter);

    // 触发一下filter变更
    if (eventFilter != null && eventFilter instanceof AviaterRegexFilter) {
        if (binlogParser instanceof LogEventConvert) {
            ((LogEventConvert) binlogParser).setNameFilter((AviaterRegexFilter) eventFilter);
        }

        if (tableMetaTSDB != null && tableMetaTSDB instanceof DatabaseTableMeta) {
            ((DatabaseTableMeta) tableMetaTSDB).setFilter(eventFilter);
        }
    }
}
示例4
public void setEventBlackFilter(CanalEventFilter eventBlackFilter) {
    super.setEventBlackFilter(eventBlackFilter);

    // 触发一下filter变更
    if (eventBlackFilter != null && eventBlackFilter instanceof AviaterRegexFilter) {
        if (binlogParser instanceof LogEventConvert) {
            ((LogEventConvert) binlogParser).setNameBlackFilter((AviaterRegexFilter) eventBlackFilter);
        }

        if (tableMetaTSDB != null && tableMetaTSDB instanceof DatabaseTableMeta) {
            ((DatabaseTableMeta) tableMetaTSDB).setBlackFilter(eventBlackFilter);
        }
    }
}
示例5
public void setFilter(CanalEventFilter filter) {
    this.filter = filter;
}
示例6
public CanalEventFilter getFilter() {
    return filter;
}
示例7
public void setFilter(CanalEventFilter filter) {
    this.filter = filter;
}
示例8
public void setBlackFilter(CanalEventFilter blackFilter) {
    this.blackFilter = blackFilter;
}
示例9
public void setEventFilter(CanalEventFilter eventFilter) {
    this.eventFilter = eventFilter;
}
示例10
public void setEventBlackFilter(CanalEventFilter eventBlackFilter) {
    this.eventBlackFilter = eventBlackFilter;
}
示例11
public void setEventFilter(CanalEventFilter eventFilter) {
    this.eventFilter = eventFilter;
}
示例12
public void setEventBlackFilter(CanalEventFilter eventBlackFilter) {
    this.eventBlackFilter = eventBlackFilter;
}
示例13
public void setFilter(CanalEventFilter filter) {
    this.filter = filter;
}
示例14
public CanalEventFilter getFilter() {
    return filter;
}
示例15
public void setFilter(CanalEventFilter filter) {
    this.filter = filter;
}
示例16
public void setBlackFilter(CanalEventFilter blackFilter) {
    this.blackFilter = blackFilter;
}
示例17
public void setEventFilter(CanalEventFilter eventFilter) {
    this.eventFilter = eventFilter;
}
示例18
public void setEventBlackFilter(CanalEventFilter eventBlackFilter) {
    this.eventBlackFilter = eventBlackFilter;
}