org.apache.flume.channel.file
Class FileChannelConfiguration

java.lang.Object
  org.apache.flume.channel.file.FileChannelConfiguration

public class FileChannelConfiguration
extends Object

Field Summary

static String	CAPACITY Maximum capacity of the channel.
static String	CHECKPOINT_DIR Directory Checkpoints will be written in
static String	CHECKPOINT_INTERVAL Interval at which checkpoints should be taken.
static String	CHECKPOINT_WRITE_TIMEOUT The amount of time in seconds the channel should wait to write the checkpoint when some other operation(s) are enqueued or in progress.
static String	DATA_DIRS Directories data files will be written in.
static int	DEFAULT_CAPACITY
static long	DEFAULT_CHECKPOINT_INTERVAL
static int	DEFAULT_CHECKPOINT_WRITE_TIMEOUT
static int	DEFAULT_KEEP_ALIVE
static long	DEFAULT_MAX_FILE_SIZE
static int	DEFAULT_TRANSACTION_CAPACITY
static int	DEFAULT_WRITE_TIMEOUT
static String	KEEP_ALIVE The length of time we will wait for space available to do a Put.
static String	LOG_WRITE_TIMEOUT The amount of time in seconds a writer will wait before failing when checkpoint is enqueued or in progress.
static String	MAX_FILE_SIZE Max file size for data files, cannot exceed the default.
static String	TRANSACTION_CAPACITY Maximum number of put/take events in a transaction.

Constructor Summary

FileChannelConfiguration()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

CHECKPOINT_DIR

public static final String CHECKPOINT_DIR

Directory Checkpoints will be written in

See Also:

Constant Field Values

DATA_DIRS

public static final String DATA_DIRS

Directories data files will be written in. Multiple directories can be specified as comma separated values. Writes will be written in a round robin fashion.

See Also:

Constant Field Values

TRANSACTION_CAPACITY

public static final String TRANSACTION_CAPACITY

Maximum number of put/take events in a transaction. Default: 1000

See Also:

Constant Field Values

DEFAULT_TRANSACTION_CAPACITY

public static final int DEFAULT_TRANSACTION_CAPACITY

See Also:

Constant Field Values

CHECKPOINT_INTERVAL

public static final String CHECKPOINT_INTERVAL

Interval at which checkpoints should be taken. Default 30s (ms)

See Also:

Constant Field Values

DEFAULT_CHECKPOINT_INTERVAL

public static final long DEFAULT_CHECKPOINT_INTERVAL

See Also:

Constant Field Values

MAX_FILE_SIZE

public static final String MAX_FILE_SIZE

Max file size for data files, cannot exceed the default. Default~ 1.5GB

See Also:

Constant Field Values

DEFAULT_MAX_FILE_SIZE

public static final long DEFAULT_MAX_FILE_SIZE

See Also:

Constant Field Values

CAPACITY

public static final String CAPACITY

Maximum capacity of the channel. This number needs to be configured in line with -XX:MaxDirectMemorySize. FileChannel Default: 1,000,000 which will consume 8MB of direct memory

See Also:

Constant Field Values

DEFAULT_CAPACITY

public static final int DEFAULT_CAPACITY

See Also:

Constant Field Values

KEEP_ALIVE

public static final String KEEP_ALIVE

The length of time we will wait for space available to do a Put. Default: 3 (seconds)

See Also:

Constant Field Values

DEFAULT_KEEP_ALIVE

public static final int DEFAULT_KEEP_ALIVE

See Also:

Constant Field Values

LOG_WRITE_TIMEOUT

public static final String LOG_WRITE_TIMEOUT

The amount of time in seconds a writer will wait before failing when checkpoint is enqueued or in progress.

See Also:

Constant Field Values

DEFAULT_WRITE_TIMEOUT

public static final int DEFAULT_WRITE_TIMEOUT

See Also:

Constant Field Values

CHECKPOINT_WRITE_TIMEOUT

public static final String CHECKPOINT_WRITE_TIMEOUT

The amount of time in seconds the channel should wait to write the checkpoint when some other operation(s) are enqueued or in progress.

See Also:

Constant Field Values

DEFAULT_CHECKPOINT_WRITE_TIMEOUT

public static final int DEFAULT_CHECKPOINT_WRITE_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

FileChannelConfiguration

public FileChannelConfiguration()