DROP ENTITY

Syntax

DROP ENTITY fully_qualified_entity_name
[IN STORE store_name];

Description

Drops an Entity from the current Store, or a provided Store name. An Entity cannot be dropped if any Relations are defined that depend on it. However, an Entity may be dropped outside of the DeltaStream platform; in which case, the Relations and Queries that depend on it, will fail to progress.

See USE for changing the current Store.

DROP ENTITY cannot be undone. Use it with care!

Arguments

fully_qualified_entity_name

The full name of the Entity to describe.

IN STORE store_name

Optionally, this specifies the Store from which the Entity should be dropped. For case-sensitive names, the name must be wrapped in double quotes, otherwise, the lowercased name will be used.

Examples

Drop a Kafka topic in the current Kafka Store

The following drops a Kafka topic from the current kafka_store Store. Note the Store name:

demodb.public/kafka_store# LIST ENTITIES;

   Entity name
----------------
  pageviews
  pageviews_pb
  customers

demodb.public/kafka_store# DROP ENTITY customers;
demodb.public/kafka_store# LIST ENTITIES;

   Entity name
----------------
  pageviews
  pageviews_pb

Drop a Kinesis data stream in a specific Store

The following drops a Kinesis data stream in a specific store. Note that we specify a store, AltStore, to LIST ENTITIES as well as the DROP ENTITY:

demodb.public/demostore# LIST ENTITIES IN STORE "AltStore";

   Entity name
----------------
  Shipments
  reviews

demodb.public/demostore# DROP ENTITY "Shipments" IN STORE "AltStore";
demodb.public/demostore# LIST ENTITIES IN STORE "AltStore";

   Entity name
----------------
  reviews

Drop a Snowflake database

demodb.public/sfstore# LIST ENTITIES;
       Entity name       
-------------------------
  MY_SNOWFLAKE_DB        
  SNOWFLAKE              
  SNOWFLAKE_SAMPLE_DATA  
demodb.public/sfstore# DROP ENTITY "MY_SNOWFLAKE_DB";
demodb.public/sfstore# LIST ENTITIES;
       Entity name       
-------------------------
  SNOWFLAKE              
  SNOWFLAKE_SAMPLE_DATA  

Drop a Snowflake schema

demodb.public/sfstore# LIST ENTITIES IN "DELTA_STREAMING";
     Entity name      
----------------------
  INFORMATION_SCHEMA  
  MY_SCHEMA           
  PUBLIC              
demodb.public/sfstore# DROP ENTITY "DELTA_STREAMING"."MY_SCHEMA";
demodb.public/sfstore# LIST ENTITIES IN "DELTA_STREAMING";
     Entity name      
----------------------
  INFORMATION_SCHEMA  
  PUBLIC              

Drop a Snowflake table

demodb.public/sfstore# LIST ENTITIES IN "DELTA_STREAMING"."PUBLIC";
    Entity name    
-------------------
  STREAM_DATA_TBL  
  sf_pv_table      
demodb.public/sfstore# DROP ENTITY "DELTA_STREAMING"."PUBLIC".sf_pv_table;
demodb.public/sfstore# LIST ENTITIES IN "DELTA_STREAMING"."PUBLIC";
    Entity name    
-------------------
  STREAM_DATA_TBL  

Drop a Databricks catalog

demodb.public/databricks_store# LIST ENTITIES;
        Entity name
---------------------------
  catalog1
  main
  system
demodb.public/databricks_store# DROP ENTITY catalog1;
demodb.public/databricks_store# LIST ENTITIES;
       Entity name       
-------------------------
  main
  system

Drop a Databricks schema

demodb.public/databricks_store# LIST ENTITIES IN catalog1;
     Entity name
----------------------
  default
  information_schema
  schema1           
demodb.public/databricks_store# DROP ENTITY catalog1.schema1;
demodb.public/databricks_store# LIST ENTITIES IN catalog1;
     Entity name
----------------------
  default
  information_schema        

Drop a Databricks table

demodb.public/databricks_store# LIST ENTITIES IN catalog1.schema1;
  Entity name
---------------
  pageviews
  pv_agg
demodb.public/databricks_store# DROP ENTITY catalog1.schema1.pageviews;
demodb.public/databricks_store# LIST ENTITIES IN catalog1.schema1;
  Entity name
---------------
  pv_agg