Details
-
Type:
New Feature
-
Status: Resolved
-
Priority:
Critical
-
Resolution: Fixed
-
Affects Version/s: v0.9.0, v0.9.1, v0.9.1u1, v0.9.2
-
Fix Version/s: v0.9.3
-
Component/s: Sinks+Sources
-
Labels:None
Description
Currently the collectorsink send to a dfs path only. We would like to reuse some of the logic in the collectorSink (such as closing off acks, rolling policies, etc) when conneting to other sinks like hbase, or to memory for testing.