getPList() {
- if (pBuilder_ == null) {
- return java.util.Collections.unmodifiableList(p_);
- } else {
- return pBuilder_.getMessageList();
- }
- }
- /**
- * repeated .Point p = 1;
- *
- *
- *The list of points
- *
- */
- public int getPCount() {
- if (pBuilder_ == null) {
- return p_.size();
- } else {
- return pBuilder_.getCount();
- }
- }
- /**
- * repeated .Point p = 1;
- *
- *
- *The list of points
- *
- */
- public de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.Point getP(int index) {
- if (pBuilder_ == null) {
- return p_.get(index);
- } else {
- return pBuilder_.getMessage(index);
- }
- }
- /**
- * repeated .Point p = 1;
- *
- *
- *The list of points
- *
- */
- public Builder setP(
- int index, de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.Point value) {
- if (pBuilder_ == null) {
- if (value == null) {
- throw new NullPointerException();
- }
- ensurePIsMutable();
- p_.set(index, value);
- onChanged();
- } else {
- pBuilder_.setMessage(index, value);
- }
- return this;
- }
- /**
- * repeated .Point p = 1;
- *
- *
- *The list of points
- *
- */
- public Builder setP(
- int index, de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.Point.Builder builderForValue) {
- if (pBuilder_ == null) {
- ensurePIsMutable();
- p_.set(index, builderForValue.build());
- onChanged();
- } else {
- pBuilder_.setMessage(index, builderForValue.build());
- }
- return this;
- }
- /**
- * repeated .Point p = 1;
- *
- *
- *The list of points
- *
- */
- public Builder addP(de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.Point value) {
- if (pBuilder_ == null) {
- if (value == null) {
- throw new NullPointerException();
- }
- ensurePIsMutable();
- p_.add(value);
- onChanged();
- } else {
- pBuilder_.addMessage(value);
- }
- return this;
- }
- /**
- * repeated .Point p = 1;
- *
- *
- *The list of points
- *
- */
- public Builder addP(
- int index, de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.Point value) {
- if (pBuilder_ == null) {
- if (value == null) {
- throw new NullPointerException();
- }
- ensurePIsMutable();
- p_.add(index, value);
- onChanged();
- } else {
- pBuilder_.addMessage(index, value);
- }
- return this;
- }
- /**
- * repeated .Point p = 1;
- *
- *
- *The list of points
- *
- */
- public Builder addP(
- de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.Point.Builder builderForValue) {
- if (pBuilder_ == null) {
- ensurePIsMutable();
- p_.add(builderForValue.build());
- onChanged();
- } else {
- pBuilder_.addMessage(builderForValue.build());
- }
- return this;
- }
- /**
- * repeated .Point p = 1;
- *
- *
- *The list of points
- *
- */
- public Builder addP(
- int index, de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.Point.Builder builderForValue) {
- if (pBuilder_ == null) {
- ensurePIsMutable();
- p_.add(index, builderForValue.build());
- onChanged();
- } else {
- pBuilder_.addMessage(index, builderForValue.build());
- }
- return this;
- }
- /**
- * repeated .Point p = 1;
- *
- *
- *The list of points
- *
- */
- public Builder addAllP(
- java.lang.Iterable values) {
- if (pBuilder_ == null) {
- ensurePIsMutable();
- com.google.protobuf.AbstractMessageLite.Builder.addAll(
- values, p_);
- onChanged();
- } else {
- pBuilder_.addAllMessages(values);
- }
- return this;
- }
- /**
- * repeated .Point p = 1;
- *
- *
- *The list of points
- *
- */
- public Builder clearP() {
- if (pBuilder_ == null) {
- p_ = java.util.Collections.emptyList();
- bitField0_ = (bitField0_ & ~0x00000001);
- onChanged();
- } else {
- pBuilder_.clear();
- }
- return this;
- }
- /**
- * repeated .Point p = 1;
- *
- *
- *The list of points
- *
- */
- public Builder removeP(int index) {
- if (pBuilder_ == null) {
- ensurePIsMutable();
- p_.remove(index);
- onChanged();
- } else {
- pBuilder_.remove(index);
- }
- return this;
- }
- /**
- * repeated .Point p = 1;
- *
- *
- *The list of points
- *
- */
- public de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.Point.Builder getPBuilder(
- int index) {
- return getPFieldBuilder().getBuilder(index);
- }
- /**
- * repeated .Point p = 1;
- *
- *
- *The list of points
- *
- */
- public de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.PointOrBuilder getPOrBuilder(
- int index) {
- if (pBuilder_ == null) {
- return p_.get(index); } else {
- return pBuilder_.getMessageOrBuilder(index);
- }
- }
- /**
- * repeated .Point p = 1;
- *
- *
- *The list of points
- *
- */
- public java.util.List
- getPOrBuilderList() {
- if (pBuilder_ != null) {
- return pBuilder_.getMessageOrBuilderList();
- } else {
- return java.util.Collections.unmodifiableList(p_);
- }
- }
- /**
- * repeated .Point p = 1;
- *
- *
- *The list of points
- *
- */
- public de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.Point.Builder addPBuilder() {
- return getPFieldBuilder().addBuilder(
- de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.Point.getDefaultInstance());
- }
- /**
- * repeated .Point p = 1;
- *
- *
- *The list of points
- *
- */
- public de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.Point.Builder addPBuilder(
- int index) {
- return getPFieldBuilder().addBuilder(
- index, de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.Point.getDefaultInstance());
- }
- /**
- * repeated .Point p = 1;
- *
- *
- *The list of points
- *
- */
- public java.util.List
- getPBuilderList() {
- return getPFieldBuilder().getBuilderList();
- }
- private com.google.protobuf.RepeatedFieldBuilder<
- de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.Point, de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.Point.Builder, de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.PointOrBuilder>
- getPFieldBuilder() {
- if (pBuilder_ == null) {
- pBuilder_ = new com.google.protobuf.RepeatedFieldBuilder<
- de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.Point, de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.Point.Builder, de.qaware.chronix.converter.serializer.gen.StraceProtocolBuffers.PointOrBuilder>(
- p_,
- ((bitField0_ & 0x00000001) == 0x00000001),
- getParentForChildren(),
- isClean());
- p_ = null;
- }
- return pBuilder_;
- }
-
- // @@protoc_insertion_point(builder_scope:Points)
- }
-
- static {
- defaultInstance = new Points(true);
- defaultInstance.initFields();
- }
-
- // @@protoc_insertion_point(class_scope:Points)
- }
-
- private static final com.google.protobuf.Descriptors.Descriptor
- internal_static_Point_descriptor;
- private static
- com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internal_static_Point_fieldAccessorTable;
- private static final com.google.protobuf.Descriptors.Descriptor
- internal_static_Points_descriptor;
- private static
- com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internal_static_Points_fieldAccessorTable;
-
- public static com.google.protobuf.Descriptors.FileDescriptor
- getDescriptor() {
- return descriptor;
- }
- private static com.google.protobuf.Descriptors.FileDescriptor
- descriptor;
- static {
- java.lang.String[] descriptorData = {
- "\n\021StracePoint.proto\"\035\n\005Point\022\t\n\001t\030\001 \001(\003\022" +
- "\t\n\001v\030\002 \002(\t\"\033\n\006Points\022\021\n\001p\030\001 \003(\0132\006.PointB" +
- "E\n*de.qaware.chronix.converter.serialize" +
- "r.genB\025StraceProtocolBuffersH\001"
- };
- com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
- new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() {
- public com.google.protobuf.ExtensionRegistry assignDescriptors(
- com.google.protobuf.Descriptors.FileDescriptor root) {
- descriptor = root;
- return null;
- }
- };
- com.google.protobuf.Descriptors.FileDescriptor
- .internalBuildGeneratedFileFrom(descriptorData,
- new com.google.protobuf.Descriptors.FileDescriptor[] {
- }, assigner);
- internal_static_Point_descriptor =
- getDescriptor().getMessageTypes().get(0);
- internal_static_Point_fieldAccessorTable = new
- com.google.protobuf.GeneratedMessage.FieldAccessorTable(
- internal_static_Point_descriptor,
- new java.lang.String[] { "T", "V", });
- internal_static_Points_descriptor =
- getDescriptor().getMessageTypes().get(1);
- internal_static_Points_fieldAccessorTable = new
- com.google.protobuf.GeneratedMessage.FieldAccessorTable(
- internal_static_Points_descriptor,
- new java.lang.String[] { "P", });
- }
-
- // @@protoc_insertion_point(outer_class_scope)
-}
diff --git a/chronix-kassiopeia-converter-strace/src/main/java/de/qaware/chronix/converter/StraceTimeSeriesConverter.java b/chronix-kassiopeia-converter-strace/src/main/java/de/qaware/chronix/converter/StraceTimeSeriesConverter.java
deleted file mode 100644
index e5d8009..0000000
--- a/chronix-kassiopeia-converter-strace/src/main/java/de/qaware/chronix/converter/StraceTimeSeriesConverter.java
+++ /dev/null
@@ -1,114 +0,0 @@
-/*
- * Copyright (C) 2016 QAware GmbH
- *
- * Licensed 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 de.qaware.chronix.converter;
-
-import de.qaware.chronix.converter.common.MetricTSSchema;
-import de.qaware.chronix.converter.serializer.JsonKassiopeiaStraceSerializer;
-import de.qaware.chronix.converter.serializer.ProtoBufKassiopeiaStraceSerializer;
-import de.qaware.chronix.timeseries.StraceTimeSeries;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.nio.charset.Charset;
-
-/**
- * The kassiopeia time series converter for the strace time series class
- * based on de.qaware.chronix.converter.KassiopeiaSimpleConverter
- *
- * @author f.lautenschlager & m.jalowski
- */
-public class StraceTimeSeriesConverter implements TimeSeriesConverter {
-
- public static final String DATA_AS_JSON_FIELD = "dataAsJson";
- public static final String DATA_FUNCTION_VALUE = "function_value";
-
- private static final Logger LOGGER = LoggerFactory.getLogger(KassiopeiaSimpleConverter.class);
-
- @Override
- public StraceTimeSeries from(BinaryTimeSeries binaryTimeSeries, long queryStart, long queryEnd) {
- LOGGER.debug("Converting {} to MetricTimeSeries starting at {} and ending at {}", binaryTimeSeries, queryStart, queryEnd);
- //get the metric
- String metric = binaryTimeSeries.get(MetricTSSchema.METRIC).toString();
-
- //Third build a minimal time series
- StraceTimeSeries.Builder builder = new StraceTimeSeries.Builder(metric);
-
- //add all user defined attributes
- binaryTimeSeries.getFields().forEach((field, value) -> {
- if (MetricTSSchema.isUserDefined(field)) {
- builder.attribute(field, value);
- }
- });
-
- //Default serialization is protocol buffers.
- if (binaryTimeSeries.getPoints().length > 0) {
- fromProtocolBuffers(binaryTimeSeries, queryStart, queryEnd, builder);
-
- } else if (binaryTimeSeries.getFields().containsKey(DATA_AS_JSON_FIELD)) {
- //do it from json
- fromJson(binaryTimeSeries, queryStart, queryEnd, builder);
-
- } else if (binaryTimeSeries.get(DATA_FUNCTION_VALUE) != null) {
- //we have a function (aggregation) result
- String value = binaryTimeSeries.get(DATA_FUNCTION_VALUE).toString();
- long meanDate = meanDate(binaryTimeSeries);
- builder.point(meanDate, value);
- }
-
- return builder.build();
-
- }
-
- private void fromProtocolBuffers(BinaryTimeSeries binaryTimeSeries, long queryStart, long queryEnd, StraceTimeSeries.Builder builder) {
- ProtoBufKassiopeiaStraceSerializer.from(binaryTimeSeries.getPoints(), binaryTimeSeries.getStart(), binaryTimeSeries.getEnd(), queryStart, queryEnd, builder);
- }
-
- private void fromJson(BinaryTimeSeries binaryTimeSeries, long queryStart, long queryEnd, StraceTimeSeries.Builder builder) {
- String jsonString = binaryTimeSeries.get(DATA_AS_JSON_FIELD).toString();
- //Second deserialize
- JsonKassiopeiaStraceSerializer serializer = new JsonKassiopeiaStraceSerializer();
- serializer.fromJson(jsonString.getBytes(Charset.forName(JsonKassiopeiaStraceSerializer.UTF_8)), queryStart, queryEnd, builder);
- }
-
- private long meanDate(BinaryTimeSeries binaryTimeSeries) {
- long start = binaryTimeSeries.getStart();
- long end = binaryTimeSeries.getEnd();
-
- return start + ((end - start) / 2);
- }
-
- @Override
- public BinaryTimeSeries to(StraceTimeSeries timeSeries) {
- LOGGER.debug("Converting {} to BinaryTimeSeries", timeSeries);
- BinaryTimeSeries.Builder builder = new BinaryTimeSeries.Builder();
-
- //serialize
- byte[] compressedPoints = ProtoBufKassiopeiaStraceSerializer.to(timeSeries.points().iterator());
-
- //Add the minimum required fields
- builder.start(timeSeries.getStart())
- .end(timeSeries.getEnd())
- .data(compressedPoints);
-
- //Currently we only have a metric
- builder.field(MetricTSSchema.METRIC, timeSeries.getMetric());
-
- //Add a list of user defined attributes
- timeSeries.attributes().forEach(builder::field);
-
- return builder.build();
- }
-}
diff --git a/chronix-kassiopeia-converter-strace/src/main/java/de/qaware/chronix/converter/StraceTimeSeriesDefaults.java b/chronix-kassiopeia-converter-strace/src/main/java/de/qaware/chronix/converter/StraceTimeSeriesDefaults.java
deleted file mode 100644
index a046a2d..0000000
--- a/chronix-kassiopeia-converter-strace/src/main/java/de/qaware/chronix/converter/StraceTimeSeriesDefaults.java
+++ /dev/null
@@ -1,70 +0,0 @@
-/*
- * Copyright (C) 2016 QAware GmbH
- *
- * Licensed 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 de.qaware.chronix.converter;
-
-import de.qaware.chronix.timeseries.StraceTimeSeries;
-
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Map;
-import java.util.Set;
-import java.util.function.BinaryOperator;
-import java.util.function.Function;
-
-/**
- * Holds default group by and reduce functions for the kassiopeia-strace time series
- *
- * @author f.lautenschlager & m.jalowski
- */
-public class StraceTimeSeriesDefaults {
-
- private StraceTimeSeriesDefaults() {
- //avoid instances
- }
-
- /**
- * Default group by function for the metric time series class.
- * Groups time series on its metric name.
- */
- public static final Function GROUP_BY = StraceTimeSeries::getMetric;
-
- /**
- * Default reduce function.
- * Attributes in both collected and reduced are merged using set holding both values.
- */
- public static final BinaryOperator REDUCE = (collected, reduced) -> {
- collected.addAll(reduced.getTimestampsAsArray(), reduced.getValuesAsArray());
-
- //The collected attributes
- Map attributesReference = collected.getAttributesReference();
-
- //merge the attributes
- //we iterate over the copy
- for (HashMap.Entry entry : reduced.attributes().entrySet()) {
- //Attribute to add
- String attributeToAdd = entry.getKey();
- Set