| Package | Description |
|---|---|
| co.cask.cdap.data.runtime |
This package contains implementations and guice-bindings needed for data-fabric runtime.
|
| co.cask.cdap.data.stream.service |
This package contains class for running stream http service as well as twill runnable for running the service in
YARN.
|
| Modifier and Type | Class and Description |
|---|---|
class |
InMemoryStreamFileWriterFactory
A Mock
StreamFileWriterFactory that actually doesn't write to file, but to in memory queue instead. |
class |
LocationStreamFileWriterFactory
A
StreamFileWriterFactory that provides FileWriter which writes to file location. |
| Constructor and Description |
|---|
StreamHandler(CConfiguration cConf,
StreamCoordinatorClient streamCoordinatorClient,
StreamAdmin streamAdmin,
StreamFileWriterFactory writerFactory,
MetricsCollectionService metricsCollectionService,
StreamWriterSizeCollector sizeCollector,
AbstractNamespaceClient namespaceClient) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.