com.datastax.oss.driver.api.querybuilder.schema

Interface CreateAggregateStart

public interface CreateAggregateStart

Method Summary

Modifier and Type	Method and Description
CreateAggregateStart	ifNotExists() Adds IF NOT EXISTS to the create aggregate specification.
CreateAggregateStart	orReplace() Adds OR REPLACE to the create aggregate specification.
CreateAggregateStart	withParameter(DataType paramType) Adds a parameter definition in the CREATE AGGREGATE statement.
CreateAggregateStateFunc	withSFunc(CqlIdentifier sfuncName) Adds SFUNC to the create aggregate specification.
default CreateAggregateStateFunc	withSFunc(String sfuncName) Shortcut for withSFunc(CqlIdentifier.fromCql(sfuncName)).

Method Detail

ifNotExists

@NonNull
CreateAggregateStart ifNotExists()

Adds IF NOT EXISTS to the create aggregate specification. This indicates that the aggregate should not be created if it already exists.

orReplace

@NonNull
CreateAggregateStart orReplace()

Adds OR REPLACE to the create aggregate specification. This indicates that the aggregate should replace an existing aggregate with the same name if it exists.

withParameter

@NonNull
CreateAggregateStart withParameter(@NonNull
                                            DataType paramType)

Adds a parameter definition in the CREATE AGGREGATE statement.

Parameter keys are added in the order of their declaration.

To create the data type, use the constants and static methods in DataTypes, or SchemaBuilder.udt(CqlIdentifier, boolean).

withSFunc

@NonNull
CreateAggregateStateFunc withSFunc(@NonNull
                                            CqlIdentifier sfuncName)

Adds SFUNC to the create aggregate specification. This is the state function for each row.

withSFunc

@NonNull
default CreateAggregateStateFunc withSFunc(@NonNull
                                                    String sfuncName)

Shortcut for withSFunc(CqlIdentifier.fromCql(sfuncName)).