APISonar


org.apache.ignite.internal.IgniteEx.log

> org > apache > ignite > internal > IgniteEx > log
org APIs apache APIs ignite APIs internal APIs IgniteEx APIs log APIs

Example 1
protected transient IgniteEx ignite;

    @Nullable @Override public final R reduce(List<ComputeJobResult> results) {
        try {
            return reduce0(results);
        }
        finally {
            if (debug)
                logFinish(ignite.log(), getClass(), start);
        }
    }
Example 2
protected transient IgniteEx ignite;

    @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, VisorTaskArgument<A> arg) {
        assert arg != null;

        start = U.currentTimeMillis();

        debug = arg.isDebug();

        taskArg = arg.getArgument();

        if (debug)
            logStart(ignite.log(), getClass(), start);

        return map0(subgrid, arg);
    }
Example 3
private static IgniteEx ignite;

    private void assertNotSupported(String explainQry, boolean local) {
        Throwable exc = GridTestUtils.assertThrows(
            ignite.log(),
            () -> cache.query(new SqlFieldsQuery(explainQry).setLocal(local)).getAll(),
            IgniteSQLException.class,
            "Explains of update queries are not supported.");

        IgniteSQLException sqlExc = ((IgniteSQLException)exc);

        assertEquals("Operation error code is not correct.",
            IgniteQueryErrorCode.UNSUPPORTED_OPERATION, sqlExc.statusCode());
    }