public Channel()

in asterix-bad/src/main/java/org/apache/asterix/bad/metadata/Channel.java [53:80]

• 28 lines of code
• 3 McCabe index (conditional complexity)

    public Channel(DataverseName dataverseName, String channelName, String subscriptionsDataset, String resultsDataset,
            FunctionSignature function, String duration, List<List<Triple<DataverseName, String, String>>> dependencies,
            String channelBody) {
        this.channelId = new EntityId(BADConstants.RUNTIME_ENTITY_CHANNEL, dataverseName, channelName);
        this.function = function;
        this.duration = duration;
        this.resultsDatasetName = resultsDataset;
        this.subscriptionsDatasetName = subscriptionsDataset;
        this.channelBody = channelBody;
        if (this.function.getDataverseName() == null) {
            this.function.setDataverseName(dataverseName);
        }
        functionAsPath = new Triple<>(this.function.getDataverseName(), this.function.getName(),
                Integer.toString(this.function.getArity()));
        if (dependencies == null) {
            this.dependencies = new ArrayList<>();
            this.dependencies.add(new ArrayList<>());
            this.dependencies.add(new ArrayList<>());
            Triple<DataverseName, String, String> resultsList = new Triple<>(dataverseName, resultsDatasetName, null);
            Triple<DataverseName, String, String> subscriptionList =
                    new Triple<>(dataverseName, subscriptionsDatasetName, null);
            this.dependencies.get(0).add(resultsList);
            this.dependencies.get(0).add(subscriptionList);
            this.dependencies.get(1).add(functionAsPath);
        } else {
            this.dependencies = dependencies;
        }
    }