kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject [kafka] branch trunk updated (4943c3f -> fffb9c5)
Date Tue, 29 May 2018 23:37:58 GMT
This is an automated email from the ASF dual-hosted git repository.

ewencp pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 4943c3f  MINOR: reduce commit time on test (#5095)
     add fffb9c5  KAFKA-6913: Add Connect converters and header converters for short, integer,
long, float, and double (KIP-305)

No new revisions were added by this update.

Summary of changes:
 .../kafka/connect/storage/DoubleConverter.java}    |  34 +++----
 .../kafka/connect/storage/FloatConverter.java}     |  34 +++----
 .../kafka/connect/storage/IntegerConverter.java}   |  34 +++----
 .../kafka/connect/storage/LongConverter.java}      |  33 +++----
 .../{StringConverter.java => NumberConverter.java} |  77 ++++++++-------
 .../connect/storage/NumberConverterConfig.java}    |  17 ++--
 .../kafka/connect/storage/ShortConverter.java}     |  34 +++----
 .../kafka/connect/storage/DoubleConverterTest.java |  35 +++----
 .../kafka/connect/storage/FloatConverterTest.java  |  35 +++----
 .../connect/storage/IntegerConverterTest.java      |  29 +++---
 .../kafka/connect/storage/LongConverterTest.java   |  28 +++---
 .../kafka/connect/storage/NumberConverterTest.java | 105 +++++++++++++++++++++
 .../kafka/connect/storage/ShortConverterTest.java  |  36 +++----
 13 files changed, 295 insertions(+), 236 deletions(-)
 copy connect/{transforms/src/main/java/org/apache/kafka/connect/transforms/util/SchemaUtil.java
=> api/src/main/java/org/apache/kafka/connect/storage/DoubleConverter.java} (53%)
 copy connect/{transforms/src/main/java/org/apache/kafka/connect/transforms/util/SchemaUtil.java
=> api/src/main/java/org/apache/kafka/connect/storage/FloatConverter.java} (53%)
 copy connect/{transforms/src/main/java/org/apache/kafka/connect/transforms/util/SchemaUtil.java
=> api/src/main/java/org/apache/kafka/connect/storage/IntegerConverter.java} (52%)
 copy connect/{transforms/src/main/java/org/apache/kafka/connect/transforms/util/SchemaUtil.java
=> api/src/main/java/org/apache/kafka/connect/storage/LongConverter.java} (53%)
 copy connect/api/src/main/java/org/apache/kafka/connect/storage/{StringConverter.java =>
NumberConverter.java} (54%)
 copy connect/{runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java
=> api/src/main/java/org/apache/kafka/connect/storage/NumberConverterConfig.java} (66%)
 copy connect/{transforms/src/main/java/org/apache/kafka/connect/transforms/util/SchemaUtil.java
=> api/src/main/java/org/apache/kafka/connect/storage/ShortConverter.java} (53%)
 copy streams/src/test/java/org/apache/kafka/test/KTableValueGetterStub.java => connect/api/src/test/java/org/apache/kafka/connect/storage/DoubleConverterTest.java
(57%)
 copy streams/src/test/java/org/apache/kafka/test/KTableValueGetterStub.java => connect/api/src/test/java/org/apache/kafka/connect/storage/FloatConverterTest.java
(57%)
 copy clients/src/main/java/org/apache/kafka/common/security/auth/SslAuthenticationContext.java
=> connect/api/src/test/java/org/apache/kafka/connect/storage/IntegerConverterTest.java
(58%)
 copy streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbKeyValueBytesStoreSupplier.java
=> connect/api/src/test/java/org/apache/kafka/connect/storage/LongConverterTest.java (58%)
 create mode 100644 connect/api/src/test/java/org/apache/kafka/connect/storage/NumberConverterTest.java
 copy streams/src/test/java/org/apache/kafka/test/KTableValueGetterStub.java => connect/api/src/test/java/org/apache/kafka/connect/storage/ShortConverterTest.java
(57%)

-- 
To stop receiving notification emails like this one, please contact
ewencp@apache.org.

Mime
View raw message