Skip to content

Commit

Permalink
fix(#3412): Remove module streampipes-platform-services
Browse files Browse the repository at this point in the history
  • Loading branch information
tenthe committed Jan 9, 2025
1 parent c36e260 commit cab2260
Show file tree
Hide file tree
Showing 5 changed files with 10 additions and 90 deletions.
81 changes: 0 additions & 81 deletions streampipes-platform-services/pom.xml

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
*
*/

package org.apache.streampipes.ps;
package org.apache.streampipes.rest.impl.datalake;

import org.apache.streampipes.rest.core.base.impl.AbstractAuthGuardedRestResource;
import org.apache.streampipes.storage.management.StorageDispatcher;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
*
*/

package org.apache.streampipes.ps;
package org.apache.streampipes.rest.impl.datalake;

import org.apache.streampipes.dataexplorer.api.IDataExplorerSchemaManagement;
import org.apache.streampipes.dataexplorer.management.DataExplorerDispatcher;
Expand All @@ -43,11 +43,11 @@

@RestController
@RequestMapping("/api/v4/datalake/measure")
public class DataLakeMeasureResourceV4 extends AbstractAuthGuardedRestResource {
public class DataLakeMeasureResource extends AbstractAuthGuardedRestResource {

private final IDataExplorerSchemaManagement dataLakeMeasureManagement;

public DataLakeMeasureResourceV4() {
public DataLakeMeasureResource() {
this.dataLakeMeasureManagement = new DataExplorerDispatcher().getDataExplorerManager()
.getSchemaManagement();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
*
*/

package org.apache.streampipes.ps;
package org.apache.streampipes.rest.impl.datalake;

import org.apache.streampipes.dataexplorer.api.IDataExplorerQueryManagement;
import org.apache.streampipes.dataexplorer.api.IDataExplorerSchemaManagement;
Expand Down Expand Up @@ -78,12 +78,12 @@

@RestController
@RequestMapping("/api/v4/datalake")
public class DataLakeResourceV4 extends AbstractRestResource {
public class DataLakeResource extends AbstractRestResource {

private final IDataExplorerQueryManagement dataExplorerQueryManagement;
private final IDataExplorerSchemaManagement dataExplorerSchemaManagement;

public DataLakeResourceV4() {
public DataLakeResource() {
this.dataExplorerSchemaManagement = new DataExplorerDispatcher()
.getDataExplorerManager()
.getSchemaManagement();
Expand All @@ -92,7 +92,7 @@ public DataLakeResourceV4() {
.getQueryManagement(this.dataExplorerSchemaManagement);
}

public DataLakeResourceV4(IDataExplorerQueryManagement dataExplorerQueryManagement) {
public DataLakeResource(IDataExplorerQueryManagement dataExplorerQueryManagement) {
this.dataExplorerQueryManagement = dataExplorerQueryManagement;
this.dataExplorerSchemaManagement = new DataExplorerDispatcher()
.getDataExplorerManager()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,8 @@
* limitations under the License.
*
*/
package org.apache.streampipes.ps;

package org.apache.streampipes.rest.impl.pe;

import org.apache.streampipes.manager.template.AdapterTemplateHandler;
import org.apache.streampipes.manager.template.DataProcessorTemplateHandler;
Expand Down

0 comments on commit cab2260

Please sign in to comment.