diff --git a/src/main/java/com/noorq/casser/core/operation/AbstractStatementOperation.java b/src/main/java/com/noorq/casser/core/operation/AbstractStatementOperation.java index e613561..41c6bc9 100644 --- a/src/main/java/com/noorq/casser/core/operation/AbstractStatementOperation.java +++ b/src/main/java/com/noorq/casser/core/operation/AbstractStatementOperation.java @@ -35,13 +35,22 @@ public abstract class AbstractStatementOperation filter : filters) { where.and(filter.getClause(sessionOps.getValuePreparer())); } + if (this.ttl != null) { + delete.using(QueryBuilder.ttl(this.ttl[0])); + } + if (this.timestamp != null) { + delete.using(QueryBuilder.timestamp(this.timestamp[0])); + } + return delete; } @@ -61,4 +77,20 @@ public final class DeleteOperation extends AbstractFilterOperation> values = new ArrayList>(); private final boolean ifNotExists; + private int[] ttl; + private long[] timestamp; + public InsertOperation(AbstractSessionOperations sessionOperations, boolean ifNotExists) { super(sessionOperations); @@ -112,6 +115,13 @@ public final class InsertOperation extends AbstractOperation extends AbstractFilterStreamOperation