Permalink
Browse files

RTSQL-10. Finish rename of rtengine to FlumeBase.

  • Loading branch information...
kimballa committed Mar 12, 2011
1 parent 636f46e commit 1d5ace14ad7fe26b576223c4fbd2946840e79d88
View
@@ -1,9 +1,9 @@
- How to compile rtsql
+ How to compile FlumeBase
-rtsql is a Java application with a maven-based build process.
+FlumeBase is a Java application with a maven-based build process.
BUILD SYSTEM REQUIREMENTS:
* Maven 2.0+
@@ -15,7 +15,7 @@ BUILD SYSTEM REQUIREMENTS:
INSTALLING PREREQUISITES:
The following prerequisite tools must be installed prior to building
-rtsql:
+FlumeBase:
* Apache Thrift compiler 0.5.0
* maven-thrift-plugin 0.1.10
@@ -50,10 +50,10 @@ and run:
-BUILDING RTSQL:
+BUILDING FLUMEBASE:
-Finally, build rtsql itself by changing to the rtsql source directory (the
-directory containing this COMPILING.txt file) and running:
+Finally, build FlumeBase itself by changing to the FlumeBase source directory
+(the directory containing this COMPILING.txt file) and running:
mvn package
@@ -65,7 +65,7 @@ More thorough (longer-running) integration tests are available at:
mvn integration-test
-The rtsql shell can be run with:
+The FlumeBase shell can be run with:
- bin/rtsql shell
+ bin/flumebase shell
View
@@ -1,18 +1,18 @@
- Welcome to rtsql!
+ Welcome to FlumeBase!
This system allows continuous and ad-hoc analysis of streaming event
data delivered by Flume.
-rtsql will easily connect to existing Flume sources and allows users
-to write SQL-based queries over these streaming data sets.
+FlumeBase will easily connect to existing Flume sources and allows
+users to write SQL-based queries over these streaming data sets.
*************************************************************
* DISCLAIMER *
* *
- * rtsql is an EXPERIMENTAL system! This is in no way ready *
+ * FlumeBase is an EXPERIMENTAL system! This is in no way ok *
* for production use. Use this AT YOUR OWN RISK. Connecting *
* this system to production Flume nodes may result in data *
* loss, misconfiguration, or other serious problems. *
@@ -21,15 +21,15 @@ to write SQL-based queries over these streaming data sets.
More documentation (in particular, a user guide explaining how to
-configure rtsql, and the rtsql language) is available in the docs/
+configure FlumeBase, and the rtsql language) is available in the docs/
directory.
-See the COMPILING.txt file for information on how to compile rtsql from
-source. rtsql is licensed to you under the terms of the Apache
-Software License version 2.0. See the LICENSE.txt and NOTICE.txt files
-for more specific information about this license.
+See the COMPILING.txt file for information on how to compile FlumeBase
+from source. FlumeBase is licensed to you under the terms of the
+Apache Software License version 2.0. See the LICENSE.txt and
+NOTICE.txt files for more specific information about this license.
-rtsql's "home" is at http://github.com/odiago/rtsql. See this site for
-the most recent source code, binary releases, wiki, bug tracking, and
-other resources.
+FlumeBase's "home" is at http://github.com/odiago/flumebase. See this
+site for the most recent source code, binary releases, wiki, bug
+tracking, and other resources.
View

Large diffs are not rendered by default.

Oops, something went wrong.
@@ -42,7 +42,7 @@
</excludes>
</fileSet>
<fileSet>
- <directory>${project.build.sourceDirectory}</directory>
+ <directory>${project.basedir}/src</directory>
<outputDirectory>/src</outputDirectory>
<useDefaultExcludes>true</useDefaultExcludes>
</fileSet>
@@ -21,7 +21,7 @@
public class HistoryFile {
/** Default filename to use for this if unspecified. */
- private static final String DEFAULT_FILE_NAME = ".rtsql_history";
+ private static final String DEFAULT_FILE_NAME = ".flumebase_history";
private String mFileName;
@@ -53,7 +53,7 @@
BucketedAggregationElement.class.getName());
/** Configuration key for the number of buckets that subdivide the aggregation time interval. */
- private static final String NUM_BUCKETS_KEY = "rtsql.aggregation.buckets";
+ private static final String NUM_BUCKETS_KEY = "flumebase.aggregation.buckets";
private static final int DEFAULT_NUM_BUCKETS = 100;
/**
@@ -62,14 +62,14 @@
* is available in that bucket; if false, only generate output when the input
* condition changes.
*/
- private static final String CONTINUOUS_OUTPUT_KEY = "rtsql.aggregation.continuous.output";
+ private static final String CONTINUOUS_OUTPUT_KEY = "flumebase.aggregation.continuous.output";
private static final boolean DEFAULT_CONTINUOUS_OUTPUT = false;
/**
* Configuration key specifying the amount of slack time we tolerate between
* events that should occur at the same time.
*/
- public static final String SLACK_INTERVAL_KEY = "rtsql.slack.time";
+ public static final String SLACK_INTERVAL_KEY = "flumebase.slack.time";
public static final int DEFAULT_SLACK_INTERVAL = 200;
/**
@@ -79,7 +79,7 @@
* this many milliseconds old.
*/
private static final String MAX_PRIOR_EMIT_INTERVAL_KEY =
- "rtsql.aggregation.max.prior.interval";
+ "flumebase.aggregation.max.prior.interval";
private static final long DEFAULT_MAX_PRIOR_EMIT_INTERVAL = 5000;
/** The number of buckets that subdivide the aggregation time interval. */
@@ -26,7 +26,7 @@
/**
* EventSink that receives events from upstream in a Flume pipeline.
* The EventSink then injects the events into a FlowElementContext
- * for delivery in an flumebase flow.
+ * for delivery in a FlumeBase flow.
*/
public class RtsqlSink extends EventSink.Base {
private static final Logger LOG = LoggerFactory.getLogger(RtsqlSink.class.getName());
@@ -29,7 +29,7 @@
*/
private SourceContext mSourceContext;
- /** Queue of events being delivered by rtsql that we should emit as a source. */
+ /** Queue of events being delivered by flumebase that we should emit as a source. */
private BlockingQueue<Event> mEventQueue;
@@ -12,7 +12,7 @@
private final String mContextName;
/**
- * Queue of events that will be populated by rtsql; these should be
+ * Queue of events that will be populated by flumebase; these should be
* broadcast to Flume via the associated RtsqlSource.
*/
private final BlockingQueue<Event> mEventQueue;
@@ -37,16 +37,16 @@
/**
* Configuration key that specifies how we should deliver output records of a
- * top-level RTSQL statement to the client. If this is set to "$console," we
+ * top-level rtsql statement to the client. If this is set to "$console," we
* print to the screen. Other strings cause us to allocate a list buffer that
* can be retrieved later by the client.
*/
- public static final String CLIENT_SELECT_TARGET_KEY = "rtsql.client.select.target";
+ public static final String CLIENT_SELECT_TARGET_KEY = "flumebase.client.select.target";
- /** Special value for rtsql.client.select.target that prints to stdout. */
+ /** Special value for flumebase.client.select.target that prints to stdout. */
public static final String CONSOLE_SELECT_TARGET = "$console";
- /** The default for rtsql.client.select.target is to use the console. */
+ /** The default for flumebase.client.select.target is to use the console. */
public static final String DEFAULT_CLIENT_SELECT_TARGET = CONSOLE_SELECT_TARGET;
/** Set of fields or other expressions to select */

0 comments on commit 1d5ace1

Please sign in to comment.