kafka-connect-hdfs:Kafka Connect HDFS连接器 （164个子文件） 
make.bat 7KB .gitignore 205B
LICENSE.cddl+gpl2.html 40KB LICENSE.javassist.html 25KB WALFile.java 30KB TopicPartitionWriter.java 27KB TopicPartitionWriterTest.java 24KB DataWriter.java 23KB HiveIntegrationAvroTest.java 17KB DataWriterAvroTest.java 16KB HdfsSinkConnectorConfig.java 16KB HiveIntegrationParquetTest.java 14KB TestWithMiniDFSCluster.java 13KB HdfsSinkConnectorConfigTest.java 13KB HdfsSinkTaskTest.java 12KB FailureRecoveryTest.java 9KB FileUtils.java 7KB TestWithSecureMiniDFSCluster.java 7KB SchemaSourceTask.java 7KB CommittedFileFilterTest.java 7KB ParquetHiveUtilTest.java 6KB AvroHiveUtilTest.java 6KB FSWAL.java 5KB HdfsSinkTask.java 5KB DataWriterJsonTest.java 5KB MemoryStorage.java 5KB HdfsSinkConnectorTestBase.java 5KB HdfsStorage.java 4KB WALFileTest.java 4KB ParquetHiveUtil.java 4KB JsonRecordWriterProvider.java 4KB AvroHiveUtil.java 4KB FormatAPIDataWriterCompatibilityTest.java 4KB AvroRecordWriterProvider.java 4KB FormatAPITopicPartitionWriterCompatibilityTest.java 4KB ParquetRecordWriterProvider.java 3KB WALTest.java 3KB TimeBasedPartitionerTest.java 3KB HdfsSinkTaskWithSecureHDFSTest.java 3KB DataWriterStringTest.java 3KB StringRecordWriterProvider.java 3KB OldFormat.java 3KB SchemaUtils.java 3KB HiveExec.java 3KB HiveTestUtils.java 3KB MemoryWAL.java 2KB JsonFormat.java 2KB HdfsSinkConnector.java 2KB ParquetFileReader.java 2KB AvroFileReader.java 2KB HiveUtil.java 2KB HourlyPartitionerTest.java 2KB StringFormat.java 2KB HiveTestBase.java 2KB DailyPartitionerTest.java 2KB DataWriterParquetTest.java 2KB FSWALTest.java 2KB JsonDataFileReader.java 2KB OldRecordWriterWrapper.java 2KB ParquetFormat.java 2KB AvroFormat.java 2KB SchemaSourceConnector.java 2KB StringDataFileReader.java 2KB MemoryRecordWriter.java 2KB DateTimeUtilsTest.java 2KB TopicPartitionCommittedFileFilter.java 2KB StringFileReader.java 2KB JsonFileReader.java 2KB TimeUtils.java 2KB AvroHiveFactory.java 2KB StorageFactory.java 1KB TopicCommittedFileFilter.java 1KB HdfsSinkConnectorConstants.java 1KB ParquetHiveFactory.java 1KB MemoryRecordWriterProvider.java 1KB Partitioner.java 1KB Version.java 1KB WALEntry.java 1KB SchemaFileReader.java 1KB MemoryFormat.java 1KB HiveMetaStore.java 1KB HiveMetaStoreException.java 1KB RecordWriterProvider.java 1KB PartitionException.java 1KB Format.java 1KB CommittedFileFilter.java 1KB ParquetDataFileReader.java 1KB AvroDataFileReader.java 1022B TimeBasedPartitioner.java 978B DefaultPartitioner.java 974B HourlyPartitioner.java 972B DailyPartitioner.java 970B FieldPartitioner.java 970B WALConstants.java 920B Storage.java 891B Data.java 883B RecordWriter.java 862B DateTimeUtils.java 842B WAL.java 719B Compatibility.java 714B共 164 条
- 1
- 2
资源评论
向朝卿
- 粉丝: 40
- 资源: 4443
最新资源
- java毕业设计-基于SSM框架的传统服饰文化体验平台【代码+部署教程】
- 优化领域的模拟退火算法详解与实战
- NewFileTime-x64.zip.fgpg
- 基于Python和HTML的Chinese-estate-helper房地产爬虫及可视化设计源码
- 基于SpringBoot2.7.7的当当书城Java后端设计源码
- 基于Python和Go语言的开发工具集成与验证设计源码
- 基于Python与JavaScript的国内供应商管理系统设计源码
- aspose.words-20.12-jdk17
- 基于czsc库的Python时间序列分析设计源码
- 基于Java、CSS、JavaScript、HTML的跨语言智联平台设计源码
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
