Package | Description |
---|---|
org.apache.flume.sink.kite.policy |
Modifier and Type | Class and Description |
---|---|
class |
RetryPolicy
A failure policy that logs the error and then forces a retry by throwing
EventDeliveryException . |
class |
SavePolicy
A failure policy that writes the raw Flume event to a Kite dataset.
|
Modifier and Type | Method and Description |
---|---|
FailurePolicy |
SavePolicy.Builder.build(Context config) |
FailurePolicy |
RetryPolicy.Builder.build(Context config) |
FailurePolicy |
FailurePolicy.Builder.build(Context config)
Build a new
FailurePolicy |
FailurePolicy |
FailurePolicyFactory.newPolicy(Context config) |
Copyright © 2009-2017 Apache Software Foundation. All Rights Reserved.