cassandra-analytics-core-example/src/main/java/org/apache/cassandra/spark/example/ExampleStorageTransportExtension.java [104:132]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @Override
    public void onObjectPersisted(String bucket, String key, long sizeInBytes)
    {
        LOGGER.info("Object {}/{} for job {} persisted with size {} bytes", bucket, key, jobId, sizeInBytes);
    }

    @Override
    public void onAllObjectsPersisted(long objectsCount, long rowCount, long elapsedMillis)
    {
        LOGGER.info("All {} objects, totaling {} rows, are persisted with elapsed time {}ms",
                    objectsCount, rowCount, elapsedMillis);
    }

    @Override
    public void onObjectApplied(String bucket, String key, long sizeInBytes, long elapsedMillis)
    {

    }

    @Override
    public void onJobSucceeded(long elapsedMillis)
    {
        LOGGER.info("Job {} succeeded with elapsed time {}ms", jobId, elapsedMillis);
    }

    @Override
    public void onJobFailed(long elapsedMillis, Throwable throwable)
    {
        LOGGER.error("Job {} failed after {}ms", jobId, elapsedMillis, throwable);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



cassandra-analytics-core-example/src/main/java/org/apache/cassandra/spark/example/LocalStorageTransportExtension.java [79:107]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @Override
    public void onObjectPersisted(String bucket, String key, long sizeInBytes)
    {
        LOGGER.info("Object {}/{} for job {} persisted with size {} bytes", bucket, key, jobId, sizeInBytes);
    }

    @Override
    public void onAllObjectsPersisted(long objectsCount, long rowCount, long elapsedMillis)
    {
        LOGGER.info("All {} objects, totaling {} rows, are persisted with elapsed time {}ms",
                    objectsCount, rowCount, elapsedMillis);
    }

    @Override
    public void onObjectApplied(String bucket, String key, long sizeInBytes, long elapsedMillis)
    {

    }

    @Override
    public void onJobSucceeded(long elapsedMillis)
    {
        LOGGER.info("Job {} succeeded with elapsed time {}ms", jobId, elapsedMillis);
    }

    @Override
    public void onJobFailed(long elapsedMillis, Throwable throwable)
    {
        LOGGER.error("Job {} failed after {}ms", jobId, elapsedMillis, throwable);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -