add aplv2 headers to engine-api

This commit is contained in:
Jonathan Shook
2022-03-08 14:14:08 -06:00
parent 1719e69d77
commit 7c82f766b5
279 changed files with 3235 additions and 2463 deletions

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;
/**

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;
/**

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;
import io.nosqlbench.engine.api.activityimpl.ActivityDef;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;
@@ -66,7 +65,7 @@ public abstract class BaseAsyncAction<D, A extends Activity> implements AsyncAct
@Override
public void requestStop() {
logger.info(this.toString() + " requested to stop.");
logger.info(this + " requested to stop.");
this.running = false;
}

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;
import io.nosqlbench.engine.api.activityimpl.ActivityDef;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;
public interface Shutdownable {

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core;

View File

@@ -1,3 +1,19 @@
/*
* Copyright (c) 2022 nosqlbench
*
* 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 io.nosqlbench.engine.api.activityapi.core.ops.fluent;
public interface FluentOp {

View File

@@ -1,3 +1,19 @@
/*
* Copyright (c) 2022 nosqlbench
*
* 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 io.nosqlbench.engine.api.activityapi.core.ops.fluent;
import io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets.OpEvents;

View File

@@ -1,3 +1,19 @@
/*
* Copyright (c) 2022 nosqlbench
*
* 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 io.nosqlbench.engine.api.activityapi.core.ops.fluent;
import com.codahale.metrics.Counter;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets;
@@ -35,6 +34,6 @@ import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResult
*/
public interface CompletedOp<D> extends Payload<D>, CycleResult {
long getStartedAtNanos();
public long getServiceTimeNanos();
public long getResponseTimeNanos();
long getServiceTimeNanos();
long getResponseTimeNanos();
}

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,14 +13,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets;
public class EventedOpImpl<D> extends OpImpl<D> {
private OpEvents<D> opTracker;
private OpEvents<D> strideTracker;
private final OpEvents<D> opTracker;
private final OpEvents<D> strideTracker;
public EventedOpImpl(OpEvents<D> opTracker, OpEvents<D> strideTracker) {
this.opTracker = opTracker;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets;
@@ -25,5 +24,5 @@ import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResult
* @param <D> The delegate type needed by the implementing activity type
*/
public interface FailedOp<D> extends Payload<D>, CycleResult, CompletedOp<D> {
public int getTries();
int getTries();
}

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2018 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets;
@@ -70,13 +69,13 @@ public interface StartedOp<D> extends Payload<D>, CycleReadable {
* Return the nanos that have elapsed since the op was started at the time of this call.
* @return nanosecond service time duration
*/
public long getCurrentServiceTimeNanos();
long getCurrentServiceTimeNanos();
/**
* Return the nanos that have elapsed since this op was started at the time of this call,
* plus any prior waittime.
* @return nanosecond response time duration
*/
public long getCurrentResponseTimeNanos();
long getCurrentResponseTimeNanos();
}

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets;
@@ -24,5 +23,5 @@ import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResult
* @param <D> The type of delegate needed for the implementing protocol
*/
public interface SucceededOp<D> extends Payload<D>, CycleResult, CompletedOp<D> {
public int getTries();
int getTries();
}

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers;
@@ -28,7 +27,7 @@ import java.util.List;
public abstract class Buffer<T extends Comparable> {
private int position;
private int limit;
private final int limit;
protected ArrayList<T> data;
public Buffer(int size) {

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers;
@@ -31,7 +30,7 @@ public interface CycleResultSegmentsReadable extends Iterable<CycleResultsSegmen
@Override
public Iterator<CycleResult> iterator() {
return new Iterator<CycleResult>() {
Iterator<CycleResultsSegment> iterSegment = CycleResultSegmentsReadable.this.iterator();
final Iterator<CycleResultsSegment> iterSegment = CycleResultSegmentsReadable.this.iterator();
Iterator<CycleResult> innerIter=iterSegment.next().iterator();
@Override

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.op_output;
@@ -22,5 +21,5 @@ import io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets.CompletedOp
import java.util.List;
public interface StrideOutputConsumer<D> {
public void onStrideOutput(List<CompletedOp<D>> ops);
void onStrideOutput(List<CompletedOp<D>> ops);
}

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.op_output;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.op_output;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results;
@@ -27,8 +26,8 @@ import java.util.concurrent.atomic.AtomicInteger;
*/
public class CycleArray implements Input {
private AtomicInteger offset=new AtomicInteger();
private long[] cycles;
private final AtomicInteger offset=new AtomicInteger();
private final long[] cycles;
public CycleArray(long... values) {
this.cycles = values;
@@ -51,7 +50,7 @@ public class CycleArray implements Input {
public static class ArraySegment implements CycleSegment {
private long[] values;
private final long[] values;
private int offset=0;
public ArraySegment(long[] values) {

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results;
@@ -25,7 +24,7 @@ import java.util.NoSuchElementException;
public class CycleResultArray implements CycleResultsSegment, CanSortCycles {
private CycleResult[] cycleResults;
private final CycleResult[] cycleResults;
public CycleResultArray(CycleResult[] cycleResults) {
this.cycleResults = cycleResults;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results;
@@ -69,7 +68,7 @@ public class CycleResultSegmentBuffer {
return buf.hasRemaining();
}
public static interface Sink {
public interface Sink {
void handle(CycleResultsSegment buffer);
}

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results;
@@ -21,7 +20,7 @@ import java.util.Iterator;
public class CycleResultStrider {
private Iterator<CycleResult> iterator;
private final Iterator<CycleResult> iterator;
public CycleResultStrider(Iterator<CycleResult> iterator) {
this.iterator = iterator;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results;
@@ -40,7 +39,7 @@ public interface CycleResultsSegment extends Comparable<CycleResultsSegment>, It
CycleResultsSegment EMPTY = new EmptySegment();
public class EmptySegment implements CycleResultsSegment {
class EmptySegment implements CycleResultsSegment {
@Override
public long getCount() {
return 0;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results;
@@ -101,7 +100,7 @@ public class CycleResultsSegmentReadable implements CycleResultsSegment {
private class BBCycleResult implements CycleResult {
private int offset;
private final int offset;
BBCycleResult(int offset) {
this.offset = offset;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results;
@@ -23,7 +22,7 @@ public class MutableCycleResult implements CycleResult {
private int result;
private long startTimeNanos;
private long endTimeNanos=Long.MIN_VALUE; // you will get some strange results if you forget to update this
private long schedulingDelay;
private final long schedulingDelay;
public MutableCycleResult(long cycle, int result, long startTimeNanos, long schedulingDelay) {
this.cycle = cycle;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results_rle;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results_rle;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results_rle;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.filters;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.filters;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.filters;
@@ -42,7 +41,7 @@ public class IncludeCodesTypeExperimental implements ExperimentalResultFilterTyp
public IncludeCodes(SimpleConfig conf) {
lut=parseCodes(128, conf.getString("codes").orElseThrow(
() -> new RuntimeException("codes= was not provided in the int predicate config for " + IncludeCodes.this.toString())
() -> new RuntimeException("codes= was not provided in the int predicate config for " + IncludeCodes.this)
));
}

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.filters;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.filters;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.filters;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.filters;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.filters;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.filters.tristate;
@@ -23,8 +22,8 @@ import java.util.function.Predicate;
public interface CycleResultPredicate extends Predicate<ResultReadable> {
public static class ResultHasSomeBits implements CycleResultPredicate {
private int mask;
class ResultHasSomeBits implements CycleResultPredicate {
private final int mask;
public ResultHasSomeBits(int mask) {
this.mask = mask;
@@ -36,8 +35,8 @@ public interface CycleResultPredicate extends Predicate<ResultReadable> {
}
}
public static class ResultHasAllBits implements CycleResultPredicate {
private int mask;
class ResultHasAllBits implements CycleResultPredicate {
private final int mask;
public ResultHasAllBits(int mask) {
this.mask = mask;
@@ -49,7 +48,7 @@ public interface CycleResultPredicate extends Predicate<ResultReadable> {
}
}
public static class ResultInRange implements CycleResultPredicate {
class ResultInRange implements CycleResultPredicate {
private final int min;
private final int max;
@@ -65,7 +64,7 @@ public interface CycleResultPredicate extends Predicate<ResultReadable> {
}
}
public static class ResultEquals implements CycleResultPredicate {
class ResultEquals implements CycleResultPredicate {
private final int value;
public ResultEquals(int value) {

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.filters.tristate;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.filters.tristate;
@@ -64,7 +63,7 @@ public class EnumReadableMappingFilter<E extends Enum<E> & ResultReadable> imple
for (E enumValue : this.enumValues) {
sb.append(enumValue.toString()).append(",");
}
logger.warn("Unable to match any known type with pattern '" + s + "', available names: " + sb.toString());
logger.warn("Unable to match any known type with pattern '" + s + "', available names: " + sb);
}
}
@@ -78,7 +77,7 @@ public class EnumReadableMappingFilter<E extends Enum<E> & ResultReadable> imple
for (E enumValue : enumValues) {
int result = enumValue.getResult();
sb.append(enumValue.toString())
sb.append(enumValue)
.append("->")
.append(result)
.append("->")

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.filters.tristate;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.filters.tristate;
@@ -25,8 +24,8 @@ import java.util.function.Predicate;
public class ResultFilteringSieve implements TristateFilter<ResultReadable> {
private Policy defaultPolicy;
private List<TristateFilter<ResultReadable>> phases;
private final Policy defaultPolicy;
private final List<TristateFilter<ResultReadable>> phases;
private ResultFilteringSieve(Policy defaultPolicy, List<TristateFilter<ResultReadable>> phases) {
this.defaultPolicy = defaultPolicy;
@@ -57,7 +56,7 @@ public class ResultFilteringSieve implements TristateFilter<ResultReadable> {
private class InclusiveFilterPredicate implements Predicate<ResultReadable> {
private ResultFilteringSieve resultFilteringSieve;
private final ResultFilteringSieve resultFilteringSieve;
public InclusiveFilterPredicate(ResultFilteringSieve resultFilteringSieve) {
this.resultFilteringSieve = resultFilteringSieve;
@@ -88,7 +87,7 @@ public class ResultFilteringSieve implements TristateFilter<ResultReadable> {
}
public static class Builder {
private List<TristateFilter<ResultReadable>> phaseFilters = new ArrayList<>();
private final List<TristateFilter<ResultReadable>> phaseFilters = new ArrayList<>();
private Policy defaultPolicy = Policy.Ignore;
public Builder keepByDefault() {

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.filters.tristate;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.filters.tristate;
@@ -67,7 +66,7 @@ public interface TristateFilter<T> extends Function<T, TristateFilter.Policy> {
* of the filter matching. If the filter does not match, then neither
* include nor exclude are presumed. See the class docs for more details.
*/
public enum Policy {
enum Policy {
Keep,
Discard,
Ignore

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.inputs.cyclelog;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.inputs.cyclelog;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.inputs.cyclelog;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.outputs;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.outputs;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.outputs.cyclelog;
@@ -86,7 +85,7 @@ public class CycleLogDumperUtility {
}
static enum DisplayType {
enum DisplayType {
cycles,
spans
}

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.outputs.cyclelog;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.outputs.cyclelog;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.outputs.cyclelog;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.outputs.logger;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.cyclelog.outputs.logger;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.errorhandling;
@@ -24,12 +23,12 @@ public interface CycleErrorHandler<T extends Throwable, R> {
}
default R handleError(long cycle, T error, long magnitude) {
return handleError(cycle, error, "magnitude: " + String.valueOf(magnitude));
return handleError(cycle, error, "magnitude: " + magnitude);
}
R handleError(long cycle, T error, String errMsg);
public static class Triple<T,R> {
class Triple<T,R> {
public T error;
public long cycle;
public String msg;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.errorhandling;

View File

@@ -1,3 +1,19 @@
/*
* Copyright (c) 2022 nosqlbench
*
* 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 io.nosqlbench.engine.api.activityapi.errorhandling;
import io.nosqlbench.engine.api.activityimpl.ActivityDef;

View File

@@ -1,6 +1,6 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Copyright 2016 jshook
* 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
@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
*/
package io.nosqlbench.engine.api.activityapi.errorhandling;

View File

@@ -1,3 +1,19 @@
/*
* Copyright (c) 2022 nosqlbench
*
* 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 io.nosqlbench.engine.api.activityapi.errorhandling.modular;
public class ErrorDetail {

View File

@@ -1,3 +1,19 @@
/*
* Copyright (c) 2022 nosqlbench
*
* 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 io.nosqlbench.engine.api.activityapi.errorhandling.modular;
public interface ErrorHandler {

View File

@@ -1,3 +1,19 @@
/*
* Copyright (c) 2022 nosqlbench
*
* 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 io.nosqlbench.engine.api.activityapi.errorhandling.modular;
import io.nosqlbench.engine.api.activityapi.errorhandling.ErrorMetrics;

View File

@@ -1,3 +1,19 @@
/*
* Copyright (c) 2022 nosqlbench
*
* 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 io.nosqlbench.engine.api.activityapi.errorhandling.modular;
import io.nosqlbench.nb.annotations.Service;

View File

@@ -1,3 +1,19 @@
/*
* Copyright (c) 2022 nosqlbench
*
* 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 io.nosqlbench.engine.api.activityapi.errorhandling.modular.handlers;
import io.nosqlbench.engine.api.activityapi.errorhandling.modular.ErrorHandler;

View File

@@ -1,3 +1,19 @@
/*
* Copyright (c) 2022 nosqlbench
*
* 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 io.nosqlbench.engine.api.activityapi.errorhandling.modular.handlers;
import io.nosqlbench.engine.api.activityapi.errorhandling.ErrorMetrics;

View File

@@ -1,3 +1,19 @@
/*
* Copyright (c) 2022 nosqlbench
*
* 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 io.nosqlbench.engine.api.activityapi.errorhandling.modular.handlers;
import io.nosqlbench.engine.api.activityapi.errorhandling.ErrorMetrics;

View File

@@ -1,3 +1,19 @@
/*
* Copyright (c) 2022 nosqlbench
*
* 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 io.nosqlbench.engine.api.activityapi.errorhandling.modular.handlers;
import io.nosqlbench.engine.api.activityapi.errorhandling.modular.ErrorDetail;

View File

@@ -1,3 +1,19 @@
/*
* Copyright (c) 2022 nosqlbench
*
* 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 io.nosqlbench.engine.api.activityapi.errorhandling.modular.handlers;
import io.nosqlbench.engine.api.activityapi.errorhandling.ErrorMetrics;

View File

@@ -1,3 +1,19 @@
/*
* Copyright (c) 2022 nosqlbench
*
* 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 io.nosqlbench.engine.api.activityapi.errorhandling.modular.handlers;
import io.nosqlbench.engine.api.activityapi.errorhandling.modular.ErrorDetail;

Some files were not shown because too many files have changed in this diff Show More