Class KeyClient

java.lang.Object
io.stargate.sdk.rest.KeyClient

public class KeyClient extends Object
Operation on a record.
Author:
Cedrick LUNVEN (@clunven)
  • Field Details

    • primaryKeyResource

      public Function<ServiceHttp,String> primaryKeyResource
      /v2/schemas/keyspaces/{keyspace}/tables/{tableName}/{key1}/...{keyn}
  • Constructor Details

    • KeyClient

      public KeyClient(LoadBalancedHttpClient stargateHttpClient, TableClient tableClient, Object... keys)
      Full constructor.
      Parameters:
      stargateHttpClient - stargateHttpClient
      tableClient - TableClient
      keys - Object
  • Method Details

    • findAll

      public Stream<ObjectMap> findAll()
      Retrieve a set of Rows from Primary key value.
      Returns:
      a list of rows
    • findAll

      public <T> Stream<T> findAll(RowMapper<T> rowMapper)
      Marshall output as objects.
      Type Parameters:
      T - current row
      Parameters:
      rowMapper - row mapper
      Returns:
      target return
    • findFirstPage

      public RowResultPage findFirstPage(int pageSize)
      Find the first page (when we know there are not a lot)
      Parameters:
      pageSize - list of page
      Returns:
      returned a list
    • findPage

      public RowResultPage findPage(int pageSize, String pageState)
      Search for a page.
      Parameters:
      pageSize - size of expected page
      pageState - cursor in research
      Returns:
      a page of results
    • findPage

      public RowResultPage findPage(QueryWithKey query)
      Retrieve a set of Rows from Primary key value.
      Parameters:
      query - QueryWithKey
      Returns:
      RowResultPage
      See Also:
    • findPage

      public <T> Page<T> findPage(QueryWithKey query, RowMapper<T> mapper)
      Retrieve a set of Rows from Primary key value.
      Type Parameters:
      T - T
      Parameters:
      query - QueryWithKey
      mapper - RowMapper
      Returns:
      ResultPage
      See Also:
    • delete

      public void delete()
      Delete by key
      See Also:
    • update

      public void update(Map<String,Object> newRecord)
      update
      Parameters:
      newRecord - Map
      See Also:
    • replace

      public void replace(Map<String,Object> newRecord)
      replace
      Parameters:
      newRecord - Map
      See Also: