fixes

Author: adriangb

src/errors/schema_error.rs

@@ -168,7 +168,7 @@ impl TableReferenceProto {
 impl SchemaErrorProto {
     pub fn from_schema_error(err: &SchemaError, backtrace: Option<&String>) -> Self {
         match err {
-            SchemaError::AmbiguousReference { ref field } => SchemaErrorProto {
+            SchemaError::AmbiguousReference { field } => SchemaErrorProto {
                 inner: Some(SchemaErrorInnerProto::AmbiguousReference(
                     AmbiguousReferenceProto {
                         field: Some(ColumnProto::from_column(field)),

src/metrics/proto.rs

@@ -1,3 +1,4 @@
+#[cfg(feature = "integration")]
 use chrono::DateTime;
 use datafusion::common::internal_err;
 use datafusion::error::DataFusionError;
@@ -381,10 +382,10 @@ pub fn metric_proto_to_df(metric: MetricProto) -> Result<Arc<Metric>, DataFusion
             )))
         }
         Some(MetricValueProto::StartTimestamp(start_ts)) => match start_ts.value {
-            Some(value) => {
+            Some(_value) => {
                 let timestamp = Timestamp::new();
                 #[cfg(feature = "integration")]
-                timestamp.set(DateTime::from_timestamp_nanos(value));
+                timestamp.set(DateTime::from_timestamp_nanos(_value));
                 #[cfg(not(feature = "integration"))]
                 { /* DateTime not available without integration feature */ }
                 Ok(Arc::new(Metric::new_with_labels(
@@ -400,10 +401,10 @@ pub fn metric_proto_to_df(metric: MetricProto) -> Result<Arc<Metric>, DataFusion
             ))),
         },
         Some(MetricValueProto::EndTimestamp(end_ts)) => match end_ts.value {
-            Some(value) => {
+            Some(_value) => {
                 let timestamp = Timestamp::new();
                 #[cfg(feature = "integration")]
-                timestamp.set(DateTime::from_timestamp_nanos(value));
+                timestamp.set(DateTime::from_timestamp_nanos(_value));
                 #[cfg(not(feature = "integration"))]
                 { /* DateTime not available without integration feature */ }
                 Ok(Arc::new(Metric::new_with_labels(

src/protobuf/distributed_codec.rs

@@ -19,7 +19,7 @@ use std::sync::Arc;
 pub struct DistributedCodec;
 
 impl DistributedCodec {
-    pub fn new_combined_with_user(cfg: &SessionConfig) -> impl PhysicalExtensionCodec {
+    pub fn new_combined_with_user(cfg: &SessionConfig) -> impl PhysicalExtensionCodec + use<> {
         let mut combined_codec = ComposedPhysicalExtensionCodec::default();
         combined_codec.push(DistributedCodec {});
         if let Some(ref user_codec) = get_distributed_user_codec(cfg) {