Cassandra connector ccreate table
@@ -245,7 +245,7 @@ public class CassandraMetadata
@Override
public void createTable(ConnectorSession session, ConnectorTableMetadata tableMetadata, boolean ignoreExisting)
{
- throw new PrestoException(NOT_SUPPORTED, "CREATE TABLE not yet supported for Cassandra");
+ createTable(tableMetadata);
}
@Override
@@ -273,6 +273,11 @@ public class CassandraMetadata
@Override
public ConnectorOutputTableHandle beginCreateTable(ConnectorSession session, ConnectorTableMetadata tableMetadata, Optional<ConnectorNewTableLayout> layout)
+ {
+ return createTable(tableMetadata);
+ }
+
+ private CassandraOutputTableHandle createTable(ConnectorTableMetadata tableMetadata)
{
ImmutableList.Builder<String> columnNames = ImmutableList.builder();
ImmutableList.Builder<Type> columnTypes = ImmutableList.builder();
