Bump version to v0.2.0

Author: cswinter

.travis.yml

@@ -10,12 +10,9 @@ language: rust
 rust:
   - nightly
 cache: cargo
-before_script:
-  - rustup component add clippy-preview
 script:
 - cargo test --all-features
 - cargo check --bench basic
-- cargo clippy
 notifications:
   email:
     on_success: never

Cargo.lock

@@ -1,7 +1,9 @@
 [package]
-authors = ["Clemens Winter <[email protected]>", "David Fisher"]
+authors = ["Clemens Winter <[email protected]>"]
 name = "locustdb"
-version = "0.2.0-dev"
+version = "0.2.0"
+license-file = "LICENSE"
+description = "Embeddable high-performance analytics database."
 [build-dependencies]
 [build-dependencies.capnpc]
 optional = true
@@ -49,6 +51,7 @@ version = "0.8.17"
 
 [dependencies.locustdb-derive]
 path = "./locustdb-derive"
+version = "0.1.0"
 
 [dependencies.log]
 features = ["max_level_trace", "release_max_level_debug"]

Cargo.toml

@@ -3,10 +3,12 @@ authors = ["Clemens Winter <[email protected]>"]
 edition = "2018"
 name = "locustdb-derive"
 version = "0.1.0"
+license = "Apache-2.0"
+description = "Macros used internally by locustdb crate."
 [dependencies]
-lazy_static = "*"
+lazy_static = "1.2"
 quote = "0.6"
-regex = "*"
+regex = "1.1"
 
 [dependencies.proc-macro2]
 features = ["nightly"]

locustdb-derive/Cargo.lock

@@ -1,4 +1,4 @@
-#![feature(proc_macro_non_items, proc_macro_diagnostic)]
+#![feature(proc_macro_hygiene, proc_macro_diagnostic)]
 #![recursion_limit = "128"]
 extern crate proc_macro;
 #[macro_use]

locustdb-derive/Cargo.toml

@@ -1 +1 @@
-nightly-2018-09-17
+nightly-2018-12-30

locustdb-derive/src/lib.rs

@@ -6,11 +6,11 @@ use std::string;
 
 use engine::data_types::*;
 use ingest::raw_val::RawVal;
-use mem_store::value::Val;
-use mem_store::column::DataSource;
 use mem_store::codec::Codec;
-use super::NullableVec;
+use mem_store::column::DataSource;
+use mem_store::value::Val;
 
+use super::NullableVec;
 
 pub type BoxedData<'a> = Box<Data<'a> + 'a>;
 

rust-toolchain

@@ -2,6 +2,7 @@ use std::fmt;
 use std::mem;
 
 use ingest::raw_val::RawVal;
+
 use super::*;
 
 #[derive(Debug)]
@@ -14,11 +15,11 @@ impl<'a> Data<'a> for ScalarVal<i64> {
 }
 
 impl<'a> Data<'a> for ScalarVal<&'a str> {
-    fn len(&self) -> usize { 1 }
+    default fn len(&self) -> usize { 1 }
     fn get_raw(&self, _: usize) -> RawVal { RawVal::Str(self.val.to_string()) }
-    fn get_type(&self) -> EncodingType { EncodingType::ScalarStr }
-    fn slice_box<'b>(&'b self, _: usize, _: usize) -> BoxedData<'b> where 'a: 'b { panic!(self.type_error("slice_box")) }
-    fn type_error(&self, func_name: &str) -> String { format!("Vec<{:?}>.{}", self.get_type(), func_name) }
+    default fn get_type(&self) -> EncodingType { EncodingType::ScalarStr }
+    default fn slice_box<'b>(&'b self, _: usize, _: usize) -> BoxedData<'b> where 'a: 'b { panic!(self.type_error("slice_box")) }
+    default fn type_error(&self, func_name: &str) -> String { format!("Vec<{:?}>.{}", self.get_type(), func_name) }
 
     fn append_all(&mut self, _: &Data<'a>, _: usize) -> Option<BoxedData<'a>> {
         panic!(self.type_error("slice_box"))
@@ -30,17 +31,17 @@ impl<'a> Data<'a> for ScalarVal<&'a str> {
 }
 
 impl<'a, T: ScalarData<T>> Data<'a> for ScalarVal<T> {
-    fn len(&self) -> usize { 1 }
-    fn get_raw(&self, _: usize) -> RawVal { T::raw_val(&self.val) }
-    fn get_type(&self) -> EncodingType { T::t() }
-    fn slice_box<'b>(&'b self, _: usize, _: usize) -> BoxedData<'b> where 'a: 'b { panic!(self.type_error("slice_box")) }
-    fn type_error(&self, func_name: &str) -> String { format!("Vec<{:?}>.{}", T::t(), func_name) }
+    default fn len(&self) -> usize { 1 }
+    default fn get_raw(&self, _: usize) -> RawVal { T::raw_val(&self.val) }
+    default fn get_type(&self) -> EncodingType { T::t() }
+    default fn slice_box<'b>(&'b self, _: usize, _: usize) -> BoxedData<'b> where 'a: 'b { panic!(self.type_error("slice_box")) }
+    default fn type_error(&self, func_name: &str) -> String { format!("Vec<{:?}>.{}", T::t(), func_name) }
 
