Skip to content
Permalink
Browse files
Initial Commit
  • Loading branch information
sjaco002 committed Sep 14, 2016
0 parents commit 409c3e792a691c5c7cd8bf0a20011d2ce42c1fa4
Show file tree
Hide file tree
Showing 74 changed files with 5,016 additions and 0 deletions.
@@ -0,0 +1,44 @@
invIndex*
opttest
primaryBTree*
target
.classpath
.settings
.project
ClusterControllerService
rttest
mdtest
ittest
asterix_logs
build
*-coredump
*.pyc
*.iml
.idea
*.ipr
*.iws
git.properties
actual
exception
expected
teststore1
teststore2
dev1
dev2
dev3
dev4
derby.log
hadoop-conf-tmp
metastore_db
teststore
output
tmp
dist
*~
.DS_Store
*.swp
.m2*
ß
/target/
/target/
/target/
211 pom.xml
@@ -0,0 +1,211 @@
<!--
! Licensed to the Apache Software Foundation (ASF) under one
! or more contributor license agreements. See the NOTICE file
! distributed with this work for additional information
! regarding copyright ownership. The ASF licenses this file
! to you under the Apache License, Version 2.0 (the
! "License"); you may not use this file except in compliance
! with the License. You may obtain a copy of the License at
!
! http://www.apache.org/licenses/LICENSE-2.0
!
! Unless required by applicable law or agreed to in writing,
! software distributed under the License is distributed on an
! "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
! KIND, either express or implied. See the License for the
! specific language governing permissions and limitations
! under the License.
!-->
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.asterix</groupId>
<artifactId>apache-asterixdb</artifactId>
<version>0.8.9-SNAPSHOT</version>
</parent>
<artifactId>asterix-opt</artifactId>
<properties>
<asterix.version>0.8.9-SNAPSHOT</asterix.version>
</properties>
<build>
<plugins>
<plugin>
<groupId>org.apache.asterix</groupId>
<artifactId>asterix-grammar-extension-maven-plugin</artifactId>
<version>${asterix.version}</version>
<configuration>
<base>${project.basedir}</base>
<gbase>../asterix-lang-aql/src/main/javacc/AQL.jj</gbase>
<gextension>src/main/resources/lang-extension/lang.txt</gextension>
<output>target/generated-resources/javacc/grammar.jj</output>
<parserClassName>BADAQLParser</parserClassName>
<packageName>org.apache.asterix.bad.lang</packageName>
</configuration>
<executions>
<execution>
<phase>generate-sources</phase>
<goals>
<goal>grammarix</goal>
</goals>
</execution>
</executions>
</plugin>
<plugin>
<groupId>org.codehaus.mojo</groupId>
<artifactId>javacc-maven-plugin</artifactId>
<version>2.6</version>
<executions>
<execution>
<id>javacc</id>
<goals>
<goal>javacc</goal>
</goals>
<configuration>
<isStatic>false</isStatic>
<javaUnicodeEscape>true</javaUnicodeEscape>
<sourceDirectory>target/generated-resources/javacc</sourceDirectory>
</configuration>
</execution>
<execution>
<id>javacc-jjdoc</id>
<goals>
<goal>jjdoc</goal>
</goals>
<phase>process-sources</phase>
</execution>
</executions>
</plugin>
<plugin>
<groupId>org.codehaus.mojo</groupId>
<artifactId>build-helper-maven-plugin</artifactId>
<version>1.9</version>
<executions>
<execution>
<id>add-source</id>
<phase>generate-sources</phase>
<goals>
<goal>add-source</goal>
</goals>
<configuration>
<sources>
<source>${project.build.directory}/generated-sources/javacc/</source>
</sources>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
<pluginManagement>
<plugins>
<!--This plugin's configuration is used to store Eclipse m2e settings only. It has no influence on the Maven build itself.-->
<plugin>
<groupId>org.eclipse.m2e</groupId>
<artifactId>lifecycle-mapping</artifactId>
<version>1.0.0</version>
<configuration>
<lifecycleMappingMetadata>
<pluginExecutions>
<pluginExecution>
<pluginExecutionFilter>
<groupId>org.apache.asterix</groupId>
<artifactId>asterix-grammar-extension-maven-plugin</artifactId>
<versionRange>[${asterix.version},)</versionRange>
<goals>
<goal>grammarix</goal>
</goals>
</pluginExecutionFilter>
<action>
<ignore></ignore>
</action>
</pluginExecution>
<pluginExecution>
<pluginExecutionFilter>
<groupId>org.codehaus.mojo</groupId>
<artifactId>javacc-maven-plugin</artifactId>
<versionRange>[2.6,)</versionRange>
<goals>
<goal>javacc</goal>
</goals>
</pluginExecutionFilter>
<action>
<ignore></ignore>
</action>
</pluginExecution>
</pluginExecutions>
</lifecycleMappingMetadata>
</configuration>
</plugin>
</plugins>
</pluginManagement>
</build>
<dependencies>
<dependency>
<groupId>org.apache.asterix</groupId>
<artifactId>asterix-om</artifactId>
<version>${project.version}</version>
<type>jar</type>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.hyracks</groupId>
<artifactId>hyracks-test-support</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.asterix</groupId>
<artifactId>asterix-runtime</artifactId>
<version>${project.version}</version>
<type>jar</type>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.hyracks</groupId>
<artifactId>algebricks-compiler</artifactId>
</dependency>
<dependency>
<groupId>org.apache.hyracks</groupId>
<artifactId>hyracks-hdfs-core</artifactId>
</dependency>
<dependency>
<groupId>org.apache.asterix</groupId>
<artifactId>asterix-common</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.asterix</groupId>
<artifactId>asterix-test-framework</artifactId>
<version>${asterix.version}</version>
</dependency>
<dependency>
<groupId>org.apache.asterix</groupId>
<artifactId>asterix-active</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.asterix</groupId>
<artifactId>asterix-algebra</artifactId>
<version>${asterix.version}</version>
</dependency>
<dependency>
<groupId>org.apache.asterix</groupId>
<artifactId>asterix-app</artifactId>
<version>${asterix.version}</version>
<type>jar</type>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.asterix</groupId>
<artifactId>asterix-app</artifactId>
<version>${asterix.version}</version>
<type>test-jar</type>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.asterix</groupId>
<artifactId>asterix-common</artifactId>
<version>${asterix.version}</version>
<type>test-jar</type>
<scope>test</scope>
</dependency>
</dependencies>
</project>
@@ -0,0 +1,48 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.asterix.bad;

