You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/12/14 09:04:50 UTC
[camel-kafka-connector] 09/15: (chores) Use diamond operators
instead of type specification
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 993b191258a3292d71d1d78ea467268a8d389f60
Author: Otavio Rodolfo Piske <op...@redhat.com>
AuthorDate: Fri Dec 11 17:41:15 2020 +0100
(chores) Use diamond operators instead of type specification
---
.../org/apache/camel/kafkaconnector/syslog/CamelSyslogSinkTask.java | 2 +-
.../org/apache/camel/kafkaconnector/syslog/CamelSyslogSourceTask.java | 2 +-
.../kafkaconnector/transforms/SinkPojoToSchemaAndStructTransform.java | 2 +-
.../kafkaconnector/transforms/SourcePojoToSchemaAndStructTransform.java | 2 +-
4 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/connectors/camel-syslog-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/syslog/CamelSyslogSinkTask.java b/connectors/camel-syslog-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/syslog/CamelSyslogSinkTask.java
index 87df61e..830bee7 100644
--- a/connectors/camel-syslog-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/syslog/CamelSyslogSinkTask.java
+++ b/connectors/camel-syslog-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/syslog/CamelSyslogSinkTask.java
@@ -32,7 +32,7 @@ public class CamelSyslogSinkTask extends CamelNettySinkTask {
}
@Override
protected Map<String, String> getDefaultConfig() {
- Map<String, String> defaultConfig = new HashMap<String, String>();
+ Map<String, String> defaultConfig = new HashMap<>();
defaultConfig.putAll(super.getDefaultConfig());
defaultConfig.put(CamelSinkConnectorConfig.CAMEL_SINK_MARSHAL_CONF, "syslog");
defaultConfig.put(CamelSinkTask.getCamelSinkEndpointConfigPrefix() + "encoders", "#syslogencoder");
diff --git a/connectors/camel-syslog-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/syslog/CamelSyslogSourceTask.java b/connectors/camel-syslog-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/syslog/CamelSyslogSourceTask.java
index bd1a09e..6b80c19 100644
--- a/connectors/camel-syslog-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/syslog/CamelSyslogSourceTask.java
+++ b/connectors/camel-syslog-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/syslog/CamelSyslogSourceTask.java
@@ -32,7 +32,7 @@ public class CamelSyslogSourceTask extends CamelNettySourceTask {
}
@Override
protected Map<String, String> getDefaultConfig() {
- Map<String, String> defaultConfig = new HashMap<String, String>();
+ Map<String, String> defaultConfig = new HashMap<>();
defaultConfig.putAll(super.getDefaultConfig());
defaultConfig.put(CamelSourceConnectorConfig.CAMEL_SOURCE_UNMARSHAL_CONF, "syslog");
defaultConfig.put(CamelSourceTask.getCamelSourceEndpointConfigPrefix() + "decoders", "#syslogdecoder");
diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransform.java b/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransform.java
index ac15280..b9a59cb 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransform.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransform.java
@@ -71,7 +71,7 @@ public class SinkPojoToSchemaAndStructTransform<R extends ConnectRecord<R>> impl
LOG.debug("GenericRecord created: {} \nwith schema: {}", avroGenericRecord, avroGenericRecord.getClass().getName());
- GenericDatumWriter<GenericRecord> writer = new GenericDatumWriter<GenericRecord>(avroGenericRecord.getSchema());
+ GenericDatumWriter<GenericRecord> writer = new GenericDatumWriter<>(avroGenericRecord.getSchema());
Object pojo;
try (ByteArrayOutputStream out = new ByteArrayOutputStream()) {
diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransform.java b/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransform.java
index 128de09..a8651f2 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransform.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransform.java
@@ -80,7 +80,7 @@ public class SourcePojoToSchemaAndStructTransform<R extends ConnectRecord<R>> im
byte[] avroDataByte = cacheEntry.getObjectWriter().writeValueAsBytes(r.value());
Decoder decoder = DecoderFactory.get().binaryDecoder(avroDataByte, null);
org.apache.avro.Schema avroSchema = cacheEntry.getAvroSchemaWrapper().getAvroSchema();
- DatumReader<GenericRecord> datumReader = new GenericDatumReader<GenericRecord>(avroSchema);
+ DatumReader<GenericRecord> datumReader = new GenericDatumReader<>(avroSchema);
GenericRecord genericAvroData = datumReader.read(null, decoder);
connectSchemaAndData = this.avroData.toConnectData(avroSchema, genericAvroData);