co.cask.cdap.data.stream

Class StreamFileJanitor

java.lang.Object

co.cask.cdap.data.stream.StreamFileJanitor

public final class StreamFileJanitor
extends Object

Performs deletion of unused stream files.

Constructor Summary

Constructors

Constructor and Description
StreamFileJanitor(CConfiguration cConf, StreamAdmin streamAdmin, NamespacedLocationFactory namespacedLocationFactory, NamespaceStore namespaceStore)

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanAll() Performs file cleanup for all streams.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamFileJanitor

@Inject
public StreamFileJanitor(CConfiguration cConf,
                        StreamAdmin streamAdmin,
                        NamespacedLocationFactory namespacedLocationFactory,
                        NamespaceStore namespaceStore)

Method Detail

cleanAll

public void cleanAll()
              throws Exception

Performs file cleanup for all streams.

Throws:

Exception