public interface BADConstants {
final String SubscriptionId = "subscriptionId";
final String BrokerName = "BrokerName";
final String ChannelName = "ChannelName";
final String DataverseName = "DataverseName";
final String BrokerEndPoint = "BrokerEndPoint";
final String DeliveryTime = "deliveryTime";
final String ResultId = "resultId";
final String ChannelExecutionTime = "channelExecutionTime";
final String ChannelSubscriptionsType = "ChannelSubscriptionsType";
final String ChannelResultsType = "ChannelResultsType";
final String ResultsDatasetName = "ResultsDatasetName";
final String SubscriptionsDatasetName = "SubscriptionsDatasetName";
final String CHANNEL_EXTENSION_NAME = "Channel";
final String BROKER_KEYWORD = "Broker";
final String RECORD_TYPENAME_BROKER = "BrokerRecordType";
final String RECORD_TYPENAME_CHANNEL = "ChannelRecordType";
final String subscriptionEnding = "Subscriptions";
final String resultsEnding = "Results";
final String BAD_METADATA_EXTENSION_NAME = "BADMetadataExtension";
final String BAD_DATAVERSE_NAME = "Metadata";
final String Duration = "Duration";
final String Function = "Function";

public enum ChannelJobType {
REPETITIVE
}
}
@@ -0,0 +1,48 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.asterix.bad;

import java.util.List;

import org.apache.asterix.active.ActiveJob;
import org.apache.asterix.active.ActivityState;
import org.apache.asterix.active.EntityId;
import org.apache.asterix.bad.BADConstants.ChannelJobType;
import org.apache.hyracks.api.job.JobId;
import org.apache.hyracks.api.job.JobSpecification;

public class ChannelJobInfo extends ActiveJob {

private static final long serialVersionUID = 1L;
private List<String> locations;

public ChannelJobInfo(EntityId entityId, JobId jobId, ActivityState state, JobSpecification spec) {
super(entityId, jobId, state, ChannelJobType.REPETITIVE, spec);
}

public List<String> getLocations() {
return locations;

}

public void setLocations(List<String> locations) {
this.locations = locations;
}

}

0 comments on commit 409c3e7

Please sign in to comment.