kafka-connect-jdbc:Kafka Connect连接器，用于兼容JDBC的数据库 （130个子文件） 
make.bat 7KB io.confluent.connect.jdbc.dialect.DatabaseDialectProvider 720B io.confluent.connect.jdbc.dialect.DatabaseDialectProvider 62B .gitignore 186B
licenses.html 1KB GenericDatabaseDialect.java 55KB JdbcSourceTaskUpdateTest.java 32KB JdbcSourceConnectorConfig.java 30KB DatabaseDialect.java 20KB JdbcSinkConfig.java 16KB GenericDatabaseDialectTest.java 16KB ExpressionBuilder.java 15KB JdbcSourceTask.java 15KB BaseDialectTest.java 14KB JdbcSourceTaskConversionTest.java 12KB JdbcDbWriterTest.java 12KB TimestampIncrementingCriteria.java 12KB TableMonitorThreadTest.java 11KB SybaseDatabaseDialectTest.java 11KB ColumnDefinition.java 10KB FieldsMetadata.java 9KB EmbeddedDerby.java 9KB Db2DatabaseDialectTest.java 9KB PreparedStatementBinderTest.java 9KB DerbyDatabaseDialectTest.java 9KB FieldsMetadataTest.java 9KB SybaseDatabaseDialect.java 9KB DatabaseDialects.java 9KB PostgreSqlDatabaseDialect.java 8KB TimestampIncrementingTableQuerier.java 8KB JdbcSourceConnectorConfigTest.java 8KB JdbcSinkTaskTest.java 8KB JdbcSourceConnectorTest.java 8KB SqliteDatabaseDialectTest.java 8KB JdbcSourceTaskLifecycleTest.java 8KB SqlServerDatabaseDialectTest.java 8KB OracleDatabaseDialectTest.java 8KB MySqlDatabaseDialectTest.java 8KB BufferedRecordsTest.java 7KB DbStructure.java 7KB BufferedRecords.java 7KB TableMonitorThread.java 7KB JdbcSourceConnector.java 7KB BaseDialectTypeTest.java 7KB GenericDatabaseDialectTypeTest.java 7KB SapHanaDatabaseDialectTest.java 7KB DatabaseDialectProvider.java 7KB PostgreSqlDatabaseDialectTest.java 6KB OracleDatabaseDialect.java 6KB IdentifierRules.java 6KB SqliteHelperTest.java 6KB SqlServerDatabaseDialect.java 6KB SchemaMapping.java 6KB VerticaDatabaseDialectTest.java 6KB MySqlDatabaseDialect.java 5KB DerbyDatabaseDialect.java 5KB Db2DatabaseDialect.java 5KB DatabaseDialectsTest.java 5KB TimestampIncrementingCriteriaTest.java 5KB JdbcSourceTaskTestBase.java 5KB PreparedStatementBinder.java 5KB SapHanaDatabaseDialect.java 5KB TableQuerier.java 4KB TimestampIncrementingOffsetTest.java 4KB SqliteDatabaseDialect.java 4KB JdbcDriverInfo.java 4KB JdbcSinkTask.java 4KB BulkTableQuerier.java 4KB CachedConnectionProvider.java 4KB TimestampIncrementingOffset.java 3KB VerticaDatabaseDialect.java 3KB TableId.java 3KB ColumnMapping.java 3KB NumericMappingConfigTest.java 3KB TableDefinitions.java 3KB DropOptions.java 3KB JdbcDbWriter.java 3KB IdentifierRulesTest.java 3KB DatabaseHelper.java 3KB SqliteHelper.java 3KB ColumnId.java 3KB TableDefinition.java 2KB DateTimeUtils.java 2KB CachedConnectionProviderTest.java 2KB JdbcSinkConnector.java 2KB OffsetProtocols.java 2KB DbStructureTest.java 2KB ConnectionProvider.java 2KB DatabaseDialectRecommender.java 2KB SinkRecordField.java 2KB MockTime.java 2KB MockDatabaseDialect.java 1KB StringUtils.java 1KB JdbcSourceTaskConfig.java 1KB SchemaPair.java 1KB Version.java 1KB JdbcSourceConnectorConstants.java 981B BytesUtil.java 979B Jenkinsfile 108B
jdbc.jpg 33KB共 130 条
- 1
- 2
资源评论
