FailOnCloseDataSink.Factory

public final class FailOnCloseDataSink.Factory implements DataSink.Factory

Factory to create a FailOnCloseDataSink.

Summary

Public constructors
Factory(Cache cache, AtomicBoolean failOnClose)

Creates an instance.

Public methods
DataSink

Creates a DataSink instance.

Public constructors

Factory

public Factory(Cache cache, AtomicBoolean failOnClose)

Creates an instance.

Parameters
Cache cache

The cache to write to when not in fail-on-close mode.
AtomicBoolean failOnClose

An AtomicBoolean whose value is read in each call to open to determine whether to enable fail-on-close for the read that's being started.

Public methods

createDataSink

public DataSink createDataSink()

Creates a DataSink instance.