IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

update logger deps for dsegraph

Browse Source
This commit is contained in:
Jonathan Shook 2020-11-17 18:08:32 -06:00
parent 975ea40d0c
commit 0ef26c8213
3 changed files with 9 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
driver-dsegraph-shaded/src/main/java/com/datastax/ebdrivers/dsegraph/GraphAction.java
View File

@ -11,15 +11,15 @@ import io.nosqlbench.engine.api.activityapi.core.ActivityDefObserver;
import io.nosqlbench.engine.api.activityapi.core.SyncAction; import io.nosqlbench.engine.api.activityapi.core.SyncAction;
import io.nosqlbench.engine.api.activityapi.planning.OpSequence; import io.nosqlbench.engine.api.activityapi.planning.OpSequence;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import org.slf4j.Logger; import org.apache.logging.log4j.LogManager;
import org.slf4j.LoggerFactory; import org.apache.logging.log4j.Logger;
import java.util.List; import java.util.List;
@SuppressWarnings("Duplicates") @SuppressWarnings("Duplicates")
public class GraphAction implements SyncAction, ActivityDefObserver { public class GraphAction implements SyncAction, ActivityDefObserver {
private static final Logger logger = LoggerFactory.getLogger(GraphAction.class); private static final Logger logger = LogManager.getLogger(GraphAction.class);
List<BindableGraphStatement> readyGraphStmts; List<BindableGraphStatement> readyGraphStmts;
private final int slot; private final int slot;
private final GraphActivity activity; private final GraphActivity activity;

9
driver-dsegraph-shaded/src/main/java/com/datastax/ebdrivers/dsegraph/GraphActivity.java
View File

@ -17,7 +17,6 @@ import io.nosqlbench.engine.api.activityapi.planning.SequencerType;
import io.nosqlbench.engine.api.activityconfig.ParsedStmt; import io.nosqlbench.engine.api.activityconfig.ParsedStmt;
import io.nosqlbench.engine.api.activityconfig.StatementsLoader; import io.nosqlbench.engine.api.activityconfig.StatementsLoader;
import io.nosqlbench.engine.api.activityconfig.yaml.OpTemplate; import io.nosqlbench.engine.api.activityconfig.yaml.OpTemplate;
import io.nosqlbench.engine.api.activityconfig.yaml.StmtDef;
import io.nosqlbench.engine.api.activityconfig.yaml.StmtsDocList; import io.nosqlbench.engine.api.activityconfig.yaml.StmtsDocList;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import io.nosqlbench.engine.api.activityimpl.ParameterMap; import io.nosqlbench.engine.api.activityimpl.ParameterMap;
@ -27,8 +26,8 @@ import io.nosqlbench.engine.api.metrics.ExceptionMeterMetrics;
import io.nosqlbench.engine.api.scripting.NashornEvaluator; import io.nosqlbench.engine.api.scripting.NashornEvaluator;
import io.nosqlbench.engine.api.templating.StrInterpolator; import io.nosqlbench.engine.api.templating.StrInterpolator;
import io.nosqlbench.engine.api.util.TagFilter; import io.nosqlbench.engine.api.util.TagFilter;
import org.slf4j.Logger; import org.apache.logging.log4j.LogManager;
import org.slf4j.LoggerFactory; import org.apache.logging.log4j.Logger;
import java.io.IOException; import java.io.IOException;
import java.nio.file.Files; import java.nio.file.Files;
@ -37,12 +36,10 @@ import java.nio.file.Paths;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.Optional; import java.util.Optional;
import java.util.stream.Stream;
import java.util.stream.StreamSupport;
@SuppressWarnings("Duplicates") @SuppressWarnings("Duplicates")
public class GraphActivity extends SimpleActivity implements ActivityDefObserver { public class GraphActivity extends SimpleActivity implements ActivityDefObserver {
private final static Logger logger = LoggerFactory.getLogger(GraphActivity.class); private final static Logger logger = LogManager.getLogger(GraphActivity.class);
public Timer bindTimer; public Timer bindTimer;
public Timer executeTimer; public Timer executeTimer;

6
driver-dsegraph-shaded/src/main/java/com/datastax/ebdrivers/dsegraph/errorhandling/GraphErrorHandler.java
View File

@ -3,14 +3,14 @@ package com.datastax.ebdrivers.dsegraph.errorhandling;
import com.datastax.driver.core.exceptions.*; import com.datastax.driver.core.exceptions.*;
import com.datastax.driver.dse.graph.GraphStatement; import com.datastax.driver.dse.graph.GraphStatement;
import io.nosqlbench.engine.api.metrics.ExceptionMeterMetrics; import io.nosqlbench.engine.api.metrics.ExceptionMeterMetrics;
import org.slf4j.Logger; import org.apache.logging.log4j.LogManager;
import org.slf4j.LoggerFactory; import org.apache.logging.log4j.Logger;
import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutionException;
@SuppressWarnings("Duplicates") @SuppressWarnings("Duplicates")
public class GraphErrorHandler { public class GraphErrorHandler {
private final static Logger logger = LoggerFactory.getLogger(GraphErrorHandler.class); private final static Logger logger = LogManager.getLogger(GraphErrorHandler.class);
private final ErrorResponse realErrorResponse; private final ErrorResponse realErrorResponse;
// private final ErrorResponse unappliedResponse; // private final ErrorResponse unappliedResponse;