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 FieldPartitioner.java 970B DailyPartitioner.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
资源评论
向朝卿
- 粉丝: 42
- 资源: 4443
最新资源
- 柯尼卡美能达Bizhub C364e打印机驱动下载
- CMake 入门实战的源代码
- c7383c5d0009dfc59e9edf595bb0bcd0.zip
- 柯尼卡美能达Bizhub C266打印机驱动下载
- java游戏之我当皇帝那些年.zip开发资料
- 基于Matlab的汉明码(Hamming Code)纠错传输以及交织编码(Interleaved coding)仿真.zip
- 中国省级新质生产力发展指数数据（任宇新版本）2010-2023年.txt
- 基于Matlab的2Q-FSK移频键控通信系统仿真.zip
- 使用C++实现的常见算法
- travel-web-springboot【程序员VIP专用】.zip
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
