Symbols after a decimal point, -1 if the string lacks the decimal point. >>> _afterpoint("123.45") 2 >>> _afterpoint("1001") -1 >

A wrapper around standard bool() which doesn't throw on NumPy arrays

>>> _isnumber("123.45") True >>> _isnumber("123") True >>> _isnumber("spam") False

@param records @return 返回一个新的Cache用于存储接下来的数据

按照configuration要求格式的path 比如： a.b.c a.b[2].c @param path

在外部线程执行并且重试。每次执行需要在timeoutMs内执行完，不然视为失败。 执行异步操作的线程池从外部传入，线程池的共享粒度由外部控制。比如，HttpClientUtil共享一个线程池。 <p/> 限制条件：仅仅能够在阻塞的时候interrupt线程 @param callable

设置pluginConfigs，方便后面插件来获取 @param pluginConfigs

根据字符串生成密钥字节数组 @param keyStr 密钥字符串 @return key 符合DESede标准的24byte数组

构建key 构建数据为空时当做脏数据处理

构建value 如果有二进制字段当做脏数据处理 如果col为null，当做脏数据处理

@param tableName @param columnHolders @param conn @param writeMode @return

计算 Partition Id @param record @return Long

Fast check the future @param f

校验文件名是否有重复的,如果有重复的文件名则抛出异常 @param fileNameList

检测splitPk的配置是否正确。 configuration为null, 是precheck的逻辑，不需要回写PK_TYPE到configuration中

检查表 @param conn @param namespace @param tableName @param isThinClient @throws DataXException

Clear batch is always recreate a new {@link ObDirectLoadBucket}

Clear the holder parameters. @throws SQLException

关闭函数，释放资源

关闭JestClient客户端