-    fn append_all(&mut self, _: &Data<'a>, _: usize) -> Option<BoxedData<'a>> {
+    default fn append_all(&mut self, _: &Data<'a>, _: usize) -> Option<BoxedData<'a>> {
         panic!(self.type_error("slice_box"))
     }
 
-    fn display(&self) -> String { format!("Scalar<{:?}>{:?}", T::t(), &self) }
+    default fn display(&self) -> String { format!("Scalar<{:?}>{:?}", T::t(), &self) }
 }
 
 impl<'a> Data<'a> for ScalarVal<String> {

src/engine/data_types/data.rs

@@ -1,40 +1,57 @@
-#![feature(fn_traits, integer_atomics, refcell_replace_swap, specialization, trait_alias, core_intrinsics, box_patterns, int_to_from_bytes, tool_lints, proc_macro_non_items, extern_prelude)]
-extern crate sqlparser;
-#[macro_use]
-extern crate failure_derive;
-#[macro_use]
-extern crate log;
+#![feature(fn_traits, integer_atomics, refcell_replace_swap, specialization, trait_alias, core_intrinsics, box_patterns, proc_macro_hygiene)]
+extern crate aliasmethod;
+extern crate byteorder;
+#[cfg(feature = "enable_rocksdb")]
+extern crate capnp;
 extern crate chrono;
+extern crate crypto;
 extern crate failure;
-extern crate futures_core;
-extern crate futures_util;
+#[macro_use]
+extern crate failure_derive;
+extern crate fnv;
 extern crate futures_channel;
+extern crate futures_core;
 extern crate futures_executor;
+extern crate futures_util;
+extern crate heapsize;
 #[macro_use]
 extern crate heapsize_derive;
-extern crate heapsize;
+extern crate hex;
 extern crate itertools;
+#[macro_use]
+extern crate lazy_static;
+extern crate locustdb_derive;
+#[macro_use]
+extern crate log;
+extern crate lru;
 extern crate num;
 extern crate num_cpus;
+extern crate rand;
 extern crate regex;
 extern crate seahash;
-extern crate time;
-extern crate tempdir;
-extern crate fnv;
-extern crate byteorder;
-extern crate lru;
-extern crate crypto;
-extern crate hex;
-#[cfg(feature = "enable_rocksdb")]
-extern crate capnp;
+extern crate sqlparser;
 extern crate std_semaphore;
-extern crate aliasmethod;
-extern crate rand;
-extern crate locustdb_derive;
-#[macro_use]
-extern crate lazy_static;
+extern crate tempdir;
+extern crate time;
 
 
+pub use disk_store::noop_storage::NoopStorage;
+pub use engine::query_task::QueryOutput;
+pub use errors::QueryError;
+pub use ingest::colgen;
+pub use ingest::csv_loader::Options as LoadOptions;
+pub use ingest::extractor;
+pub use ingest::nyc_taxi_data;
+pub use ingest::raw_val::RawVal as Value;
+pub use ingest::raw_val::syntax as value_syntax;
+pub use locustdb::LocustDB as LocustDB;
+pub use locustdb::Options as Options;
+pub use mem_store::table::TableStats;
+#[doc(hidden)]
+pub use trace::_replace;
+#[doc(hidden)]
+pub use trace::_start;
+
 #[macro_use]
 mod trace;
 #[macro_use]
@@ -50,26 +67,8 @@ mod stringpack;
 mod bitvec;
 pub mod unit_fmt;
 
-pub use engine::query_task::QueryOutput;
-pub use errors::QueryError;
-pub use ingest::csv_loader::Options as LoadOptions;
-pub use ingest::extractor;
-pub use ingest::nyc_taxi_data;
-pub use ingest::raw_val::RawVal as Value;
-pub use ingest::raw_val::syntax as value_syntax;
-pub use ingest::colgen;
-pub use locustdb::LocustDB as LocustDB;
-pub use locustdb::Options as Options;
-pub use mem_store::table::TableStats;
-pub use disk_store::noop_storage::NoopStorage;
-
 pub type QueryResult = Result<QueryOutput, QueryError>;
 
-#[doc(hidden)]
-pub use trace::_replace;
-#[doc(hidden)]
-pub use trace::_start;
-
 #[allow(warnings)]
 #[cfg(feature = "enable_rocksdb")]
 pub(crate) mod storage_format_capnp {