Package org.apache.ignite.table

Interface DataStreamerItem<T>

public interface DataStreamerItem<T>
Data streamer item: data and operation type.

  • Method Details

    • get

      T get()
      Gets the data.
      Returns:
      Data.

    • operationType

      DataStreamerOperationType operationType()
      Gets the operation type.
      Returns:
      Operation type.

    • of

      static <T> DataStreamerItem<T> of(T item)
      Creates a new data streamer item with the given data and DataStreamerOperationType.PUT operation type.
      Type Parameters:
      T - Data type.
      Parameters:
      item - Data.
      Returns:
      PUT data streamer item.

    • of

      static <T> DataStreamerItem<T> of(T item, DataStreamerOperationType op)
      Creates a new data streamer item with the given data and operation type.
      Type Parameters:
      T - Data type.
      Parameters:
      item - Data.
      op - Operation type.
      Returns:
      PUT data streamer item.

    • removed

      static <T> DataStreamerItem<T> removed(T item)
      Creates a new data streamer item with the given data and DataStreamerOperationType.REMOVE operation type.
      Type Parameters:
      T - Data type.
      Parameters:
      item - Data.
      Returns:
      REMOVE data streamer item.