Package cz.o2.proxima.direct.core.batch

Class BatchLogReaders.ForwardingBatchLogObserver

java.lang.Object

cz.o2.proxima.direct.core.batch.BatchLogReaders.ForwardingBatchLogObserver

All Implemented Interfaces:

BatchLogObserver, LogObserver<Offset,BatchLogObserver.OnNextContext>

Enclosing class:

BatchLogReaders

public static class BatchLogReaders.ForwardingBatchLogObserver
extends java.lang.Object
implements BatchLogObserver

Nested Class Summary

Nested classes/interfaces inherited from interface cz.o2.proxima.direct.core.batch.BatchLogObserver

BatchLogObserver.OnNextContext

Constructor Summary

Constructors

Constructor	Description
ForwardingBatchLogObserver(BatchLogObserver delegate)

Method Summary

Modifier and Type	Method	Description
void	onCancelled()	Notify that the processing has been canceled.
void	onCompleted()	Notify that the processing has gracefully ended.
boolean	onError(java.lang.Throwable error)	Called to notify there was an error in the commit reader.
boolean	onException(java.lang.Exception exception)	Called to notify there was an exception in the commit reader.
boolean	onFatalError(java.lang.Error error)	Called to notify there was an error in the commit reader.
void	onInterrupted()	Called when the consumption is cancelled in case BatchLogObserver.onNext(StreamElement, OnNextContext) method is blocked and should be interrupted.
boolean	onNext(StreamElement element)	Read next data from the batch storage.
boolean	onNext(StreamElement element, BatchLogObserver.OnNextContext context)	Process next record in the commit log.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ForwardingBatchLogObserver

public ForwardingBatchLogObserver(BatchLogObserver delegate)

Method Detail

onNext

public boolean onNext(StreamElement element)

Description copied from interface: BatchLogObserver

Read next data from the batch storage.

Specified by:

onNext in interface BatchLogObserver

Parameters:

element - the retrieved data element

Returns:

true to continue processing, false otherwise

onNext

public boolean onNext(StreamElement element,
                      BatchLogObserver.OnNextContext context)

Description copied from interface: LogObserver

Process next record in the commit log.

Specified by:

onNext in interface BatchLogObserver

Specified by:

onNext in interface LogObserver<Offset,BatchLogObserver.OnNextContext>

Parameters:

element - the element written to the commit log

context - a context that the application must use to confirm processing of the element. If the application fails to do so, the result is undefined.

Returns:

true if the processing should continue, false otherwise

onInterrupted

public void onInterrupted()

Description copied from interface: BatchLogObserver

Called when the consumption is cancelled in case BatchLogObserver.onNext(StreamElement, OnNextContext) method is blocked and should be interrupted.

Specified by:

onInterrupted in interface BatchLogObserver

onCompleted

public void onCompleted()

Description copied from interface: LogObserver

Notify that the processing has gracefully ended.

Specified by:

onCompleted in interface LogObserver<Offset,BatchLogObserver.OnNextContext>

onCancelled

public void onCancelled()

Description copied from interface: LogObserver

Notify that the processing has been canceled.

Specified by:

onCancelled in interface LogObserver<Offset,BatchLogObserver.OnNextContext>

onError

public boolean onError(java.lang.Throwable error)

Description copied from interface: LogObserver

Called to notify there was an error in the commit reader.

Specified by:

onError in interface LogObserver<Offset,BatchLogObserver.OnNextContext>

Parameters:

error - error caught during processing

Returns:

true to restart processing from last committed position, false to stop processing

onException

public boolean onException(java.lang.Exception exception)

Description copied from interface: LogObserver

Called to notify there was an exception in the commit reader. There is no guarantee this method gets called, if LogObserver.onError(Throwable) is overridden.

Specified by:

onException in interface LogObserver<Offset,BatchLogObserver.OnNextContext>

Parameters:

exception - exception caught during processing

Returns:

true to restart processing from last committed position, false to stop processing

onFatalError

public boolean onFatalError(java.lang.Error error)

Description copied from interface: LogObserver

Called to notify there was an error in the commit reader. There is no guarantee this method gets called, if LogObserver.onError(Throwable) is overridden.

Specified by:

onFatalError in interface LogObserver<Offset,BatchLogObserver.OnNextContext>

Parameters:

error - error caught during processing

Returns:

true to restart processing from last committed position, false to stop processing