path	# lines of code
src/main/java/com/aliyun/odps/kafka/connect/utils/ConfigHelper.java	24
src/main/java/com/aliyun/odps/kafka/connect/utils/JsonHandler.java	49
src/main/java/com/aliyun/odps/kafka/connect/utils/ConverterHelper.java	72
src/main/java/com/aliyun/odps/kafka/connect/utils/OdpsUtils.java	45
src/main/java/com/aliyun/odps/kafka/connect/MaxComputeSinkConnectorConfig.java	176
src/main/java/com/aliyun/odps/kafka/connect/PartitionWindowType.java	6
src/main/java/com/aliyun/odps/kafka/connect/VersionUtil.java	10
src/main/java/com/aliyun/odps/kafka/connect/MaxComputeSinkTask.java	499
src/main/java/com/aliyun/odps/kafka/connect/MaxComputeSinkWriter.java	454
src/main/java/com/aliyun/odps/kafka/connect/account/AccountGenerator.java	6
src/main/java/com/aliyun/odps/kafka/connect/account/sts/StsService.java	40
src/main/java/com/aliyun/odps/kafka/connect/account/sts/StsUserBo.java	33
src/main/java/com/aliyun/odps/kafka/connect/account/AccountFactory.java	14
src/main/java/com/aliyun/odps/kafka/connect/account/IAccountFactory.java	4
src/main/java/com/aliyun/odps/kafka/connect/account/impl/AliyunAccountGenerator.java	16
src/main/java/com/aliyun/odps/kafka/connect/account/impl/STSAccountGenerator.java	35
src/main/java/com/aliyun/odps/kafka/connect/MaxComputeSinkConnector.java	145
src/main/java/com/aliyun/odps/kafka/connect/converter/JsonRecordConverter.java	56
src/main/java/com/aliyun/odps/kafka/connect/converter/CsvRecordConverter.java	86
src/main/java/com/aliyun/odps/kafka/connect/converter/RecordConverter.java	12
src/main/java/com/aliyun/odps/kafka/connect/converter/BinaryRecordConverter.java	32
src/main/java/com/aliyun/odps/kafka/connect/converter/DefaultRecordConverter.java	39
src/main/java/com/aliyun/odps/kafka/connect/converter/FlattenRecordConverter.java	79
src/main/java/com/aliyun/odps/kafka/connect/converter/RecordConverterBuilder.java	52
src/main/java/com/aliyun/odps/kafka/connect/SinkStatusContext.java	52
src/main/java/com/aliyun/odps/kafka/KafkaWriter.java	46
src/main/assembly/package.xml	39