Fork me on GitHub

CPD Results

The following document contains the results of PMD's CPD 7.17.0.

Duplications

File Project Line
io/aiven/commons/kafka/connector/source/extractor/CsvExtractorTest.java Aiven source framework for connectors on Apache Kafka Tests 259
io/aiven/commons/kafka/connector/source/extractor/CsvExtractorTest.java Aiven source framework for connectors on Apache Kafka Tests 328
final String nativeItem = CsvTestDataFixture.generateCsvRecords(1);
    final EvolvingSourceRecord sourceRecord = createEvolvingSourceRecord(nativeItem);

    final List<SchemaAndValue> records = extractor.generateRecords(sourceRecord).toList();
    assertThat(records.size()).isEqualTo(1);
    Schema schema = records.get(0).schema();
    List<Field> fields = schema.fields();
    assertThat(fields).hasSize(4);
    assertThat(fields.get(0).name()).isEqualTo("one");
    assertThat(fields.get(1).name()).isEqualTo("two");
    assertThat(fields.get(2).name()).isEqualTo("three");
    assertThat(fields.get(3).name()).isEqualTo("four");

    Map<String, String> values = (Map) records.get(0).value();
    assertThat(values.get("one")).isEqualTo("0");
    assertThat(values.get("two")).isEqualTo(CsvTestDataFixture.TEST_MESSAGE);
    assertThat(values.get("three")).isEqualTo(CsvTestDataFixture.MESSAGE_PREFIX + "0");
    assertThat(values.get("four")).isEqualTo("");
  }

  @Test
  void tooFewHeadersTest() throws Exception {
File Project Line
io/aiven/commons/kafka/connector/source/lookback/BufferTest.java Aiven source framework for connectors on Apache Kafka Tests 39
io/aiven/commons/kafka/connector/source/lookback/BufferTest.java Aiven source framework for connectors on Apache Kafka Tests 73
void addTest() {
    assertThat(underTest.contains("aKey")).isFalse();
    underTest.add("aKey");
    assertThat(underTest.contains("aKey")).isTrue();
    underTest.add("bKey");
    assertThat(underTest.contains("aKey")).isTrue();
    assertThat(underTest.contains("bKey")).isTrue();
    underTest.add("cKey");
    assertThat(underTest.contains("aKey")).isTrue();
    assertThat(underTest.contains("bKey")).isTrue();
    assertThat(underTest.contains("cKey")).isTrue();
    underTest.add("dKey");
    assertThat(underTest.contains("aKey")).isFalse();
    assertThat(underTest.contains("bKey")).isTrue();
    assertThat(underTest.contains("cKey")).isTrue();
    assertThat(underTest.contains("dKey")).isTrue();
  }

  @Override
  @Test
  void getTest() {
File Project Line
io/aiven/commons/kafka/connector/source/extractor/CsvExtractorTest.java Aiven source framework for connectors on Apache Kafka Tests 137
io/aiven/commons/kafka/connector/source/extractor/CsvExtractorTest.java Aiven source framework for connectors on Apache Kafka Tests 163
assertThat(records.size()).isEqualTo(1);
    Schema schema = records.get(0).schema();
    List<Field> fields = schema.fields();
    assertThat(fields).hasSize(3);
    assertThat(fields.get(0).name()).isEqualTo("field0");
    assertThat(fields.get(1).name()).isEqualTo("field1");
    assertThat(fields.get(2).name()).isEqualTo("field2");

    Map<String, String> values = (Map) records.get(0).value();
    assertThat(values.get("field0")).isEqualTo("1");
    assertThat(values.get("field1")).isEqualTo("hi");
    assertThat(values.get("field2")).isEqualTo(CsvTestDataFixture.MESSAGE_PREFIX + "1");
File Project Line
io/aiven/commons/kafka/connector/source/extractor/CsvExtractorTest.java Aiven source framework for connectors on Apache Kafka Tests 289
io/aiven/commons/kafka/connector/source/extractor/CsvExtractorTest.java Aiven source framework for connectors on Apache Kafka Tests 361
+ CsvTestDataFixture.generateCsvRecord(2, "bye")
            + ",more data";
    final EvolvingSourceRecord sourceRecord = createEvolvingSourceRecord(nativeItem);

    final List<SchemaAndValue> records = extractor.generateRecords(sourceRecord).toList();
    assertThat(records.size()).isEqualTo(2);
    Schema schema = records.get(0).schema();
    List<Field> fields = schema.fields();
    assertThat(fields).hasSize(3);
    assertThat(fields.get(0).name()).isEqualTo("one");
    assertThat(fields.get(1).name()).isEqualTo("two");
    assertThat(fields.get(2).name()).isEqualTo("value");
File Project Line
io/aiven/commons/kafka/connector/source/extractor/CsvExtractorTest.java Aiven source framework for connectors on Apache Kafka Tests 194
io/aiven/commons/kafka/connector/source/extractor/CsvExtractorTest.java Aiven source framework for connectors on Apache Kafka Tests 228
CsvTestDataFixture.generateCsvRecord(1, "hi")
            + "\n"
            + CsvTestDataFixture.generateCsvRecord(2, "bye")
            + ",more data";
    final EvolvingSourceRecord sourceRecord = createEvolvingSourceRecord(nativeItem);

    final List<SchemaAndValue> records = extractor.generateRecords(sourceRecord).toList();
    assertThat(records.size()).isEqualTo(2);
    Schema schema = records.get(1).schema();
    List<Field> fields = schema.fields();
    assertThat(fields).hasSize(4);
    assertThat(fields.get(0).name()).isEqualTo("field0");