scorpionslau

以传统数据库作为flume的source支持自定义查询以提供使用整个SQL语言的可能性。这是强大的，但有风险，请小心使用自定义查询。要避免行导出重复，请使用WHERE子句中的$@$特殊字符，以递增方式导出未处理的行和插入的新行。重要信息：为了正确操作自定义查询，请确保在查询结果的第一个位置返回增量字