Details
-
Bug
-
Status: Open
-
Minor
-
Resolution: Unresolved
-
None
-
None
-
None
Description
The API for creating InputSourceDataInputStream's does not provide a way to configure bucket sizes or cache limits when a BucketingInputSource is used. We need a way to allow this to be configured.
One option is to just modify the InputSOurceDataInptuStream constructor to accept additional parameters.
Another option is to use tunables to configure these, and treat the DataProcessor as a factory for creating InputSourceDataInputStreams. This allows the tunables that are part of the DataProcessor to be passed to the InputSource.