Package org.apache.kafka.connect.header

Class ConnectHeaders

java.lang.Object
org.apache.kafka.connect.header.ConnectHeaders
All Implemented Interfaces:
Iterable<Header>, Headers
public class ConnectHeaders
extends Object
implements Headers
A basic Headers implementation.

  • Constructor Details

    • ConnectHeaders

      public ConnectHeaders()

    • ConnectHeaders

      public ConnectHeaders​(Iterable<Header> original)

  • Method Details

    • size

      public int size()
      Description copied from interface: Headers
      Get the number of headers in this object.
      Specified by:
      size in interface Headers
      Returns:
      the number of headers; never negative

    • isEmpty

      public boolean isEmpty()
      Description copied from interface: Headers
      Determine whether this object has no headers.
      Specified by:
      isEmpty in interface Headers
      Returns:
      true if there are no headers, or false if there is at least one header

    • clear

      public Headers clear()
      Description copied from interface: Headers
      Removes all headers from this object.
      Specified by:
      clear in interface Headers
      Returns:
      this object to facilitate chaining multiple methods; never null

    • add

      public Headers add​(Header header)
      Description copied from interface: Headers
      Add the given Header to this collection.
      Specified by:
      add in interface Headers
      Parameters:
      header - the header; may not be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • addWithoutValidating

      protected Headers addWithoutValidating​(String key, Object value, Schema schema)

    • add

      public Headers add​(String key, SchemaAndValue schemaAndValue)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and value.
      Specified by:
      add in interface Headers
      Parameters:
      key - the header's key; may not be null
      schemaAndValue - the SchemaAndValue for the header; may be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • add

      public Headers add​(String key, Object value, Schema schema)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and value.
      Specified by:
      add in interface Headers
      Parameters:
      key - the header's key; may not be null
      value - the header's value; may be null
      schema - the schema for the header's value; may not be null if the value is not null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • addString

      public Headers addString​(String key, String value)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and value.
      Specified by:
      addString in interface Headers
      Parameters:
      key - the header's key; may not be null
      value - the header's value; may be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • addBytes

      public Headers addBytes​(String key, byte[] value)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and value.
      Specified by:
      addBytes in interface Headers
      Parameters:
      key - the header's key; may not be null
      value - the header's value; may be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • addBoolean

      public Headers addBoolean​(String key, boolean value)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and value.
      Specified by:
      addBoolean in interface Headers
      Parameters:
      key - the header's key; may not be null
      value - the header's value; may be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • addByte

      public Headers addByte​(String key, byte value)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and value.
      Specified by:
      addByte in interface Headers
      Parameters:
      key - the header's key; may not be null
      value - the header's value; may be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • addShort

      public Headers addShort​(String key, short value)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and value.
      Specified by:
      addShort in interface Headers
      Parameters:
      key - the header's key; may not be null
      value - the header's value; may be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • addInt

      public Headers addInt​(String key, int value)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and value.
      Specified by:
      addInt in interface Headers
      Parameters:
      key - the header's key; may not be null
      value - the header's value; may be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • addLong

      public Headers addLong​(String key, long value)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and value.
      Specified by:
      addLong in interface Headers
      Parameters:
      key - the header's key; may not be null
      value - the header's value; may be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • addFloat

      public Headers addFloat​(String key, float value)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and value.
      Specified by:
      addFloat in interface Headers
      Parameters:
      key - the header's key; may not be null
      value - the header's value; may be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • addDouble

      public Headers addDouble​(String key, double value)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and value.
      Specified by:
      addDouble in interface Headers
      Parameters:
      key - the header's key; may not be null
      value - the header's value; may be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • addList

      public Headers addList​(String key, List<?> value, Schema schema)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and value.
      Specified by:
      addList in interface Headers
      Parameters:
      key - the header's key; may not be null
      value - the header's value; may be null
      schema - the schema describing the list value; may not be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • addMap

      public Headers addMap​(String key, Map<?,​?> value, Schema schema)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and value.
      Specified by:
      addMap in interface Headers
      Parameters:
      key - the header's key; may not be null
      value - the header's value; may be null
      schema - the schema describing the map value; may not be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • addStruct

      public Headers addStruct​(String key, Struct value)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and value.
      Specified by:
      addStruct in interface Headers
      Parameters:
      key - the header's key; may not be null
      value - the header's value; may be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • addDecimal

      public Headers addDecimal​(String key, BigDecimal value)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and Decimal value.
      Specified by:
      addDecimal in interface Headers
      Parameters:
      key - the header's key; may not be null
      value - the header's Decimal value; may be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • addDate

      public Headers addDate​(String key, Date value)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and Date value.
      Specified by:
      addDate in interface Headers
      Parameters:
      key - the header's key; may not be null
      value - the header's Date value; may be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • addTime

      public Headers addTime​(String key, Date value)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and Time value.
      Specified by:
      addTime in interface Headers
      Parameters:
      key - the header's key; may not be null
      value - the header's Time value; may be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • addTimestamp

      public Headers addTimestamp​(String key, Date value)
      Description copied from interface: Headers
      Add to this collection a Header with the given key and Timestamp value.
      Specified by:
      addTimestamp in interface Headers
      Parameters:
      key - the header's key; may not be null
      value - the header's Timestamp value; may be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • lastWithName

      public Header lastWithName​(String key)
      Description copied from interface: Headers
      Return the last Header with the specified key.
      Specified by:
      lastWithName in interface Headers
      Parameters:
      key - the key for the header; may not be null
      Returns:
      the last Header, or null if there are no headers with the specified key

    • allWithName

      public Iterator<Header> allWithName​(String key)
      Description copied from interface: Headers
      Get the collection of Header objects whose keys all match the specified key.
      Specified by:
      allWithName in interface Headers
      Parameters:
      key - the key; may not be null
      Returns:
      the iterator over headers with the specified key; may be null if there are no headers with the specified key

    • iterator

      public Iterator<Header> iterator()
      Specified by:
      iterator in interface Iterable<Header>

    • remove

      public Headers remove​(String key)
      Description copied from interface: Headers
      Removes all Header objects whose key matches the specified key.
      Specified by:
      remove in interface Headers
      Parameters:
      key - the key; may not be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • retainLatest

      public Headers retainLatest()
      Description copied from interface: Headers
      Removes all but the last Header object with each key.
      Specified by:
      retainLatest in interface Headers
      Returns:
      this object to facilitate chaining multiple methods; never null

    • retainLatest

      public Headers retainLatest​(String key)
      Description copied from interface: Headers
      Removes all but the latest Header objects whose key matches the specified key.
      Specified by:
      retainLatest in interface Headers
      Parameters:
      key - the key; may not be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • apply

      public Headers apply​(String key, Headers.HeaderTransform transform)
      Description copied from interface: Headers
      Get all Headers with the given key, apply the transform to each and store the result in place of the original.
      Specified by:
      apply in interface Headers
      Parameters:
      key - the header's key; may not be null
      transform - the transform to apply; may not be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • apply

      public Headers apply​(Headers.HeaderTransform transform)
      Description copied from interface: Headers
      Get all Headers, apply the transform to each and store the result in place of the original.
      Specified by:
      apply in interface Headers
      Parameters:
      transform - the transform to apply; may not be null
      Returns:
      this object to facilitate chaining multiple methods; never null

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • equals

      public boolean equals​(Object obj)
      Overrides:
      equals in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • duplicate

      public ConnectHeaders duplicate()
      Description copied from interface: Headers
      Create a copy of this Headers object. The new copy will contain all of the same Header objects as this object.
      Specified by:
      duplicate in interface Headers
      Returns:
      the copy; never null