Package com.dtsx.astra.sdk.cassio

Class ClusteredTable

java.lang.Object

com.dtsx.astra.sdk.cassio.AbstractCassandraTable<ClusteredRecord>

com.dtsx.astra.sdk.cassio.ClusteredTable

public class ClusteredTable
extends AbstractCassandraTable<ClusteredRecord>

Table representing persistence for LangChain operations

Field Summary

Fields inherited from class com.dtsx.astra.sdk.cassio.AbstractCassandraTable

ATTRIBUTES_BLOB, BODY_BLOB, COLUMN_SIMILARITY, cqlSession, DEFAULT_RECORD_COUNT, keyspaceName, METADATA_S, PARTITION_ID, ROW_ID, SAI_INDEX_CLASSNAME, tableName, VECTOR

Constructor Summary

Constructors

Constructor	Description
ClusteredTable(@NonNull com.datastax.oss.driver.api.core.CqlSession session, @NonNull String keyspaceName, @NonNull String tableName)	Constructor with the mandatory parameters.

Method Summary

Modifier and Type	Method	Description
void	create()	Create table if not exist.
void	delete(@NonNull String partitionId, @NonNull UUID rowId)	Delete one row.
void	deletePartition(@NonNull String partitionId)	Delete Partition.
Optional<ClusteredRecord>	findById(String partition, UUID rowId)	Find a row by its id.
List<ClusteredRecord>	findPartition(@NonNull String partitionDd)	Find a partition.
void	insert(@NonNull String partitionId, @NonNull UUID rowId, @NonNull String bodyBlob)	Insert Row.
ClusteredRecord	mapRow(@NonNull com.datastax.oss.driver.api.core.cql.Row row)	Should be table to map from a Cassandra row to a record.
void	put(@NonNull ClusteredRecord row)	Upsert a row of the table.
void	upsertPartition(List<ClusteredRecord> rows)	Update the history in one go.

Methods inherited from class com.dtsx.astra.sdk.cassio.AbstractCassandraTable

clear, delete, getCqlSession, putAsync

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ClusteredTable

public ClusteredTable(@NonNull
 @NonNull com.datastax.oss.driver.api.core.CqlSession session,
 @NonNull
 @NonNull String keyspaceName,
 @NonNull
 @NonNull String tableName)

Constructor with the mandatory parameters.

Parameters:

session - cassandra Session

keyspaceName - keyspace name

tableName - table name

Method Details

create

public void create()

Create table if not exist.

Specified by:

create in class AbstractCassandraTable<ClusteredRecord>

put

public void put(@NonNull
 @NonNull ClusteredRecord row)

Upsert a row of the table.

Specified by:

put in class AbstractCassandraTable<ClusteredRecord>

Parameters:

row - current row

mapRow

public ClusteredRecord mapRow(@NonNull
 @NonNull com.datastax.oss.driver.api.core.cql.Row row)

Should be table to map from a Cassandra row to a record.

Specified by:

mapRow in class AbstractCassandraTable<ClusteredRecord>

Parameters:

row - current cassandra row

Returns:

current record

findPartition

public List<ClusteredRecord> findPartition(@NonNull
 @NonNull String partitionDd)

Find a partition.

Parameters:

partitionDd - partition id

Returns:

list of rows

upsertPartition

public void upsertPartition(List<ClusteredRecord> rows)

Update the history in one go.

Parameters:

rows - current rows.

findById

public Optional<ClusteredRecord> findById(String partition,
 UUID rowId)

Find a row by its id.

Parameters:

partition - partition id

rowId - row id

Returns:

record if exists

deletePartition

public void deletePartition(@NonNull
 @NonNull String partitionId)

Delete Partition.

Parameters:

partitionId - delete the whole partition

delete

public void delete(@NonNull
 @NonNull String partitionId,
 @NonNull
 @NonNull UUID rowId)

Delete one row.

Parameters:

partitionId - current session

rowId - message id

insert

public void insert(@NonNull
 @NonNull String partitionId,
 @NonNull
 @NonNull UUID rowId,
 @NonNull
 @NonNull String bodyBlob)

Insert Row.

Parameters:

partitionId - partition id

rowId - rowId

bodyBlob - body