|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use FailurePolicy | |
---|---|
org.apache.flume.sink.kite.policy |
Uses of FailurePolicy in org.apache.flume.sink.kite.policy |
---|
Classes in org.apache.flume.sink.kite.policy that implement FailurePolicy | |
---|---|
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. |
Methods in org.apache.flume.sink.kite.policy that return FailurePolicy | |
---|---|
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)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |