removed code related to stream entity

core/src/main/java/org/polypheny/db/catalog/Catalog.java

@@ -1933,8 +1933,8 @@ public enum EntityType {
         ENTITY( 1 ),
         SOURCE( 2 ),
         VIEW( 3 ),
-        MATERIALIZED_VIEW( 4 ),
-        STREAM(5);
+        MATERIALIZED_VIEW( 4 );
+        //STREAM(5);
 
         private final int id;
 

core/src/main/java/org/polypheny/db/ddl/DdlManager.java

@@ -476,8 +476,6 @@ public static DdlManager getInstance() {
 
     public abstract void createCollection( long schemaId, String name, boolean ifNotExists, List<DataStore> stores, PlacementType placementType, Statement statement ) throws EntityAlreadyExistsException;
 
-    public abstract void createStreamCollection(long schemaId, String name, boolean ifNotExists, List<DataStore> stores, PlacementType placementType, Statement statement ) throws EntityAlreadyExistsException;
-
     public abstract void addCollectionPlacement( long namespaceId, String name, List<DataStore> stores, Statement statement );
 
     /**

dbms/src/main/java/org/polypheny/db/ddl/DdlManagerImpl.java

@@ -2293,56 +2293,6 @@ public void createCollection( long schemaId, String name, boolean ifNotExists, L
     }
 
 
-    @Override
-    public void createStreamCollection( long schemaId, String name, boolean ifNotExists, List<DataStore> stores, PlacementType placementType, Statement statement ) throws EntityAlreadyExistsException {
-        name = adjustNameIfNeeded( name, schemaId );
-
-        if ( assertEntityExists( schemaId, name, ifNotExists ) ) {
-            return;
-        }
-
-        if ( stores == null ) {
-            // Ask router on which store(s) the table should be placed
-            stores = RoutingManager.getInstance().getCreatePlacementStrategy().getDataStoresForNewTable();
-        }
-
-        long collectionId;
-        long partitionId;
-        try {
-            collectionId = catalog.addCollectionLogistics( schemaId, name, stores, false );
-            partitionId = catalog.getPartitionGroups( collectionId ).get( 0 ).id;
-        } catch ( GenericCatalogException e ) {
-            throw new RuntimeException( e );
-        }
-
-        catalog.addCollection(
-                collectionId,
-                name,
-                schemaId,
-                statement.getPrepareContext().getCurrentUserId(),
-                EntityType.STREAM,
-                true );
-
-        // Initially create DataPlacement containers on every store the table should be placed.
-        CatalogCollection catalogCollection = catalog.getCollection( collectionId );
-
-        // Trigger rebuild of schema; triggers schema creation on adapters
-        PolySchemaBuilder.getInstance().getCurrent();
-
-        for ( DataStore store : stores ) {
-            catalog.addCollectionPlacement(
-                    store.getAdapterId(),
-                    catalogCollection.id,
-                    PlacementType.AUTOMATIC );
-
-            afterDocumentLogistics( store, collectionId );
-
-            store.createCollection( statement.getPrepareContext(), catalogCollection, store.getAdapterId() );
-        }
-
-    }
-
-
     private boolean assertEntityExists( long namespaceId, String name, boolean ifNotExists ) throws EntityAlreadyExistsException {
         // Check if there is already an entity with this name
         if ( catalog.checkIfExistsEntity( namespaceId, name ) ) {

dbms/src/main/java/org/polypheny/db/schema/PolySchemaBuilder.java

@@ -211,14 +211,6 @@ private void buildDocumentLogical( AbstractPolyphenyDbSchema polyphenyDbSchema,
                             catalogEntity.getNamespaceName(),
                             catalogEntity.name,
                             AlgDataTypeImpl.proto( fieldInfo.build() ) );
-
-                } else if ( catalogEntity.entityType == EntityType.STREAM ) {
-                    entity = new LogicalStreamCollection(
-                            catalogEntity.id,
-                            catalogEntity.getNamespaceName(),
-                            catalogEntity.name,
-                            AlgDataTypeImpl.proto( fieldInfo.build() ) );
-
                 } else {
                     throw new RuntimeException( "Unhandled table type: " + catalogEntity.entityType.name() );
                 }